关闭未认证连接

问题:

如何关闭规定时间内未发送过数据的客户端,

比如30秒内没收到一条数据就自动关闭这个客户端连接,

目的是为了让未认证的连接必须在规定时间内认证

答案:

方法一、利用GatewayWorker的心跳做

GatewayWorker
GatewayWorker中可以利用心跳来解决这个问题,GatewayWorker有设置客户端多久不回复心跳服务端就关闭连接的属性,可以利用这个机制关闭未及时认证的客户端。

start_gateway.php

  1. // 心跳间隔
  2. $gateway->pingInterval = 30;
  3. // 发给客户端你的心跳数据
  4. $gateway->pingData = '{"type":"ping"}';
  5. // 客户端在30秒内有1次未回复就断开连接
  6. $gateway->pingNotResponseLimit = 1;

Event.php

  1. class Event
  2. {
  3. public static function onMessage($client_id, $msg)
  4. {
  5. $msg = json_decode($msg, true);
  6. switch($msg['type'])
  7. {
  8. case 'login':
  9. 略...
  10. // 记录session,表明认证成功
  11. $_SESSION['login'] = true;
  12. break;
  13. // 30秒后客户端发来心跳回复时,仍然没认证,则关闭连接
  14. case 'pong':
  15. if(empty($_SESSION['login']))
  16. {
  17. Gateway::closeClient($client_id);
  18. }
  19. }
  20. ............略
  21. }
  22. }



方法二,利用定时器Timer做

如果是GatewayWorker项目

Event.php

  1. use Workerman\Lib\Timer;
  2. class Event
  3. {
  4. public static function onConnect($client_id)
  5. {
  6. // 连接到来后,定时30秒关闭这个链接,需要30秒内发认证并删除定时器阻止关闭连接的执行
  7. $_SESSION['auth_timer_id'] = Timer::add(30, function($client_id){
  8. Gateway::closeClient($client_id);
  9. }, array($client_id), false);
  10. }
  11. public static function onMessage($client_id, $msg)
  12. {
  13. $msg = json_decode($msg);
  14. switch($msg['type'])
  15. {
  16. case 'login':
  17. 略...
  18. // 认证成功,删除 30关闭连接定 的时器
  19. Timer::del($_SESSION['auth_timer_id']);
  20. break;
  21. }
  22. ............略
  23. }
  24. }