up.
This commit is contained in:
parent
fbc0a5ecd2
commit
2c3ccbabb6
@ -14,6 +14,8 @@ use Workerman\Worker;
|
||||
|
||||
class SysGateway extends Command
|
||||
{
|
||||
private string $registerAddress;
|
||||
|
||||
protected function configure()
|
||||
{
|
||||
$this->setName('admin:gateway')
|
||||
@ -35,6 +37,9 @@ class SysGateway extends Command
|
||||
$argv[] = '-g';
|
||||
}
|
||||
|
||||
$this->registerAddress = config('gateway.registerAddress', '127.0.0.1:1236');
|
||||
|
||||
|
||||
/*
|
||||
* 载入注册中心
|
||||
*/
|
||||
@ -51,7 +56,7 @@ class SysGateway extends Command
|
||||
$worker = new BusinessWorker();
|
||||
$worker->name = 'AdminBusinessWorker';
|
||||
$worker->count = 4;
|
||||
$worker->registerAddress = '127.0.0.1:1236';
|
||||
$worker->registerAddress = $this->registerAddress;
|
||||
$worker->eventHandler = SysGatewayEvent::class;
|
||||
|
||||
// 运行所有服务
|
||||
@ -61,12 +66,12 @@ class SysGateway extends Command
|
||||
|
||||
private function startRegister(): Register
|
||||
{
|
||||
return new Register('text://127.0.0.1:1236');
|
||||
return new Register("text://$this->registerAddress");
|
||||
}
|
||||
private function startGateway(): \GatewayWorker\Gateway
|
||||
{
|
||||
// gateway 进程
|
||||
$gateway = new \GatewayWorker\Gateway("Websocket://0.0.0.0:19981");
|
||||
$gateway = new \GatewayWorker\Gateway('Websocket://'.config('gateway.websocketAddress', '0.0.0.0:19981'));
|
||||
// 设置名称,方便status时查看
|
||||
$gateway->name = 'AdminGateway';
|
||||
// 设置进程数,一般两个进程就足够
|
||||
@ -81,7 +86,7 @@ class SysGateway extends Command
|
||||
// 心跳数据
|
||||
$gateway->pingData = '{"type":"ping"}';
|
||||
// 服务注册地址
|
||||
$gateway->registerAddress = '127.0.0.1:1236';
|
||||
$gateway->registerAddress = $this->registerAddress;
|
||||
|
||||
/*
|
||||
// 当客户端连接上来时,设置连接的onWebSocketConnect,即在websocket握手时的回调
|
||||
|
||||
@ -18,5 +18,9 @@ return [
|
||||
'cls' => [
|
||||
'secretId' => 'AKIDz6HXnBZ0Pm5UtEXlv5BThrwvsmcM0a5e',
|
||||
'secretKey' => 'eGoIj6QiYSLBFNTsIdv8GxZOWaWWcn8R'
|
||||
],
|
||||
'gateway' => [
|
||||
'websocketAddress' => env('GATEWAY_WEBSOCKET_ADDRESS','0.0.0.0:19981'),
|
||||
'registerAddress'=> env('GATEWAY_REGISTER_ADDRESS', '127.0.0.1:1236'),
|
||||
]
|
||||
];
|
||||
Loading…
Reference in New Issue
Block a user