Gateway监听多个端口(每个端口的协议不同)时，不能同时工作

kenny534 更新于2019-10-30

如题：只有第一个端口(9526)可以触发Events的onMessage方法,而9527端口只能连接上，onMessage不会被调用到

$register = new Register('text://0.0.0.0:1237');

//初始化 bussinessWorker 进程
$worker = new BusinessWorker();
// worker名称
$worker->name = 'AppBusinessWorker';
// bussinessWorker进程数量
$worker->count = 2;
// 服务注册地址
$worker->registerAddress = '192.168.18.9:1237';
//设置处理业务的类,此处制定Events的命名空间
$worker->eventHandler = 'app\kenny\controller\Events';

// 初始化 gateway 进程
$gateway = new Gateway("book://0.0.0.0:9526");
// 设置名称，方便status时查看
$gateway->name = 'AppGateway';
$gateway->count = 1;
// 分布式部署时请设置成内网ip（非127.0.0.1）
$gateway->lanIp = '192.168.18.9';

$gateway->startPort = 2300;
// 心跳间隔
$gateway->pingInterval = 180;
$gateway->pingNotResponseLimit = 1;
// 心跳数据
$gateway->pingData = "\n|\n";
// 服务注册地址
$gateway->registerAddress = "192.168.18.9:1237";

$gateway->onWorkerStart = function ($gateway){
    if ($gateway->id === 0){ //仅在第二个gateway中监听websocket
        $inner_gateway = new Gateway("text://0.0.0.0:9527");
        $inner_gateway->reusePort = true;
        $inner_gateway->listen();
    }
};

//运行所有Worker;
Worker::runAll();

请问这是GatewayWorker模型的设计所致，还是哪里使用的不对头？

 5403  4 0

4个回答

kenny534 2019-09-16

追问一下：GatewayWorker是否可以实现协议之间的通讯？
例如：开启两个gateway ： gateway1（text协议）和 gateway2(websocket) ，实现在两个端口上监听。
在gateway1 接收消息，再从gateway2发送出去，或者从gateway2收到消息，再发到gateway1上去，当然，这就涉及到“协议间通讯”的问题了。请问是否能够支持呢？

暂无评论

walkor 2019-09-16

打赏

http://doc2.workerman.net/multi-protocols.html
多协议支持请参考手册

kenny534 2019-09-17

能否在onMessage回调中增加一个“协议名称”的参数，用于识别当前数据是哪个协议下发来的，而不是通过判断数据的结构特点先识别出协议，再调用该协议下的decode方法？
如果有这个参数的话，那么 onMessage里可以让代码简化一些，例如：
if ($protocol == 'text' ) {
$message = text::decode($buffer);
}
if ($protocol == 'websocket' ){
$message = websocket::decode($buffer);
}
//上述代码应该不能正常运行，是伪代码。
https://wenda.workerman.net/question/57
这个链接中的方法需要判断$buffer的格式来识别协议，当前的版本如果要实现我的上述想法，应该怎么做？框架是否可以考虑增加一个可选参数，比如叫 $protocol ?
walkor 2019-09-17

协议是和端口绑定的，可以通过端口来判断协议类型。参考手册 http://doc2.workerman.net/get-gateway-port.html
kenny534 2019-09-17

怎样才能调用到协议的decode/encode方法呢？我写的那小段运行报错。
kenny534 2019-09-17

1：
在gateway3.0.13下，无法像（https://wenda.workerman.net/question/57）文中提到的：
$message = yourIOSProtocol::decode($buffer);
这样调用自定义协议的解码方法，如果用require '..../yourIOSProtocol.php'，又会报重复定义的错误。烦请给一个示例
2：
《多协议支持》章节最底部的说明：
/支持多协议还有其他的方法，比如通过协议自身的特点区分当前是哪种协议，然后分别调用相应协议的解码方法，这样可以做到只开一个端口就可以支持多种协议的效果/
如何实现“分别调用相应协议的解码方法”呢？调用之后，怎样找到对端，将数据发出去。
latin 2019-09-18

多协议用群主发的文档的方式不用调用协议的decode/encode方法啊，怎么感觉你搞复杂了。

phpcreeper 2019-09-16

使用姿势不正确，原因是 gateway的用户回调onWorkerStart 的内部端口此时并不能与bussinessworker建立连接，按官方手册方法玩吧，非要这么用的话，参考代码：


$gateway->onWorkerStart = function($gateway){
    if ($gateway->id === 0)
    {
        //step-1
        $inner_gateway = new Gateway("text://0.0.0.0:9527");
        $inner_gateway->reusePort = true;
        $inner_gateway->lanIp = '127.0.0.1';
        $inner_gateway->startPort = 3900;
        $inner_gateway->lanPort = $inner_gateway->startPort + $gateway->id;
        $inner_gateway->registerAddress = ;
        $inner_gateway->onConnect  = array($inner_gateway, 'onClientConnect');
        $inner_gateway->onClose = array($inner_gateway, 'onClientClose');
        $inner_gateway->onMessage = array($inner_gateway, 'onClientMessage');
        $inner_gateway->listen();

        //step-2
        $worker = new Worker("GatewayProtocol://{$inner_gateway->lanIp}:{$inner_gateway->lanPort}");
        $worker->name = 'testWorker';
        $worker->onMessage = array($inner_gateway, 'onWorkerMessage');
        $worker->onConnect = array($inner_gateway, 'onWorkerConnect');
        $worker->onClose   = array($inner_gateway, 'onWorkerClose');
        $worker->listen();

        //step-3
        $inner_gateway->registerAddress();
    }
};