如何让ReactPHP返回202 Accepted后后台执行异步任务

你的问题核心在于：ReactPHP是单线程事件循环模型，如果你用Loop::futureTick包裹同步阻塞的耗时任务（比如10秒循环），事件循环会被这个任务卡住，无法优先处理响应发送逻辑——因为futureTick的回调会抢占事件循环的下一次迭代，而同步阻塞代码会直接停住整个循环，必须等任务完成才能继续发送响应。

要实现「先返回响应，再后台执行任务」，必须把耗时任务从主线程的事件循环中剥离，具体方案如下：

方案1：用子进程执行阻塞任务（推荐） #

将耗时任务放到独立的子进程中运行，避免阻塞主线程的事件循环，确保响应能立即发送。

server.php 代码 #

<?php

require __DIR__ . '/vendor/autoload.php';

$loop = React\EventLoop\Loop::get();

$server = new React\Http\Server(function (Psr\Http\Message\ServerRequestInterface $request) use ($loop) {
    // 1. 立即构造并发送202响应
    $response = new React\Http\Message\Response(
        202,
        ['Content-Type' => 'text/plain'],
        'Accepted - Task running in background'
    );
    $response->end(); // 结束请求连接，响应立即发送

    // 2. 启动子进程执行耗时任务
    $process = new React\ChildProcess\Process('php ' . __DIR__ . '/long-task.php');
    $process->start($loop);

    // 可选：监听子进程状态和输出
    $process->stdout->on('data', fn($data) => echo "Task output: {$data}");
    $process->on('exit', fn($code) => echo "Task exited with code: {$code}\n");

    return $response;
});

$socket = new React\Socket\SocketServer('127.0.0.1:8080');
$server->listen($socket);

echo "Server running at http://127.0.0.1:8080\n";
$loop->run();

long-task.php （模拟耗时任务） #

<?php
// 模拟10秒阻塞任务
sleep(10);
echo "Long-running task finished\n";

方案2：用异步非阻塞API处理IO密集任务 #

如果你的耗时任务是IO等待型（比如数据库查询、HTTP请求），可以用ReactPHP的异步组件实现非阻塞等待，无需子进程：

<?php
// 需先安装 react/async：composer require react/async

require __DIR__ . '/vendor/autoload.php';

$loop = React\EventLoop\Loop::get();

$server = new React\Http\Server(function (Psr\Http\Message\ServerRequestInterface $request) {
    // 立即发送202响应
    $response = new React\Http\Message\Response(
        202,
        ['Content-Type' => 'text/plain'],
        'Accepted - Async task running'
    );
    $response->end();

    // 用异步非阻塞方式执行任务
    React\Async\async(function () {
        await React\Async\sleep(10); // 非阻塞等待10秒
        echo "Async task completed\n";
    })();

    return $response;
});

$socket = new React\Socket\SocketServer('127.0.0.1:8080');
$server->listen($socket);

echo "Server running at http://127.0.0.1:8080\n";
$loop->run();

为什么之前的futureTick方式无效？ #

Loop::futureTick的回调会在当前事件循环迭代结束后立即执行，但如果回调里是同步阻塞代码（比如10秒循环），整个事件循环会被彻底卡住——主线程会一直执行这个阻塞任务，无法处理响应发送、新请求等任何其他逻辑，直到任务完成。这就是为什么你的响应要等任务结束才返回。

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