关于workerman做客户端进行中转求解

问题描述

需要用ws链接其他服务器的，然后收到数据后转发给自己的客户端
现在用的是AsyncTcpConnection

看文档AsyncTcpConnection 定义在onWorkerStart中但是worker有多个进程会导致启动多个

想的有几个方案哪个方案比较好呢,或者有没有更好的方案推荐

// 方案1：
//  一个channel
//  workerA 去链接外部服务器  收到消息使用channel发给客户端  并监听workerB客户端的消息
//  workerB 在onWorkerStart中 监听channel的消息  发给客户端 并监听客户端消息发给workerA

$channel_server = new Channel\Server();

// workerA负责接收其他服务器信息并发布给B
$workerA = new Worker();
$workerA->onWorkerStart = function($worker){

    Channel\Client::connect('127.0.0.1', 2206);

    $otherServer = new AsyncTcpConnection("ws://0.0.0.0:8765");
    $otherServer->onMessage = function($con, $data){
        Channel\Client::publish('newData','新数据');
    };
    $otherServer->connect();

    //监听客户端要给other发消息
    Channel\Client::on('clientData', function($event_data)use($otherServer){
        $otherServer->send($event_data);
    });
};

//workerB负责接收信息并发布给客户端
$workerB = new Worker("websocket://0.0.0.0:1002");
$workerB->count = 4;
$workerB->onWorkerStart = function($worker){

    Channel\Client::connect('127.0.0.1', 2206);
    Channel\Client::on('newData', function($event_data)use($worker){
        // 向所有客户端广播消息
        foreach($worker->connections as $connection)
        {
            $connection->send($event_data);
        }
    });
};
$workerB->onMessage = function($con,$data){
    Channel\Client::publish('clientData','客户端给other发消息');
};

Worker::runAll();

另外使用全局变量是否可行呢

$otherServer;
$workerA = new Worker();
$workerB = new Worker("websocket://0.0.0.0:1002");
$workerB->count = 4;

$workerA->onWorkerStart = function($worker){
    global $otherServer;
    $otherServer = new AsyncTcpConnection("ws://0.0.0.0:8765");
    $otherServer->onMessage = function($con, $data){
        global $workerB;
        foreach($workerB->connections as $connection)
        {
            $connection->send($data);
        }
    };
    $otherServer->connect();
};

$workerB->onMessage = function($con,$data){
    global $otherServer;
    $otherServer->send($data);
};

Worker::runAll();