如何关闭规定时间内未认证的连接

walkor

请问如何关闭规定时间内未发送过数据的客户端
比如30秒内没收到一条数据就自动关闭这个客户端连接
为了让未认证的连接必须在规定时间内认证

群里有人问这个问题,这里在问答中回复下

6886 2 0
2个回答

walkor

方法一,利用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);
                }
        }
        ............略
        }
}
  • 暂无评论
walkor

方法二,利用定时器Timer做

如果是GatewayWorker项目

Event.php

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;
             ... 略
        }
        ... 略
}
  • 暂无评论
年代过于久远,无法发表回答
🔝