問題描述

這里寫問題描述
3個(gè)websocket，如何讓每一個(gè)Gateway的數(shù)據(jù)怎么定指定到哪個(gè)businessworker上來處理啊，在webman的config文件夾里怎么配置?。?br /> 比如chatmsg的Gateway 指定到 'eventHandler' => common\sockets\ChatEvents::class,
notice的的Gateway 指定到 'eventHandler' => common\sockets\NoticeEvents::class,
channel的Gateway 指定到 'eventHandler' => common\sockets\ChannelEvents::class,
在webman的config文件夾里怎么配置?。?/p>

return [
     // msg 用于聊天
    'chatmsg' => [
        'handler'     => Gateway::class,
        'listen'      => 'websocket://0.0.0.0:7272',
        'count'       => 1,
        'reloadable'  => false,
        'constructor' => ['config' => [
            'lanIp'           => '127.0.0.1',
            'startPort'       => 2300,
            'pingInterval'    => 20,
            'pingData'        => '{"type":"ping"}',
            'registerAddress' => '127.0.0.1:1236',
            'onConnect'       => function(){},
        ]]
    ], 
    // notice 新訂單和新退款單 消息通知
   'notice' => [
        'handler'     => Gateway::class,
        'listen'      => 'websocket://0.0.0.0:7273',
        'count'       => 1,
        'reloadable'  => false,
        'constructor' => ['config' => [
            'lanIp'           => '127.0.0.1',
            'startPort'       => 2300,
            'pingInterval'    => 20,
            'pingData'        => '{"type":"ping"}',
            'registerAddress' => '127.0.0.1:1236',
            'onConnect'       => function(){},
        ]]
    ],         
    // 系統(tǒng)程序接收到發(fā)送過來的消息
    'channel' => [
        'handler'     => Gateway::class,
        'listen'      => 'frame://0.0.0.0:7274',
        'count'       => 1,
        'reloadable'  => false,
        'constructor' => ['config' => [
            'lanIp'           => '127.0.0.1',
            'startPort'       => 2300,
            'pingInterval'    => 20,
            'pingData'        => '{"type":"ping"}',
            'registerAddress' => '127.0.0.1:1236',
            'onConnect'       => function(){},
        ]]
    ], 

    'businesser' => [
        'handler'     => BusinessWorker::class,
        'count'       => cpu_count()*2,
        'constructor' => ['config' => [
            //'eventHandler'    => plugin\webman\gateway\Events::class,
            'eventHandler'    => common\sockets\ChatEvents::class,
            'name'            => 'ChatBusinessWorker',
            'registerAddress' => '127.0.0.1:1236',
        ]]
    ],
    'register' => [
        'handler'     => Register::class,
        'listen'      => 'text://127.0.0.1:1236',
        'count'       => 1, // Must be 1
        'constructor' => []
    ],
];