Workerman開(kāi)發(fā)典范：實(shí)現(xiàn)實(shí)時(shí)數(shù)據(jù)推送功能的最佳實(shí)踐

composer require workerman/workerman

<?php require_once __DIR__ . '/vendor/autoload.php';  use WorkermanWorker;  // 創(chuàng)建一個(gè)Worker監(jiān)聽(tīng)8080端口，使用websocket協(xié)議通訊 $ws_worker = new Worker('websocket://0.0.0.0:8080');  // 啟動(dòng)4個(gè)進(jìn)程對(duì)外提供服務(wù) $ws_worker->count = 4;  // 當(dāng)客戶端與服務(wù)端建立連接時(shí)觸發(fā) $ws_worker-&gt;onConnect = function ($connection) {     echo "New connection "; };  // 當(dāng)客戶端給服務(wù)端發(fā)送消息時(shí)觸發(fā) $ws_worker-&gt;onMessage = function ($connection, $data) use ($ws_worker) {     // 將消息廣播給所有客戶端     foreach ($ws_worker-&gt;connections as $client_connection) {         $client_connection-&gt;send($data);     } };  // 當(dāng)客戶端與服務(wù)端斷開(kāi)連接時(shí)觸發(fā) $ws_worker-&gt;onClose = function ($connection) {     echo "Connection closed "; };  // 運(yùn)行worker Worker::runAll();

       <meta charset="UTF-8"><title>實(shí)時(shí)數(shù)據(jù)推送</title><script>         var ws = new WebSocket('ws://127.0.0.1:8080');          ws.onopen = function () {             console.log('已連接服務(wù)器');         };          ws.onmessage = function (event) {             console.log('收到消息：' + event.data);         };          function send() {             var message = document.getElementById('message').value;             ws.send(message);             console.log('發(fā)送消息：' + message);         }     </script><input type="text" id="message" placeholder="請(qǐng)輸入要發(fā)送的消息"><button onclick="send()">發(fā)送</button>  

// 在onConnect事件中驗(yàn)證用戶登錄 $ws_worker->onConnect = function ($connection) {     // 獲取用戶token     $token = $connection->getRequestHeader('token');     // 驗(yàn)證token     if (!verifyToken($token)) {         $connection->close();     } };

// 創(chuàng)建分組、加入分組和發(fā)送給指定分組的示例代碼 $group = new WorkermanConnectionConnections(); $group->add($client_connection); $ws_worker->group['group_name'] = $group; ...  // 發(fā)送消息給指定分組 $ws_worker->group['group_name']->send($data);

// 在onMessage事件中判斷要發(fā)送的客戶端id $id = $data['recipient_id']; if ($connection = $ws_worker->uidConnections[$id] ?? null) {     // 找到對(duì)應(yīng)的客戶端連接并發(fā)送消息     $connection->send($data); }