diff --git a/app/common/service/workerim/start_businessworker.php b/app/common/service/workerim/start_businessworker.php index 99f51d8cf..07d89103e 100644 --- a/app/common/service/workerim/start_businessworker.php +++ b/app/common/service/workerim/start_businessworker.php @@ -17,7 +17,7 @@ $worker->name = 'PushBusinessWorker'; $worker->count = 4; // 服务注册地址 -$worker->registerAddress = env('worker.address').':'.env('worker.port'); +$worker->registerAddress = '172.19.97.179:1256'; // 注册服务类 $worker->eventHandler = 'app\common\service\workerim\Events'; diff --git a/app/common/service/workerim/start_gateway.php b/app/common/service/workerim/start_gateway.php index 5c653259f..b925962ed 100644 --- a/app/common/service/workerim/start_gateway.php +++ b/app/common/service/workerim/start_gateway.php @@ -10,20 +10,20 @@ require_once __DIR__ . '/../../../../vendor/autoload.php'; $gateway = new Gateway("Websocket://0.0.0.0:8282"); // gateway名称,status方便查看 -$gateway->name = env('worker.work_name'); +$gateway->name = 'worker_task_im'; // gateway进程数,一般设置2个就足够 $gateway->count = 4; // 本机ip,分布式部署时使用内网ip -$gateway->lanIp = env('worker.address'); +$gateway->lanIp = '172.19.97.179'; // 内部通讯起始端口,假如$gateway->count=2,起始端口为2900 // 则一般会使用3900 3901 3902 3903 4个端口作为内部通讯端口 -$gateway->startPort = env('worker.start_port'); +$gateway->startPort = 3900; // 服务注册地址 -$gateway->registerAddress = env('worker.address').':'.env('worker.port'); +$gateway->registerAddress = '172.19.97.179:1256'; // 心跳间隔 $gateway->pingInterval = 20; diff --git a/app/common/service/workerim/start_register.php b/app/common/service/workerim/start_register.php index aa0d8b34f..d2da32b52 100644 --- a/app/common/service/workerim/start_register.php +++ b/app/common/service/workerim/start_register.php @@ -6,7 +6,7 @@ use \GatewayWorker\Register; require_once __DIR__ . '/../../../../vendor/autoload.php'; // register 必须是text协议,切记不能将register端口开放给外网 -$register = new Register('text://'.env('worker.address').':'.env('worker.port')); +$register = new Register('text://172.19.97.179:1256'); // 如果不是在根目录启动,则运行runAll方法 if(!defined('GLOBAL_START'))