Закрытие неаутентифицированных соединений
Проблема:
Как закрыть клиентские соединения, которые не отправили данные в течение установленного времени, например, если в течение 30 секунд не получено ни одного сообщения, необходимо автоматически закрыть это клиентское соединение. Цель состоит в том, чтобы неаутентифицированные соединения должны пройти аутентификацию в установленный срок.
Ответ:
use Workerman\Worker;
use Workerman\Timer;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';
$worker = new Worker('xxx://x.x.x.x:x');
$worker->onConnect = function(TcpConnection $connection)
{
// Временно добавляем свойство auth_timer_id в объект $connection для хранения id таймера
// Таймер на 30 секунд для закрытия соединения, клиент должен отправить проверку в течение 30 секунд, чтобы удалить таймер
$connection->auth_timer_id = Timer::add(30, function()use($connection){
$connection->close();
}, null, false);
};
$worker->onMessage = function(TcpConnection $connection, $msg)
{
$msg = json_decode($msg, true);
switch($msg['type'])
{
case 'login':
...略
// Успешная аутентификация, удаляем таймер, чтобы предотвратить закрытие соединения
Timer::del($connection->auth_timer_id);
break;
... 略
}
... 略
}