心跳
注意:長連接應用必須加心跳,否則連接可能由于長時間未通訊被路由節(jié)點強行斷開。
心跳作用主要有兩個:
1、客戶端定時給服務端發(fā)送點數(shù)據(jù),防止連接由于長時間沒有通訊而被某些節(jié)點的防火墻關閉導致連接斷開的情況。
2、服務端可以通過心跳來判斷客戶端是否在線,如果客戶端在規(guī)定時間內(nèi)沒有發(fā)來任何數(shù)據(jù),就認為客戶端下線。這樣可以檢測到客戶端由于極端情況(斷電、斷網(wǎng)等)下線的事件。
心跳間隔建議值:
建議客戶端發(fā)送心跳間隔小于60秒,比如55秒。
心跳的數(shù)據(jù)格式?jīng)]有要求,服務端能識別即可。
心跳示例
<?php
use Workerman\Worker;
use Workerman\Timer;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';
// 心跳間隔55秒
define('HEARTBEAT_TIME', 55);
$worker = new Worker('text://0.0.0.0:1234');
$worker->onMessage = function(TcpConnection $connection, $msg) {
// 給connection臨時設置一個lastMessageTime屬性,用來記錄上次收到消息的時間
$connection->lastMessageTime = time();
// 其它業(yè)務邏輯...
};
// 進程啟動后設置一個每10秒運行一次的定時器
$worker->onWorkerStart = function($worker) {
Timer::add(10, function()use($worker){
$time_now = time();
foreach($worker->connections as $connection) {
// 有可能該connection還沒收到過消息,則lastMessageTime設置為當前時間
if (empty($connection->lastMessageTime)) {
$connection->lastMessageTime = $time_now;
continue;
}
// 上次通訊時間間隔大于心跳間隔,則認為客戶端已經(jīng)下線,關閉連接
if ($time_now - $connection->lastMessageTime > HEARTBEAT_TIME) {
$connection->close();
}
}
});
};
Worker::runAll();
以上配置為如果客戶端超過55秒沒有發(fā)送任何數(shù)據(jù)給服務端,則服務端認為客戶端已經(jīng)掉線,服務端關閉連接并觸發(fā)onClose。
斷線重連(重要)
不管是客戶端發(fā)送心跳還是服務端發(fā)送心跳,連接都有斷開的可能。例如瀏覽器最小化js被暫停、瀏覽器切換到其它tab頁面js被暫停、電腦進入睡眠等等、移動端切換網(wǎng)絡、信號變?nèi)?、手機黑屏、手機應用切換到后臺、路由故障、業(yè)務主動斷開等。尤其是外網(wǎng)環(huán)境復雜,很多路由節(jié)點會清理1分鐘內(nèi)不活躍的連接,這也是為什么心跳間隔推薦小于1分鐘的原因。
連接在外網(wǎng)環(huán)境很容易被斷開,所以斷線重連是長連接應用必須具備的功能(斷線重連只能客戶端做,服務端無法實現(xiàn))。例如瀏覽器websocket需要監(jiān)聽onclose事件,當發(fā)生onclose時建立新的連接(為避免需崩可延建立連接)。更嚴格一點,服務端也應該定時發(fā)起心跳數(shù)據(jù),并且客戶端需要定時監(jiān)測服務端的心跳數(shù)據(jù)是否超時,超過規(guī)定時間未收到服務端心跳數(shù)據(jù)應該認定連接已經(jīng)斷開,需要執(zhí)行close關閉連接,并重新建立新的連接。