如何關(guān)閉規(guī)定時(shí)間內(nèi)未認(rèn)證的連接

walkor 更新于2019-10-30

請(qǐng)問(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)證

群里有人問(wèn)這個(gè)問(wèn)題，這里在問(wèn)答中回復(fù)下

 7908  2 0

2個(gè)回答

walkor 2015-09-13

打賞

方法一，利用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)
        {
            case 'login':
                略...
                    // 記錄session，表明認(rèn)證成功
                    $_SESSION = true;
                    break;
            // 30秒后客戶端發(fā)來(lái)心跳回復(fù)時(shí)，仍然沒(méi)認(rèn)證，則關(guān)閉連接
            case 'pong':
                if(empty($_SESSION))
                {
                    Gateway::closeClient($client_id);
                }
        }
        ............略
        }
}

暫無(wú)評(píng)論

walkor 2015-09-13

打賞

方法二，利用定時(shí)器Timer做

如果是GatewayWorker項(xiàng)目

Event.php

use Workerman\Lib\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í)行
        $_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':
                略...
                    // 認(rèn)證成功，刪除 30關(guān)閉連接定 的時(shí)器
                    Timer::del($_SESSION);
                    break;
        }
        ............略
        }
}

如果是Workerman項(xiàng)目

use Workerman\Lib\Timer;
$worker = new Worker('xxx://x.x.x.x:x');
$worker->onConnect = function($connection)
{
    // 臨時(shí)給$connection對(duì)象添加一個(gè)auth_timer_id屬性存儲(chǔ)定時(shí)器
    // 定時(shí)30秒關(guān)閉連接，需要客戶端30秒內(nèi)發(fā)送驗(yàn)證刪除定時(shí)器
    $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':
            ...略
            // 驗(yàn)證成功，刪除定時(shí)器，防止連接被關(guān)閉
            Timer::del($connection->auth_timer_id);
            break;
             ... 略
        }
        ... 略
}