请问如何关闭规定时间内未发送过数据的客户端 比如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) { case 'login': 略... // 记录session,表明认证成功 $_SESSION = true; break; // 30秒后客户端发来心跳回复时,仍然没认证,则关闭连接 case 'pong': if(empty($_SESSION)) { Gateway::closeClient($client_id); } } ............略 } }
方法二,利用定时器Timer做
如果是GatewayWorker项目
use Workerman\Lib\Timer; class Event { public static function onConnect($client_id) { // 连接到来后,定时30秒关闭这个链接,需要30秒内发认证删除定时器阻止关闭连接的执行 $_SESSION = 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) { case 'login': 略... // 认证成功,删除 30关闭连接定 的时器 Timer::del($_SESSION); break; } ............略 } }
如果是Workerman项目
use Workerman\Lib\Timer; $worker = new Worker('xxx://x.x.x.x:x'); $worker->onConnect = function($connection) { // 临时给$connection对象添加一个auth_timer_id属性存储定时器 // 定时30秒关闭连接,需要客户端30秒内发送验证删除定时器 $connection->auth_timer_id = Timer::add(30, function($connection){ $connection->close(); }, array($connection), false); }; $worker->onMessage = function($connection, $msg) { $msg = json_decode($msg, true); switch($msg) { case 'login': ...略 // 验证成功,删除定时器,防止连接被关闭 Timer::del($connection->auth_timer_id); break; ... 略 } ... 略 }
方法一,利用GatewayWorker的心跳做
GatewayWorker
GatewayWorker中可以利用心跳来解决这个问题,GatewayWorker有设置客户端多久不回复心跳服务端就关闭连接的属性,可以利用这个机制关闭未及时认证的客户端。
start_gateway.php
Event.php
方法二,利用定时器Timer做
如果是GatewayWorker项目
Event.php
如果是Workerman项目