站長(zhǎng)資訊網(wǎng)
在開發(fā)過程中，我們經(jīng)常會(huì)遇到如下這種情況。前端列表展示后臺(tái)數(shù)據(jù)庫中的數(shù)據(jù)，但是在后臺(tái)的某一個(gè)接口中向數(shù)據(jù)庫插入一條數(shù)據(jù)，此時(shí)數(shù)據(jù)庫已更新，但是前端展示數(shù)據(jù)并沒有更新，需要手動(dòng)刷新才可以。但是每次都自己手動(dòng)更新，太麻煩了，這時(shí)候就可以用到workerman來解決問題了。
Workerman框架是一款純PHP開發(fā)的開源高性能的PHP socket 服務(wù)器框架。被廣泛的用于手機(jī)app、移動(dòng)通訊，微信小程序，手游服務(wù)端、網(wǎng)絡(luò)游戲、PHP聊天室、硬件通訊、智能家居、車聯(lián)網(wǎng)、物聯(lián)網(wǎng)等領(lǐng)域的開發(fā)。 支持TCP長(zhǎng)連接，支持Websocket、HTTP等協(xié)議，支持自定義協(xié)議。擁有異步Mysql、異步Redis、異步Http、異步消息隊(duì)列等眾多高性能組件。
那我們應(yīng)該如何能使用才能解決上述問題呢？
1.前后端建立websocket的長(zhǎng)連接，用于互相的消息推送
2.后端內(nèi)部在建立一個(gè)監(jiān)聽進(jìn)程（協(xié)議不限）
3.在接口往數(shù)據(jù)庫中插入數(shù)據(jù)成功后，想內(nèi)部監(jiān)聽端口推送數(shù)據(jù)
4.在收到內(nèi)部監(jiān)聽端口的推送消息之后，后端在向前端通過websocket推送消息，實(shí)現(xiàn)刷新
在下載好workerman框架源碼后，我們來實(shí)現(xiàn)上述過程。
實(shí)現(xiàn)代碼：
server.php
<?php use WorkermanWorker; require_once __DIR__ . '/../../vendor/autoload.php'; // 初始化一個(gè)worker容器，監(jiān)聽1234端口 $worker = new Worker('websocket://0.0.0.0:1234');// /* * 注意這里進(jìn)程數(shù)必須設(shè)置為1，否則會(huì)報(bào)端口占用錯(cuò)誤 * (php 7可以設(shè)置進(jìn)程數(shù)大于1，前提是$inner_text_worker->reusePort=true) */ $worker->count = 1; // worker進(jìn)程啟動(dòng)后創(chuàng)建一個(gè)text Worker以便打開一個(gè)內(nèi)部通訊端口 $worker->onWorkerStart = function($worker) { // 開啟一個(gè)內(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) { // $data數(shù)組格式，里面有uid，表示向那個(gè)uid的頁面推送數(shù)據(jù) $data = json_decode($buffer, true); $uid = $data['uid']; // 通過workerman，向uid的頁面推送數(shù)據(jù) $ret = sendMessageByUid($uid, $buffer); // 返回推送結(jié)果 $connection->send($ret ? 'ok' : 'fail'); }; // ## 執(zhí)行監(jiān)聽 ## $inner_text_worker->listen(); }; // 新增加一個(gè)屬性，用來保存uid到connection的映射 $worker->uidConnections = array(); // 當(dāng)有客戶端發(fā)來消息時(shí)執(zhí)行的回調(diào)函數(shù) $worker->onMessage = function($connection, $data) { global $worker; // 判斷當(dāng)前客戶端是否已經(jīng)驗(yàn)證,既是否設(shè)置了uid if(!isset($connection->uid)) { // 沒驗(yàn)證的話把第一個(gè)包當(dāng)做uid（這里為了方便演示，沒做真正的驗(yàn)證） $connection->uid = $data; /* 保存uid到connection的映射，這樣可以方便的通過uid查找connection， * 實(shí)現(xiàn)針對(duì)特定uid推送數(shù)據(jù) */ $worker->uidConnections[$connection->uid] = $connection; return; } }; // 當(dāng)有客戶端連接斷開時(shí) $worker->onClose = function($connection) { global $worker; if(isset($connection->uid)) { // 連接斷開時(shí)刪除映射 unset($worker->uidConnections[$connection->uid]); } }; // 向所有驗(yàn)證的用戶推送數(shù)據(jù) function broadcast($message) { global $worker; foreach($worker->uidConnections as $connection) { $connection->send($message); } } // 針對(duì)uid推送數(shù)據(jù) function sendMessageByUid($uid, $message) { global $worker; if(isset($worker->uidConnections[$uid])) { $connection = $worker->uidConnections[$uid]; $connection->send($message); return true; } return false; } // 運(yùn)行所有的worker Worker::runAll();
push.php
<?php //插入數(shù)據(jù)庫操作 // 建立socket連接到內(nèi)部推送端口 $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1); // 推送的數(shù)據(jù)，包含uid字段，表示是給這個(gè)uid推送 $data = array('uid'=>'uid1', 'percent'=>'88%'); // 發(fā)送數(shù)據(jù)，注意5678端口是Text協(xié)議的端口，Text協(xié)議需要在數(shù)據(jù)末尾加上換行符 fwrite($client, json_encode($data)."n"); // 讀取推送結(jié)果 echo fread($client, 8192); ?>
clien.html
<!DOCTYPE html> <html> <head> <title></title> </head> <body> <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> </body> </html>
運(yùn)行流程：
打開cmd，運(yùn)行server.php
打開前端頁面和console
在打開一個(gè)cmd，運(yùn)行push.php
此時(shí)在看前端頁面，console就收收到消息。
