发表新帖

多进程的协程websocket服务端如何获取其他进程的wsObjects

### 问题描述
我现在使用的是多进程+ websocket协程服务端, A,B,C,D四个进程,每个进程都有单独的 $wsObjects, 请问如果在B 里面获取A里面的$wsObjects

### Swoole版本，PHP版本，以及操作系统版本信息
swoole 4.4 php7.4

### 相关代码
```php
        $workerNum = swoole_cpu_num();
        $pool = new \Swoole\Process\Pool($workerNum,SWOOLE_IPC_UNIXSOCK,0,true);
        $pool->on("WorkerStart", function ($pool, $workerId) {
            echo "Worker#{$workerId} is started\n";
            //每个进程都监听9504端口
            $server = new \Co\Http\Server("0.0.0.0", '9501', false, true);
            //收到15信号关闭服务
            pcntl_signal(SIGTERM, function () use ($server) {
                $server->shutdown();
            });
            //监听全网段地址、端口
            $server->handle('/websocket', function ($request, $ws) use ($workerId,$pool) {
                $ws->upgrade();//向客户端发送websocket握手信息
                global $wsObjects;
                $objectId = spl_object_id($ws);
                $wsObjects[$objectId] = $ws;
                $cid = \Co::getCid();
                echo "Client: {$cid } connect\n";
                while (true) {
                    $frame = $ws->recv();
                    if ($frame === '' || $frame->data == 'close' || get_class($frame) === \Swoole\WebSocket\CloseFrame::class) {
                        echo "Client: {$cid} close\n";
                        unset($wsObjects[$objectId]);
                        $ws->close();
                        break;
                    } else if ($frame === false) {
                        echo 'error : ' . swoole_last_error() . "\n";
                        break;
                    } else {
                        echo "receive from {$cid}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
                        $args = json_decode($frame->data,true);
                      
                    }
                }
            });
            $server->start();
        });
        $pool->on("WorkerStop", function ($pool, $workerId) {
            echo "Worker#{$workerId} is stopped\n";
        });
        $pool->start();
```

### 你期待的结果是什么？实际看到的错误信息又是什么？
能取到另一个进程里面的 $wsObjects 或者$ws对象

发布于3年前 · 6 次浏览 · 来自提问