<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ThinkChat2.0新版上線,更智能更精彩,支持會話、畫圖、視頻、閱讀、搜索等,送10W Token,即刻開啟你的AI之旅 廣告
                # listen ```php void Worker::listen(void) ``` 用于實例化Worker后執行監聽。 此方法主要用于在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,否則會報```Address already in use```錯誤。例如下面的代碼是```無法```運行的。 ```php use Workerman\Worker; require_once __DIR__ . '/Workerman/Autoloader.php'; $worker = new Worker(); // 4個進程 $worker->count = 4; // 每個進程啟動后在當前進程新增一個Worker監聽 $worker->onWorkerStart = function($worker) { /** * 4個進程啟動的時候都創建2016端口的Worker * 當執行到worker->listen()時會報Address already in use錯誤 * 如果worker->count=1則不會報錯 */ $inner_worker = new Worker('http://0.0.0.0:2016'); $inner_worker->onMessage = 'on_message'; // 執行監聽。這里會報Address already in use錯誤 $inner_worker->listen(); }; $worker->onMessage = 'on_message'; function on_message($connection, $data) { $connection->send("hello\n"); } // 運行worker Worker::runAll(); ``` 如果您的PHP版本>=7.0,可以設置Worker->reusePort=true, 這樣可以做到多個子進程創建相同端口的Worker。見下面的例子: ```php use Workerman\Worker; require_once './Workerman/Autoloader.php'; $worker = new Worker('text://0.0.0.0:2015'); // 4個進程 $worker->count = 4; // 每個進程啟動后在當前進程新增一個Worker監聽 $worker->onWorkerStart = function($worker) { $inner_worker = new Worker('http://0.0.0.0:2016'); // 設置端口復用,可以創建監聽相同端口的Worker(需要PHP>=7.0) $inner_worker->reusePort = true; $inner_worker->onMessage = 'on_message'; // 執行監聽。正常監聽不會報錯 $inner_worker->listen(); }; $worker->onMessage = 'on_message'; function on_message($connection, $data) { $connection->send("hello\n"); } // 運行worker Worker::runAll(); ``` ### 示例 php后端及時推送消息給客戶端 **原理:** 1、建立一個websocket Worker,用來維持客戶端長連接 2、websocket Worker內部建立一個text Worker 3、websocket Worker 與 text Worker是同一個進程,可以方便的共享客戶端連接 4、某個獨立的php后臺系統通過text協議與text Worker通訊 5、text Worker操作websocket連接完成數據推送 **代碼及步驟** push.php ```php <?php use Workerman\Worker; require_once './Workerman/Autoloader.php'; // 初始化一個worker容器,監聽1234端口 $worker = new Worker('websocket://0.0.0.0:1234'); /* * 注意這里進程數必須設置為1,否則會報端口占用錯誤 * (php 7可以設置進程數大于1,前提是$inner_text_worker->reusePort=true) */ $worker->count = 1; // worker進程啟動后創建一個text Worker以便打開一個內部通訊端口 $worker->onWorkerStart = function($worker) { // 開啟一個內部端口,方便內部系統推送數據,Text協議格式 文本+換行符 $inner_text_worker = new Worker('text://0.0.0.0:5678'); $inner_text_worker->onMessage = function($connection, $buffer) { // $data數組格式,里面有uid,表示向那個uid的頁面推送數據 $data = json_decode($buffer, true); $uid = $data['uid']; // 通過workerman,向uid的頁面推送數據 $ret = sendMessageByUid($uid, $buffer); // 返回推送結果 $connection->send($ret ? 'ok' : 'fail'); }; // ## 執行監聽 ## $inner_text_worker->listen(); }; // 新增加一個屬性,用來保存uid到connection的映射 $worker->uidConnections = array(); // 當有客戶端發來消息時執行的回調函數 $worker->onMessage = function($connection, $data) { global $worker; // 判斷當前客戶端是否已經驗證,既是否設置了uid if(!isset($connection->uid)) { // 沒驗證的話把第一個包當做uid(這里為了方便演示,沒做真正的驗證) $connection->uid = $data; /* 保存uid到connection的映射,這樣可以方便的通過uid查找connection, * 實現針對特定uid推送數據 */ $worker->uidConnections[$connection->uid] = $connection; return; } }; // 當有客戶端連接斷開時 $worker->onClose = function($connection) { global $worker; if(isset($connection->uid)) { // 連接斷開時刪除映射 unset($worker->uidConnections[$connection->uid]); } }; // 向所有驗證的用戶推送數據 function broadcast($message) { global $worker; foreach($worker->uidConnections as $connection) { $connection->send($message); } } // 針對uid推送數據 function sendMessageByUid($uid, $message) { global $worker; if(isset($worker->uidConnections[$uid])) { $connection = $worker->uidConnections[$uid]; $connection->send($message); return true; } return false; } // 運行所有的worker Worker::runAll(); ``` 啟動后端服務 ```php push.php start -d``` 前端接收推送的js代碼 ```php var ws = new WebSocket('ws://127.0.0.1:1234'); ws.onopen = function(){ var uid = 'uid1'; ws.send(uid); }; ws.onmessage = function(e){ alert(e.data); }; ``` 后端推送消息的代碼 ```php // 建立socket連接到內部推送端口 $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1); // 推送的數據,包含uid字段,表示是給這個uid推送 $data = array('uid'=>'uid1', 'percent'=>'88%'); // 發送數據,注意5678端口是Text協議的端口,Text協議需要在數據末尾加上換行符 fwrite($client, json_encode($data)."\n"); // 讀取推送結果 echo fread($client, 8192); ```
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看