$worker->onWorkerStart = function($worker)
    {
        // 開啟一個內(nèi)部端口，方便內(nèi)部系統(tǒng)推送數(shù)據(jù)，Text協(xié)議格式 文本+換行符
        $inner_text_worker = new Worker('Text://0.0.0.0:5678');
        $inner_text_worker->onMessage = function($connection, $buffer)
        {
            global $worker;
            // $data數(shù)組格式，里面有uid，表示向那個uid的頁面推送數(shù)據(jù)
            $data = json_decode($buffer, true);
            $uid = $data['uid'];
            $url=$data['url'];
            // 通過workerman，向uid的頁面推送數(shù)據(jù)
            $ret = sendMessageByUid($uid, $url);

            // 返回推送結(jié)果
            $connection->send($ret ? 'ok' : 'fail');
        };
        $inner_text_worker->listen();
    };

這樣子使用好像沒什么用