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

walkor 更新于2019-10-30

請問如何關(guān)閉規(guī)定時間內(nèi)未發(fā)送過數(shù)據(jù)的客戶端
比如30秒內(nèi)沒收到一條數(shù)據(jù)就自動關(guān)閉這個客戶端連接
為了讓未認證的連接必須在規(guī)定時間內(nèi)認證

群里有人問這個問題，這里在問答中回復下

 7851  2 0

2個回答

walkor 2015-09-13

打賞

方法一，利用GatewayWorker的心跳做

GatewayWorker
GatewayWorker中可以利用心跳來解決這個問題，GatewayWorker有設(shè)置客戶端多久不回復心跳服務(wù)端就關(guān)閉連接的屬性，可以利用這個機制關(guān)閉未及時認證的客戶端。

start_gateway.php

...
// 心跳間隔
$gateway->pingInterval = 30;
// 發(fā)給客戶端你的心跳數(shù)據(jù)
$gateway->pingData = '{"type":"ping"}';
// 客戶端在30秒內(nèi)有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秒后客戶端發(fā)來心跳回復時，仍然沒認證，則關(guān)閉連接
            case 'pong':
                if(empty($_SESSION))
                {
                    Gateway::closeClient($client_id);
                }
        }
        ............略
        }
}

暫無評論

walkor 2015-09-13

打賞

方法二，利用定時器Timer做

如果是GatewayWorker項目

Event.php

use Workerman\Lib\Timer;
class Event
{
    public static function onConnect($client_id)
    {
        // 連接到來后，定時30秒關(guān)閉這個鏈接，需要30秒內(nèi)發(fā)認證刪除定時器阻止關(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':
                略...
                    // 認證成功，刪除 30關(guān)閉連接定 的時器
                    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秒關(guān)閉連接，需要客戶端30秒內(nèi)發(fā)送驗證刪除定時器
    $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':
            ...略
            // 驗證成功，刪除定時器，防止連接被關(guān)閉
            Timer::del($connection->auth_timer_id);
            break;
             ... 略
        }
        ... 略
}