PHP 流写入缓冲区

Question

我正在尝试以非阻塞方式将大量数据(~250K)写入流。

抽象出复杂性和对象结构，这就是我正在运行的:

$fp = fsockopen('host', 80);
socket_set_blocking( $fp, false );
fwrite( $fp, $string, $length ); // Where $string is a 250K string

但是数据并未全部写入。假设这是 PHP 的写入缓冲区发挥作用，我设置了 stream_set_write_buffer( $fp, 0 ) 但这也没有解决问题。

我将 fwrite 分成了 4096B 的 block - 看起来客户端发送了 3 个完整的批处理(4096 字节)和第四批的约 1500B。对 fwrite 的任何和所有连续调用都会返回写入的 0 个字节。

有谁知道如何将这些数据排队以非阻塞方式发送出去？如果我删除 socket_set_blocking( $fp, false ); - 一切正常。很明显，这是异步运行的问题。

你有什么想法？套接字扩展在这里有帮助吗？它处理缓冲区的方式不同吗？

注意:我故意编写这个套接字传输层以避免出于各种原因使用curl。使用 curl_multi() 不是一个选项。

Answer 1

您的问题几乎肯定是由于非阻塞套接字流上的 fwrite 操作可能会因新数据包的到达而中断。因此，您不能指望 fwrite 是原子的。在这种情况下，您必须依赖 fwrite 调用的返回值来准确告诉您该传递中写入流的字节数，并继续写入，直到所有数据都写入已发送。

例如...

$dataToWrite = 'my data';
$bytesToWrite = strlen($dataToWrite);
$totalBytesWritten = 0;

while ($totalBytesWritten < $bytesToWrite) {
    $bytes = fwrite($mySock, substr($dataToWrite, $totalBytesWritten));
    $totalBytesWritten += $bytes;
}

显然，对此问题的稳健处理还必须考虑套接字连接消失等情况。