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