等待 socket_write 完成后再写入

Question

我需要将一些数据从 PHP 服务器发送到 Node 服务器。

这是我目前在 PHP 方面的简化版本：

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
$result = socket_connect($socket, '127.0.0.1', '3000');
socket_write($socket, "Hello World", 11);
socket_close($socket);

运行此代码成功将消息发送到我的节点服务器并输出。

但是，我需要将多个消息发送回套接字。我实际上需要发送数千个回复。但是，如果我要在这样的循环中调用 socket_write() 函数：

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
$result = socket_connect($socket, '127.0.0.1', '3000');
for($i=0;$i<1000;$i++){
    socket_write($socket, "Hello World", 11);
}
socket_close($socket);

它似乎将所有数据附加在一起并在脚本末尾一次性发送。我需要实时发回数据。有什么办法可以在 PHP 中做到这一点？

Answer 1

在查看了许多 PHP 套接字库后，我注意到几乎所有这些库都只是在发送套接字后实现了 usleep(1000000)。我不确定这是否是最好的方法，但由于 PHP 的限制，这可能是唯一的方法。

最后，我决定存储数据最后一次写入套接字的时间。然后，计算从那时起经过的时间并从 1000000 微秒中减去。这样，脚本就不会等待超过必要的时间。

public function send(array $payload){
    $json = json_encode($payload);
    $write = socket_write($this->socket, $json, strlen($json);
    $sleep_time = 1000000 - (microtime(true) - $this->last_sent);
    if($sleep_time > 0) usleep($sleep_time);
    $this->last_sent = microtime(true);
    return $write !== false ? true : false;
}