在開發過程中，我們經常會遇到如下這種情況。前端列表展示后臺數據庫中的數據，但是在后臺的某一個接口中向數據庫插入一條數據，此時數據庫已更新，但是前端展示數據并沒有更新，需要手動刷新才可以。但是每次都自己手動更新，太麻煩了，這時候就可以用到workerman來解決問題了。
Workerman框架是一款純php開發的開源高性能的PHP socket 服務器框架。被廣泛的用于手機app、移動通訊，微信小程序，手游服務端、網絡游戲、PHP聊天室、硬件通訊、智能家居、車聯網、物聯網等領域的開發。 支持TCP長連接，支持websocket、http等協議，支持自定義協議。擁有異步mysql、異步redis、異步Http、異步消息隊列等眾多高性能組件。
那我們應該如何能使用才能解決上述問題呢？
1.前后端建立websocket的長連接，用于互相的消息推送
立即學習“前端免費學習筆記（深入）”；
2.后端內部在建立一個監聽進程（協議不限）
3.在接口往數據庫中插入數據成功后，想內部監聽端口推送數據
4.在收到內部監聽端口的推送消息之后，后端在向前端通過websocket推送消息，實現刷新
在下載好workerman框架源碼后，我們來實現上述過程。
實現代碼：
server.php
<?php use WorkermanWorker; require_once __DIR__ . '/../../vendor/autoload.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();
push.php
<?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); ? ??>
clien.html
nbsp;html> <title></title><script> 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); console.log(e.data); //window.location.reload(); }; </script>
運行流程：
打開cmd，運行server.php
打開前端頁面和console
在打開一個cmd，運行push.php
此時在看前端頁面，console就收收到消息。
更多workerman知識請關注PHP中文網Workerman框架欄目。
? 版權聲明
文章版權歸作者所有，未經允許請勿轉載。
THE END
喜歡就支持一下吧
相關推薦
