ReactPHP HTTP Server如何实现异步请求处理？是否缺少配置？

ReactPHP HTTP Server 完全支持异步处理请求，你当前遇到的同步阻塞问题，根源是使用了PHP原生的sleep()函数——这是一个阻塞式同步函数，会直接卡住ReactPHP的事件循环，导致所有后续请求都必须等待当前阻塞操作完成才能处理。

为什么sleep()会导致同步？ #

ReactPHP的核心是单线程事件循环，所有异步逻辑都依赖这个循环的非阻塞运转。一旦调用sleep()这类阻塞函数，整个进程会暂停执行，事件循环无法处理新的请求、定时器或其他异步任务，直到阻塞结束。

正确的异步实现方式 #

要实现异步处理，你需要使用ReactPHP提供的非阻塞异步API来替代阻塞操作，比如用异步定时器模拟耗时任务，或使用React生态中的异步客户端处理实际的IO操作（如数据库查询、远程API调用）。

下面是修改后的代码示例，用ReactPHP的异步定时器替代sleep()，实现真正的异步请求处理：

<?php

use React\Http\Server;
use React\Http\Message\Response;
use Psr\Http\Message\ServerRequestInterface;
use React\EventLoop\Loop;

$httpServer = new Server(
    function(ServerRequestInterface $request) {
        $path = $request->getUri()->getPath();
        
        // 返回Promise对象，让事件循环可以在等待时处理其他请求
        return new \React\Promise\Promise(function ($resolve) use ($path) {
            // 根据路径设置异步延迟时间
            $delay = match($path) {
                '/testSlow' => 5,
                '/testFast' => 1,
                default => 0
            };
            
            // 使用ReactPHP的异步定时器，不会阻塞事件循环
            Loop::addTimer($delay, function () use ($path, $resolve) {
                $resolve(new Response(
                    200,
                    [
                        "Access-Control-Allow-Headers" => "*",
                        "Access-Control-Allow-Origin" => "*",
                        "Content-Type" => "application/json"
                    ],
                    json_encode($path)
                ));
            });
        });
    }
);

$socketServer = new React\Socket\Server("0.0.0.0:31");
$httpServer->listen($socketServer);

echo "Server running on http://0.0.0.0:31\n";

代码说明 #

1. 返回Promise：请求处理函数返回React\Promise\Promise对象，告知ReactPHP当前请求需要异步处理，事件循环可以先去处理其他请求。
2. 异步定时器：用Loop::addTimer()替代sleep()，这个定时器是非阻塞的——它会在指定延迟后触发回调，但不会暂停事件循环，期间可以正常处理其他请求。
3. 实际场景扩展：如果你的耗时操作是数据库查询或远程API调用，要使用React生态对应的异步客户端（如react/mysql、react/http-client），避免使用同步IO扩展（如mysqli、file_get_contents）。

验证效果 #

现在你先请求/testSlow，紧接着请求/testFast：

• /testFast会在1秒后返回响应
• /testSlow会在5秒后返回响应
  两个请求并行处理，无需等待前一个请求完成。

内容的提问来源于stack exchange，提问作者TheLovelySausage