使用 PHP 和 Swoole 构建高性能协程 HTTP 服务

PHP 长期以来被贴上“脚本语言、性能一般”的标签，尤其在传统 LNMP 架构下，每次请求都要经历完整的框架初始化、文件加载和进程销毁流程。虽然 OPcache 和 FPM 在一定程度上缓解了性能问题，但面对高并发、低延迟的场景，PHP 依然显得力不从心。Swoole 的出现彻底改变了这一局面。它通过 PHP 扩展的方式，为 PHP 提供了协程、异步 IO、常驻内存等能力，让 PHP 也能构建出媲美 Go、Node.js 的高性能网络服务。

本文将带你从零开始，使用 PHP 和 Swoole 构建一个高性能的协程 HTTP 服务，并深入探讨其核心原理与最佳实践。

为什么选择 Swoole？

Swoole 是一个面向生产环境的 PHP 异步网络通信引擎，它让 PHP 开发者可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP、WebSocket 服务。其核心优势包括：

• 常驻内存：避免每次请求重复加载框架和配置，大幅降低开销。
• 协程支持：以同步的写法实现异步的性能，没有回调地狱。
• 内置连接池：轻松管理 MySQL、Redis 等连接，避免频繁创建销毁。
• 毫秒级定时器：支持高精度定时任务。
• 多进程模型：充分利用多核 CPU。

与传统 FPM 模式相比，Swoole 的 HTTP 服务在 QPS 上通常有 5 到 10 倍的提升，同时内存占用更低。

环境准备

在开始之前，请确保你的环境满足以下要求：

• PHP 7.4 或更高版本（推荐 PHP 8.1+）
• Swoole 5.0 或更高版本
• Linux 或 macOS（Windows 可通过 WSL2 或 Docker）

安装 Swoole 最简单的方式是通过 PECL：

pecl install swoole

然后在 php.ini 中添加：

extension=swoole.so

使用 php --ri swoole 验证安装是否成功。

编写第一个协程 HTTP 服务

下面是一个最基础的 Swoole HTTP 服务示例：

<?php
use Swoole\Http\Server;
use Swoole\Http\Request;
use Swoole\Http\Response;

$server = new Server('0.0.0.0', 9501);

$server->set([
    'worker_num' => 4,          // 工作进程数，建议为 CPU 核数的 1-2 倍
    'enable_coroutine' => true, // 开启协程
    'max_request' => 10000,     // 每个进程处理的最大请求数，防止内存泄漏
]);

$server->on('Request', function (Request $request, Response $response) {
    // 协程环境下，这里可以使用协程化的 IO 操作
    $response->header('Content-Type', 'application/json');
    $response->end(json_encode([
        'message' => 'Hello, Swoole!',
        'time' => microtime(true),
    ]));
});

$server->start();

运行 php server.php，访问 http://127.0.0.1:9501 即可看到响应。这个服务已经具备了协程能力，但还没有体现出协程的真正威力。

协程化的 IO 操作

Swoole 提供了协程化的 MySQL、Redis、HTTP 客户端等组件。在协程环境中，这些操作会自动挂起当前协程，让出 CPU 给其他协程，从而实现高并发。

以协程 Redis 为例：

use Swoole\Coroutine\Redis;

$server->on('Request', function (Request $request, Response $response) {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    
    // 这里的 get 是协程化的，不会阻塞其他请求
    $value = $redis->get('some_key');
    
    $response->end(json_encode(['value' => $value]));
});

注意：每次请求都创建新的 Redis 连接并不高效。在生产环境中，应该使用连接池。

使用连接池管理资源

Swoole 提供了 Swoole\Database\RedisPool 和 Swoole\Database\PDOPool 等连接池组件。以下是一个 Redis 连接池的示例：

use Swoole\Database\RedisConfig;
use Swoole\Database\RedisPool;

$pool = new RedisPool(
    (new RedisConfig())
        ->withHost('127.0.0.1')
        ->withPort(6379)
        ->withTimeout(1.0),
    64 // 连接池大小
);

$server->on('Request', function (Request $request, Response $response) use ($pool) {
    $redis = $pool->get();
    try {
        $value = $redis->get('some_key');
        $response->end(json_encode(['value' => $value]));
    } finally {
        $pool->put($redis); // 务必归还连接
    }
});

连接池的大小需要根据实际并发量和后端服务的承载能力进行调优。过小会导致请求排队，过大会压垮后端。

路由与中间件设计

虽然 Swoole 的 HTTP 服务本身不提供路由功能，但我们可以轻松实现一个轻量级路由：

$routes = [];

function route(string $method, string $path, callable $handler) {
    global $routes;
    $routes[$method][$path] = $handler;
}

route('GET', '/users', function (Request $request, Response $response) {
    $response->end(json_encode(['users' => []]));
});

$server->on('Request', function (Request $request, Response $response) {
    global $routes;
    $method = $request->server['request_method'];
    $path = $request->server['request_uri'];
    
    // 去除查询字符串
    if (($pos = strpos($path, '?')) !== false) {
        $path = substr($path, 0, $pos);
    }
    
    $handler = $routes[$method][$path] ?? null;
    if ($handler) {
        $handler($request, $response);
    } else {
        $response->status(404);
        $response->end(json_encode(['error' => 'Not Found']));
    }
});

对于更复杂的应用，可以引入中间件机制，在请求处理前后执行额外逻辑，如鉴权、日志、CORS 等。

性能调优建议

1. 合理设置 worker_num：通常为 CPU 核数的 1-2 倍。IO 密集型应用可以适当增加。
2. 开启 task 进程：对于耗时操作（如发送邮件、处理图片），投递到 task 进程异步执行，避免阻塞 worker。
3. 使用协程化的组件：避免在协程中使用阻塞的 IO 函数，如 file_get_contents、curl_exec 等。Swoole 提供了 Swoole\Coroutine\Http\Client 等替代品。
4. 注意内存泄漏：常驻内存意味着变量不会自动释放。避免在全局变量中累积数据，定期重启 worker（通过 max_request）。
5. 启用 OPcache：虽然 Swoole 常驻内存，但 OPcache 仍能加速首次加载。
6. 压测与监控：使用 ab、wrk 等工具压测，结合 Swoole 的 stats() 方法监控运行状态。

常见陷阱与注意事项

• 不要使用 exit 和 die：它们会终止整个 worker 进程，影响其他请求。
• 全局变量和静态变量：在协程间共享，需谨慎使用，避免数据污染。
• 超全局变量：$_GET、$_POST 等在 Swoole 中不可用，需从 Request 对象获取。
• 异常处理：协程中的异常必须捕获，否则可能导致进程退出。
• 信号处理：Swoole 已内置信号管理，不要随意注册信号处理器。

总结

Swoole 为 PHP 打开了高性能服务端编程的大门。通过协程、常驻内存和连接池，我们可以用 PHP 构建出高并发、低延迟的 HTTP 服务，同时保持代码的简洁和可维护性。本文从基础服务搭建到连接池、路由设计，再到性能调优和注意事项，为你提供了一条完整的实践路径。

当然，Swoole 并非银弹。它适合 IO 密集型、高并发的场景，而对于 CPU 密集型任务，仍需结合多进程或其他语言。在实际项目中，建议从简单服务开始，逐步引入连接池、任务队列等组件，并通过压测持续优化。

现在，不妨动手写一个属于自己的 Swoole HTTP 服务，体验 PHP 的另一种可能。

未经允许不得转载：任鹏个人博客 » 使用 PHP 和 Swoole 构建高性能协程 HTTP 服务