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