ReactPHP /套接字服务器 - 设置连接超时

Question

我有使用react \ socket的TCP套接字服务器。

根据从客户端收到的数据，它做了一些事情，然后它关闭与客户端的连接。

问题是我不明白如何使连接超时， 如果服务器一段时间没有收到任何数据，如何关闭连接？

我要找一样我与stream_socket_accept（）使用stream_set_timeout（）

<?php 

require __DIR__ . '/vendor/autoload.php'; 

$loop = React\EventLoop\Factory::create(); 
$socket = new React\Socket\Server($loop); 

$socket->listen(2222); 

$socket->on('connection', function ($conn) { 

    $conn->on('data', function ($data) use ($conn) { 

     if (substr($data, 0, 3) == 'one') { 
      $conn->end('end_two'); 
     } 
     else if (substr($data, 0, 3) == 'two') { 
      $conn->end('end_two'); 
     } 
     else { 
      $conn->close(); 
     } 
    }); 

}); 
$loop->run(); 
stream_set_timeout($client, 5); 

Answer 1

你需要一个计时器添加到您的$loop像下面的例子。

$loop = React\EventLoop\Factory::create(); 

$socket = new React\Socket\Server($loop); 
$socket->on('connection', function ($conn) use ($loop) { 
    $func = function() use ($conn) {$conn->close();}; 
    $timer = $loop->addTimer(1, $func); 
    $conn->on('data', function ($data) use ($loop, &$timer, $func) { 
     $timer->cancel(); 
     $timer = $loop->addTimer(1, $func); 
    }); 
}); 

实施例从：

https://github.com/reactphp/socket/issues/42