关闭未认证连接
问题:
如何关闭规定时间内未发送过数据的客户端,
比如30秒内没收到一条数据就自动关闭这个客户端连接,
目的是为了让未认证的连接必须在规定时间内认证
答案:
方法一、利用GatewayWorker的心跳做
GatewayWorker
GatewayWorker中可以利用心跳来解决这个问题,GatewayWorker有设置客户端多久不回复心跳服务端就关闭连接的属性,可以利用这个机制关闭未及时认证的客户端。
start_gateway.php
// 心跳间隔
$gateway->pingInterval = 30;
// 发给客户端你的心跳数据
$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秒后客户端发来心跳回复时,仍然没认证,则关闭连接
case 'pong':
if(empty($_SESSION['login']))
{
Gateway::closeClient($client_id);
}
}
............略
}
}
方法二,利用定时器Timer做
如果是GatewayWorker项目
Event.php
use Workerman\Lib\Timer;
class Event
{
public static function onConnect($client_id)
{
// 连接到来后,定时30秒关闭这个链接,需要30秒内发认证并删除定时器阻止关闭连接的执行
$_SESSION['auth_timer_id'] = Timer::add(30, function($client_id){
Gateway::closeClient($client_id);
}, array($client_id), false);
}
public static function onMessage($client_id, $msg)
{
$msg = json_decode($msg);
switch($msg['type'])
{
case 'login':
略...
// 认证成功,删除 30关闭连接定 的时器
Timer::del($_SESSION['auth_timer_id']);
break;
}
............略
}
}