listen

    此方法主要用于在Worker进程启动后动态创建新的Worker实例，能够实现同一个进程监听多个端口，支持多种协议。

    例如一个http Worker启动后实例化一个websocket Worker，那么这个进程即能通过http协议访问，又能通过websocket协议访问。由于websocket Worker和http Worker在同一个进程中，所以它们可以访问共同的内存变量，共享所有socket连接。可以做到接收http请求，然后操作websocket客户端完成向客户端推送数据类似的效果。

    注意：

    如果PHP版本<=7.0，则不支持在多个子进程中实例化相同端口的Worker。例如A进程创建了监听2016端口的Worker，那么B进程就不能再创建监听2016端口的Worker，否则会报错误。例如下面的代码是无法运行的。

    1. use Workerman\Worker;
    2. require_once __DIR__ . '/Workerman/Autoloader.php';
    4. $worker = new Worker();
    5. // 4个进程
    6. $worker->count = 4;
    7. // 每个进程启动后在当前进程新增一个Worker监听
    8. $worker->onWorkerStart = function($worker)
    9. {
    10.     /**
    11.      * 4个进程启动的时候都创建2016端口的Worker
    12.      * 当执行到worker->listen()时会报Address already in use错误
    13.      * 如果worker->count=1则不会报错
    14.      */
    15.     $inner_worker = new Worker('http://0.0.0.0:2016');
    16.     $inner_worker->onMessage = 'on_message';
    17.     // 执行监听。这里会报Address already in use错误
    18.     $inner_worker->listen();
    19. };
    21. $worker->onMessage = 'on_message';
    23. function on_message($connection, $data)
    24. {
    25.     $connection->send("hello\n");
    26. }
    28. // 运行worker
    29. Worker::runAll();

    原理：

    1、建立一个websocket Worker，用来维持客户端长连接

    2、websocket Worker内部建立一个text Worker

    3、websocket Worker 与 text Worker是同一个进程，可以方便的共享客户端连接

    5、text Worker操作websocket连接完成数据推送

    代码及步骤

    push.php

    1. <?php
    2. use Workerman\Worker;
    3. require_once './Workerman/Autoloader.php';
    4. // 初始化一个worker容器，监听1234端口
    5. $worker = new Worker('websocket://0.0.0.0:1234');
    7. /*
    8.  * 注意这里进程数必须设置为1，否则会报端口占用错误
    9.  * (php 7可以设置进程数大于1，前提是$inner_text_worker->reusePort=true)
    10.  */
    11. // worker进程启动后创建一个text Worker以便打开一个内部通讯端口
    12. $worker->onWorkerStart = function($worker)
    13. {
    14.     // 开启一个内部端口，方便内部系统推送数据，Text协议格式 文本+换行符
    15.     $inner_text_worker = new Worker('text://0.0.0.0:5678');
    16.     $inner_text_worker->onMessage = function($connection, $buffer)
    17.     {
    18.         // $data数组格式，里面有uid，表示向那个uid的页面推送数据
    19.         $data = json_decode($buffer, true);
    20.         $uid = $data['uid'];
    21.         // 通过workerman，向uid的页面推送数据
    22.         $ret = sendMessageByUid($uid, $buffer);
    23.         // 返回推送结果
    24.         $connection->send($ret ? 'ok' : 'fail');
    25.     };
    26.     // ## 执行监听 ##
    27.     $inner_text_worker->listen();
    28. };
    29. // 新增加一个属性，用来保存uid到connection的映射
    30. $worker->uidConnections = array();
    31. // 当有客户端发来消息时执行的回调函数
    32. $worker->onMessage = function($connection, $data)
    33. {
    34.     global $worker;
    35.     // 判断当前客户端是否已经验证,既是否设置了uid
    36.     if(!isset($connection->uid))
    37.     {
    38.        // 没验证的话把第一个包当做uid（这里为了方便演示，没做真正的验证）
    39.        $connection->uid = $data;
    40.        /* 保存uid到connection的映射，这样可以方便的通过uid查找connection，
    41.         * 实现针对特定uid推送数据
    42.         */
    43.        $worker->uidConnections[$connection->uid] = $connection;
    44.        return;
    45.     }
    46. };
    48. // 当有客户端连接断开时
    49. $worker->onClose = function($connection)
    50. {
    51.     if(isset($connection->uid))
    52.     {
    53.         // 连接断开时删除映射
    54.         unset($worker->uidConnections[$connection->uid]);
    55.     }
    56. };
    58. // 向所有验证的用户推送数据
    59. function broadcast($message)
    60. {
    61.    global $worker;
    62.    foreach($worker->uidConnections as $connection)
    63.    {
    64.         $connection->send($message);
    65.    }
    66. }
    68. // 针对uid推送数据
    69. function sendMessageByUid($uid, $message)
    70. {
    71.     global $worker;
    72.     if(isset($worker->uidConnections[$uid]))
    73.     {
    74.         $connection = $worker->uidConnections[$uid];
    75.         $connection->send($message);
    76.         return true;
    77.     }
    78.     return false;
    79. }
    81. // 运行所有的worker
    82. Worker::runAll();

    启动后端服务
    php push.php start -d

    后端推送消息的代码

    1. // 建立socket连接到内部推送端口
    2. $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);
    3. // 推送的数据，包含uid字段，表示是给这个uid推送
    4. $data = array('uid'=>'uid1', 'percent'=>'88%');
    5. // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
    6. fwrite($client, json_encode($data)."\n");
    7. // 读取推送结果