简体中文
简体中文
在 PHP 中使用 socket 进行网络编程时，非阻塞模式能够提升并发处理能力，是实现事件驱动或多路复用服务器的关键。然而，某些时候我们又需要临时地将套接字设置为阻塞状态，以完成某些“必须等待”的操作，例如完整读取一个大数据包，或者等待客户端发送完整的握手数据。
幸运的是，PHP 提供了 socket_set_block() 和 socket_set_nonblock() 两个函数，可以非常方便地在阻塞与非阻塞模式之间进行切换。
本文将结合一个具体的 TCP 服务端示例，演示如何在非阻塞监听中临时切换套接字为阻塞状态，并在完成操作后恢复非阻塞状态。
我们构建一个非阻塞 TCP 服务器，监听客户端连接，并在接收到客户端连接之后，临时将该连接切换为阻塞模式，从客户端读取一段数据，完成后再切回非阻塞模式。
以下是完整代码：
<code> <?php$host = '0.0.0.0';
$port = 12345;
// 创建 socket
$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);
// 绑定和监听
socket_bind($server, $host, $port);
socket_listen($server);
// 设置为非阻塞
socket_set_nonblock($server);
echo "Server listening on {$host}:{$port} ...\n";
$clients = [];
while (true) {
// 接受连接（非阻塞）
$client = @socket_accept($server);
if ($client !== false) {
echo "New client connected.\n";
// 添加到客户端列表
$clients[] = $client;
// 设置客户端为非阻塞
socket_set_nonblock($client);
}
foreach ($clients as $index => $sock) {
$buffer = '';
// 临时设置为阻塞以确保完整读取（例如读取固定长度或直到某个标志）
socket_set_block($sock);
$bytes = @socket_recv($sock, $buffer, 1024, MSG_DONTWAIT);
// 恢复为非阻塞
socket_set_nonblock($sock);
if ($bytes === false || $bytes === 0) {
// 客户端断开
echo "Client disconnected.\n";
socket_close($sock);
unset($clients[$index]);
continue;
}
// 输出读取数据
echo "Received: " . trim($buffer) . "\n";
// 示例响应
$response = "HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\n\r\nHello from server!\n";
socket_write($sock, $response);
}
// 轻微延迟避免 CPU 占满
usleep(100000);
}
socket_close($server);
?>
</code>
在上述代码中，我们的监听 socket（$server）是非阻塞的，因此不会在 socket_accept() 上阻塞。每当接受到新连接后，我们将新客户端也设置为非阻塞。然而，在我们处理接收数据的部分，我们主动将客户端 socket 切换为阻塞模式，这是因为我们希望保证 socket_recv() 能完整接收到我们期望的数据，避免数据残缺。
这是非常常见的混合使用方式，在很多场景（如协议握手阶段）尤其重要。例如你设计了一个简单协议，规定客户端第一次发送必须包含固定头信息，服务端需要完整接收后才能继续处理，此时使用阻塞读取就变得非常有意义。
切换模式要谨慎：在非阻塞流程中临时使用阻塞读取是一种“强制等待”的手段，虽然方便，但如果客户端没有发送任何数据，服务端会被卡住，建议搭配超时机制或预设数据长度。
适用于短期阻塞：这类模式切换适用于某些操作必须阻塞完成的情况，不建议在整个通信过程中都采用阻塞方式。
使用 socket_set_block() 和 socket_set_nonblock() 可以让你的 PHP 套接字编程更具弹性。你可以根据处理逻辑灵活选择合适的阻塞模式，从而兼顾效率与完整性。
更多 socket 编程的实践与示例可以参考文档或访问我们的资源平台：
