關閉未認證連接
問題:
如何關閉規(guī)定時間內未發(fā)送過數(shù)據(jù)的客戶端,
比如30秒內沒收到一條數(shù)據(jù)就自動關閉這個客戶端連接,
目的是為了讓未認證的連接必須在規(guī)定時間內認證
答案:
方法一、利用GatewayWorker的心跳做
GatewayWorker
GatewayWorker中可以利用心跳來解決這個問題,GatewayWorker有設置客戶端多久不回復心跳服務端就關閉連接的屬性,可以利用這個機制關閉未及時認證的客戶端。
start_gateway.php
// 心跳間隔
$gateway->pingInterval = 30;
// 發(fā)給客戶端你的心跳數(shù)據(jù)
$gateway->pingData = '{"type":"ping"}';
// 客戶端在30秒內有1次未回復就斷開連接
$gateway->pingNotResponseLimit = 1;
Event.php
class Event
{
public static function onMessage($client_id, $msg)
{
$msg = json_decode($msg, true);
switch($msg['type'])
{
case 'login':
略...
// 記錄session,表明認證成功
$_SESSION['login'] = true;
break;
// 30秒后客戶端發(fā)來心跳回復時,仍然沒認證,則關閉連接
case 'pong':
if(empty($_SESSION['login']))
{
Gateway::closeClient($client_id);
}
}
............略
}
}
方法二,利用定時器Timer做
如果是GatewayWorker項目
Event.php
use Workerman\Timer;
class Event
{
public static function onConnect($client_id)
{
// 連接到來后,定時30秒關閉這個鏈接,需要30秒內發(fā)認證并刪除定時器阻止關閉連接的執(zhí)行
$auth_timer_id = Timer::add(30, function($client_id){
Gateway::closeClient($client_id);
}, array($client_id), false);
Gateway::updateSession($client_id, array('auth_timer_id' => $auth_timer_id));
}
public static function onMessage($client_id, $msg)
{
$_SESSION = Gateway::getSession($client_id);
$msg = json_decode($msg);
switch($msg['type'])
{
case 'login':
略...
// 認證成功,刪除 30關閉連接定 的時器
Timer::del($_SESSION['auth_timer_id']);
break;
}
............略
}
}