問題描述

需要用到兩個協(xié)議，ws和客戶端聯(lián)系，tcp和機(jī)器聯(lián)系
webman框架集成了gatewayworker

程序代碼或配置

<?php

use Webman\GatewayWorker\Gateway;
use Webman\GatewayWorker\BusinessWorker;
use Webman\GatewayWorker\Register;

return [
    'gateway' => [
        'handler'     => Gateway::class,
        'listen'      => 'tcp://0.0.0.0:8950',
        'count'       => cpu_count(),
        'reloadable'  => false,
        'constructor' => ['config' => [
            'lanIp'           => '127.0.0.1',
            'startPort'       => 2400,
            'pingInterval'    => 10,
            'pingData'        => \app\services\BallMagicService::COMMAND_HEALTH_CHECK, //心跳,
            'registerAddress' => '127.0.0.1:1236',
            'onConnect'       => function(){},
            'pingNotResponseLimit' => 1,
        ]]
    ],
    'worker' => [
        'handler'     => BusinessWorker::class,
        'count'       => cpu_count()*2,
        'constructor' => ['config' => [
            'eventHandler'    => plugin\webman\gateway\Events::class,
            'name'            => 'TcpBusinessWorker',
            'registerAddress' => '127.0.0.1:1236',
        ]]
    ],
    //ws
    'gateway_ws' => [
        'handler'     => Gateway::class,
        'listen'      => 'websocket://0.0.0.0:5252',
        'count'       => cpu_count(),
        'reloadable'  => false,
        'constructor' => ['config' => [
            'lanIp'           => '127.0.0.1',
            'startPort'       => 2300,
            'pingInterval'    => 10,
            'pingData'        => '123456', //心跳,
            'registerAddress' => '127.0.0.1:1236',
            'onConnect'       => function(){},
            'pingNotResponseLimit' => 1,
        ]]
    ],
    'worker_ws' => [
        'handler'     => BusinessWorker::class,
        'count'       => cpu_count()*2,
        'constructor' => ['config' => [
            'eventHandler'    => plugin\webman\gateway\WebSocketEvents::class,
            'name'            => 'WsBusinessWorker',
            'registerAddress' => '127.0.0.1:1236',
        ]]
    ],

    'register' => [
        'handler'     => Register::class,
        'listen'      => 'text://127.0.0.1:1236',
        'count'       => 1, // Must be 1
        'constructor' => []
    ],
];

重現(xiàn)問題的步驟

機(jī)器發(fā)送的tcp數(shù)據(jù)在wsEvent里了。兩個協(xié)議數(shù)據(jù)互相串。一下子正常，一下子又出問題