传统PHP应用通常运行在PHP-FPM或Apache模块模式下，每个请求独立占用一个进程或线程，当请求执行耗时操作（如远程API调用、文件读写、数据库查询）时，进程只能阻塞等待，资源利用率较低。ReactPHP改变了这一模式，它通过事件循环（EventLoop）让单个PHP进程同时处理成千上万个并发连接，非常适合构建异步非阻塞的Web服务。本文将带你从安装ReactPHP的HTTP组件开始，逐步构建一个可运行的异步HTTP服务器，并深入理解其背后的非阻塞I/O机制。
理解事件循环与非阻塞I/O
ReactPHP的核心是事件循环（EventLoop）。事件循环本质上是一个无限循环，它不停地检查是否有事件发生，比如新的网络连接、数据到达、定时器到期等。一旦检测到事件，就立即调用事先注册好的回调函数。由于回调函数的执行时间通常非常短，事件循环可以在极短时间内处理大量事件，从而实现在单个PHP进程内并发处理多个任务。
与传统的同步阻塞I/O不同，ReactPHP中的I/O操作是非阻塞的。例如当你发起一个远程HTTP请求或读取文件时，不会停下来等待结果返回，而是告诉事件循环“等数据准备好了再叫我”。注册一个回调后，事件循环会继续处理其他事件，等到数据真正可用时再执行回调。这种模式使得一个进程可以同时管理数千个打开的连接，而不会因为某个慢请求拖垮整个服务。
为了优雅地组织异步代码，ReactPHP引入了Promise机制。一个异步操作会返回Promise对象，你可以通过then()方法注册成功回调，通过catch()或otherwise()注册失败回调。多个异步操作可以通过链式调用顺序执行，也可以使用all()等方法并行等待多个Promise。下面通过一个简单的定时器示例展示事件循环的基本用法：
<?php
require 'vendor/autoload.php';
$loop = React\EventLoop\Loop::get();
// 注册一个1秒后触发的定时器
$loop->addTimer(1, function () {
echo "定时器触发\n";
});
echo "开始事件循环\n";
$loop->run();
echo "事件循环结束\n";
这段代码输出“开始事件循环”，等待1秒后输出“定时器触发”，然后程序结束。在定时器等待期间，事件循环并没有阻塞，如果有其他事件到来，它可以同时处理。这正是异步非阻塞的直观体现。
使用ReactPHP HTTP组件创建服务器
要构建HTTP服务器，首先需要通过Composer安装react/http组件。在项目目录下执行composer require react/http，该组件依赖react/socket和react/event-loop，会自动安装相关依赖。安装完成后，你可以编写一个最简单的HTTP服务器：
<?php
require 'vendor/autoload.php';
use React\Http\Message\Response;
use Psr\Http\Message\ServerRequestInterface;
$loop = React\EventLoop\Loop::get();
$server = new React\Http\HttpServer(function (ServerRequestInterface $request) {
$path = $request->getUri()->getPath();
if ($path === '/') {
return new Response(200, ['Content-Type' => 'text/plain'], "Hello ReactPHP\n");
}
if ($path === '/json') {
return new Response(200, ['Content-Type' => 'application/json'], json_encode(['status' => 'ok']));
}
return new Response(404, ['Content-Type' => 'text/plain'], "Not Found\n");
});
$socket = new React\Socket\SocketServer('0.0.0.0:8080', [], $loop);
$server->listen($socket);
echo "服务器运行在 http://127.0.0.1:8080\n";
$loop->run();
这段代码创建了一个监听8080端口的HTTP服务器。HttpServer的构造函数接收一个回调函数，每次请求进入时都会执行该回调。回调函数的参数是ServerRequestInterface类型的请求对象，你可以从中获取请求路径、方法、头部等信息。回调必须返回一个ResponseInterface对象，这里使用React\Http\Message\Response构建响应。通过Content-Type头部可以返回纯文本或JSON数据。
启动服务器后，在浏览器访问http://127.0.0.1:8080即可看到输出。由于事件循环在$loop->run()处开始运行，服务器不会退出，而是持续等待新的请求。整个处理过程完全在内存中完成，不需要经过PHP-FPM或Web服务器，因此响应速度更快。
路由处理与中间件机制
上面的示例通过if语句手动判断路径，只适用于简单场景。对于真实项目，建议使用路由组件来管理URL与处理函数之间的映射。虽然ReactPHP的HTTP组件本身不提供路由功能，但你可以很方便地集成第三方路由库，例如nikic/fast-route。安装composer require nikic/fast-route后，可以这样组织路由：
<?php
require 'vendor/autoload.php';
use FastRoute\RouteCollector;
use function FastRoute\simpleDispatcher;
use React\Http\Message\Response;
use Psr\Http\Message\ServerRequestInterface;
$dispatcher = simpleDispatcher(function (RouteCollector $r) {
$r->addRoute('GET', '/', function () {
return new Response(200, ['Content-Type' => 'text/plain'], "首页\n");
});
$r->addRoute('GET', '/users/{id:\d+}', function ($vars) {
return new Response(200, ['Content-Type' => 'application/json'], json_encode(['user_id' => $vars['id']]));
});
});
$server = new React\Http\HttpServer(function (ServerRequestInterface $request) use ($dispatcher) {
$httpMethod = $request->getMethod();
$uri = $request->getUri()->getPath();
$routeInfo = $dispatcher->dispatch($httpMethod, $uri);
switch ($routeInfo[0]) {
case FastRoute\Dispatcher::NOT_FOUND:
return new Response(404, ['Content-Type' => 'text/plain'], 'Not Found');
case FastRoute\Dispatcher::METHOD_NOT_ALLOWED:
return new Response(405, ['Content-Type' => 'text/plain'], 'Method Not Allowed');
case FastRoute\Dispatcher::FOUND:
$handler = $routeInfo[1];
$vars = $routeInfo[2];
return $handler($vars);
}
});
这种方式将路由定义与请求处理逻辑分离，代码更清晰，支持正则约束和动态参数。除此之外，ReactPHP还支持中间件（Middleware）模式，你可以在请求到达最终处理函数之前或之后执行一些通用逻辑，例如身份验证、日志记录、CORS处理等。中间件通常是一个可调用对象，接收请求对象和下一个处理函数，并返回响应。
在实际开发中，你可能需要处理表单提交、上传文件、Cookie等。ReactPHP的HTTP组件提供了完整的PSR-7实现，可以配合其他PSR-15中间件使用。需要注意的是，所有中间件都必须在事件循环内保持非阻塞，否则会拖慢整个服务器。
异步数据库查询与并发任务
异步HTTP服务器的最大优势在于处理耗时I/O操作时不会阻塞事件循环。以数据库查询为例，传统的PDO或mysqli扩展是同步阻塞的，在查询执行期间整个进程无法处理其他请求。ReactPHP提供了异步MySQL客户端react/mysql，它基于Promise返回结果，可以完美融入事件循环。先安装composer require react/mysql，然后可以这样使用：
<?php
require 'vendor/autoload.php';
use React\EventLoop\Loop;
use React\MySQL\Factory;
use React\Http\Message\Response;
use Psr\Http\Message\ServerRequestInterface;
$loop = Loop::get();
$factory = new Factory($loop);
$db = $factory->createLazyConnection('user:pass@localhost/dbname');
$server = new React\Http\HttpServer(function (ServerRequestInterface $request) use ($db) {
$path = $request->getUri()->getPath();
if ($path === '/users') {
return $db->query('SELECT id, name FROM users LIMIT 10')->then(
function (React\MySQL\QueryResult $result) {
$users = $result->resultRows;
return new Response(200, ['Content-Type' => 'application/json'], json_encode($users));
},
function (Exception $e) {
return new Response(500, ['Content-Type' => 'text/plain'], '数据库查询失败');
}
);
}
return new Response(404, ['Content-Type' => 'text/plain'], 'Not Found');
});
$socket = new React\Socket\SocketServer('0.0.0.0:8080', [], $loop);
$server->listen($socket);
$loop->run();
上面的代码中，$db->query()返回一个Promise对象。当SQL执行完成时，then()中的第一个回调会被调用，并接收到查询结果。如果查询出错，第二个回调会处理异常并返回500响应。整个过程不会阻塞事件循环，服务器仍然可以同时处理其他请求。
需要特别注意的是，任何同步阻塞操作（如sleep()、file_get_contents()、原生PDO查询）都会暂停整个事件循环，导致所有请求被卡住。因此在使用ReactPHP时，必须选择合适的异步组件。对于文件操作，可以使用react/filesystem；对于HTTP客户端请求，使用react/http-client或react/browser；对于Redis，使用clue/reactphp-redis等。
错误处理、性能与部署建议
事件循环中如果发生未捕获的异常，进程可能会退出。为了避免单个请求错误导致整个服务器崩溃，应该在代码中主动捕获异常并返回合适的响应。你可以在HttpServer外层包装一个错误处理中间件，或者在每个处理函数中使用try-catch。另外，ReactPHP的Promise对象支持catch()方法，可以集中处理异步操作中的错误。建议在全局设置一个异常处理器，记录日志并返回500响应。
性能方面，ReactPHP使用单进程事件循环，内存占用远低于PHP-FPM的多进程模型，但需要注意闭包和对象引用可能导致的内存泄漏。长时间运行的进程会持续占用内存，如果回调中持有大量不再使用的数据，应显式释放或使用弱引用。同时，使用gc_collect_cycles()定期回收循环引用的对象也是一种实践。
部署ReactPHP服务时，建议使用进程管理器如Supervisor来守护服务进程，确保进程崩溃后自动重启。生产环境中通常在前面放置Nginx或HAProxy作为反向代理，负责SSL终止和静态文件服务，将动态请求转发到ReactPHP的HTTP端口。由于ReactPHP是单进程，如果需要利用多核CPU，可以启动多个进程监听不同端口或使用SO_REUSEPORT特性。与PHP-FPM相比，ReactPHP更适合长连接、WebSocket、实时通信、API网关等需要高并发低延迟的场景，但对于CPU密集型计算或传统CMS系统，PHP-FPM依然是更稳妥的选择。
通过以上步骤，你已经能够使用ReactPHP构建一个完整的异步非阻塞Web服务。从理解事件循环到处理数据库查询，再到生产部署，ReactPHP为PHP开发者打开了一扇通往异步编程的大门。掌握这一技术，可以显著提升PHP应用在高并发场景下的表现，同时降低服务器资源消耗。