WorkerMan中php后端及時推送消息給客戶端

1、workerman中php后端及時推送消息給客戶端php后端準時推送消息給客戶端原理：1、建立一個websocketworker，用來維持客戶端長銜接2、websocketworker內(nèi)部建立一個textworker3、websocketworker與textworker是同一個進程，可以便利的分享客戶端銜接4、某個自立的php后臺系統(tǒng)通過text協(xié)議與textworker通訊5、textworker操作websocket銜接完成數(shù)據(jù)推送代碼及步驟push.phpreuseport=true)*/$worker-count=1;/worker進程啟動后創(chuàng)建一個textworker以便打開一個內(nèi)

2、部通訊端口$worker-onworkerstart=function($worker)/開啟一個內(nèi)部端口，便利內(nèi)部系統(tǒng)推送數(shù)據(jù)，text協(xié)議格式文本+換行符$inner_text_worker=newworker(&39;text:/0.0.0.0:5678&39;);$inner_text_worker-onmessage=function($connection,$buffer)/$data數(shù)組格式，里面有uid，表示向那個uid的頁面推送數(shù)據(jù)$data=json_decode($buffer,true);$uid=$data&39;uid&39;/通過workerman，向uid的頁面

3、推送數(shù)據(jù)$ret=sendmessagebyuid($uid,$buffer);/返回推送結(jié)果$connection-send($ret?&39;ok&39;:&39;fail&39;);/執(zhí)行監(jiān)聽$inner_text_worker-listen();/新增強一個屬性，用來保存uid到connection的映射$worker-uidconnections=array();/當有客戶端發(fā)來消息時執(zhí)行的回調(diào)函數(shù)$worker-onmessage=function($connection,$data)global$worker;/推斷當前客戶端是否已閱歷證,既是否設(shè)置了uidif(!isset($

4、connection-uid)/沒驗證的話把第一個包當做uid（這里為了便利演示，沒做真正的驗證）$connection-uid=$data;/*保存uid到connection的映射，這樣可以便利的通過uid查找connection，*實現(xiàn)針對特定uid推送數(shù)據(jù)*/$worker-uidconnections$connection-uid=$connection;return;/當有客戶端銜接斷開時$worker-onclose=function($connection)global$worker;if(isset($connection-uid)/銜接斷開時刪除映射unset($worke

5、r-uidconnections$connection-uid);/向全部驗證的用戶推送數(shù)據(jù)functionbroadcast($message)global$worker;foreach($worker-uidconnectionsas$connection)$connection-send($message);/針對uid推送數(shù)據(jù)functionsendmessagebyuid($uid,$message)global$worker;if(isset($worker-uidconnections$uid)$connection=$worker-uidconnections$uid;$con

6、nection-send($message);returntrue;returnfalse;/運行全部的workerworker:runall();啟動后端服務phppush.phpstart-d前端接收推送的js代碼varws=newwebsocket(&39;ws:/127.0.0.1:1234&39;);ws.onopen=function()varuid=&39;uid1&39;ws.send(uid);ws.onmessage=function(e)alert(e.data);后端推送消息的代碼/建立socket銜接到內(nèi)部推送端口$client=stream_socket_client(&39;tcp:/127.0.0.1:5678&39;,$errno,$errmsg,1);/推送的數(shù)據(jù)，包含uid字段，表示是給這個uid推送$data=array(&39;uid&39;=&39;uid1&39;,&39;percent&39;=&39;88%&39;);/發(fā)送數(shù)據(jù)，注重5678端口是text協(xié)議的端口，text協(xié)議需要在數(shù)據(jù)末尾加上換行符fwrite($client,json_encode($data)."n");/讀取推送結(jié)果echofread($client,8192);后端推送消息的代碼和push.php監(jiān)聽同一個端