PHP 中如何发送 HTTP 响应后继续处理？

2024-03-09 19:55:12

PHP 中发送 HTTP 响应后继续处理的解决方案

在 PHP 中，你可能会遇到在发送 HTTP 响应后继续处理脚本的问题。这是因为服务器在发送响应后会关闭与客户端的连接。为了解决这个问题，我们可以使用以下两种方法：

非阻塞 I/O

非阻塞 I/O 允许脚本在等待响应的同时处理其他请求。这可以通过使用 fread、fwrite 等流函数或 select 函数来实现。通过设置流的非阻塞模式，你可以继续执行脚本，而不会被阻塞在等待响应上。

消息队列

消息队列允许你将任务异步地发送到一个队列中。脚本可以从队列中读取任务并处理它们，而无需等待响应。你可以使用 Redis、RabbitMQ 或 Amazon SQS 等消息队列服务。通过将任务放入队列中，你可以将处理任务的过程与发送 HTTP 响应的过程解耦。

实现指南

非阻塞 I/O 实现：

// 创建流上下文，设置非阻塞模式
$context = stream_context_create([
    'socket' => [
        'blocking' => false,
    ],
]);

// 打开流
$fp = stream_socket_client('tcp://host:port', $errno, $errstr, -1, STREAM_CLIENT_CONNECT, $context);

// 接收消息
while (!feof($fp)) {
    $data = fread($fp, 4096);
    if ($data) {
        // 处理消息
    }
}

// 发送响应
fwrite($fp, 'HTTP/1.1 200 OK' . PHP_EOL);
fwrite($fp, 'Content-Type: text/plain' . PHP_EOL);
fwrite($fp, 'Content-Length: 12' . PHP_EOL);
fwrite($fp, 'Hello World' . PHP_EOL);

// 继续处理

消息队列实现：

// 创建消息队列客户端
$client = new Client();

// 从队列中获取任务
$task = $client->receive();

// 处理任务

// 发送响应
header('HTTP/1.1 200 OK');
header('Content-Type: text/plain');
echo 'Hello World';

// 继续处理