Gateway/Worker開發(fā)模型支持服務端的心跳檢測,可以定時向客戶端發(fā)送應用層的心跳,能夠及時檢測到客戶端極端掉線情況(掉電、突發(fā)網絡故障等)。
注意:長連接應用必須加心跳,否則連接可能由于長時間未通訊被路由節(jié)點強行斷開。 (推薦學習: workerman教程)
心跳作用主要有兩個:
1、客戶端定時給服務端發(fā)送點數據,防止連接由于長時間沒有通訊而被某些節(jié)點的防火墻關閉導致連接斷開的情況。
2、服務端可以通過心跳來判斷客戶端是否在線,如果客戶端在規(guī)定時間內沒有發(fā)來任何數據,就認為客戶端下線。這樣可以檢測到客戶端由于極端情況(斷電、斷網等)下線的事件。
心跳間隔建議值:
建議客戶端發(fā)送心跳間隔小于60秒,比如55秒。
示例:
<?php require_once __DIR__ . '/Workerman/Autoloader.php'; use WorkermanWorker; use WorkermanLibTimer; // 心跳間隔55秒 define('HEARTBEAT_TIME', 55); $worker = new Worker('text://0.0.0.0:1234'); $worker->onMessage = function($connection, $msg) { // 給connection臨時設置一個lastMessageTime屬性,用來記錄上次收到消息的時間 $connection->lastMessageTime = time(); // 其它業(yè)務邏輯... }; // 進程啟動后設置一個每秒運行一次的定時器 $worker->onWorkerStart = function($worker) { Timer::add(1, function()use($worker){ $time_now = time(); foreach($worker->connections as $connection) { // 有可能該connection還沒收到過消息,則lastMessageTime設置為當前時間 if (empty($connection->lastMessageTime)) { $connection->lastMessageTime = $time_now; continue; } // 上次通訊時間間隔大于心跳間隔,則認為客戶端已經下線,關閉連接 if ($time_now - $connection->lastMessageTime > HEARTBEAT_TIME) { $connection->close(); } } }); }; Worker::runAll();
以上配置為如果客戶端超過55秒沒有發(fā)送任何數據給服務端,則服務端認為客戶端已經掉線,服務端關閉連接并觸發(fā)onClose。