PHP协程高并发实战技巧

本文深入解析了PHP协程高并发编程的核心原理与实践要点，明确指出PHP原生不支持协程，必须依赖Swoole或OpenSwoole扩展，并严格限定于CLI模式运行——在Apache/Nginx+PHP-FPM等传统Web环境中协程完全不可用，强行调用会触发致命错误；文章强调协程高效的关键在于彻底摒弃同步I/O（如curl、file_get_contents、sleep），转而使用Swoole提供的协程化客户端（如Coroutine\Http\Client、Coroutine\MySQL），并详解了正确启动协程环境、避免资源复用、设置超时、处理连接失效及防止内存泄漏等高频踩坑场景，直击PHP协程落地中最易忽视却至关重要的底层约束与工程细节。

PHP 原生不支持协程，所谓“PHP 协程”实际依赖 Swoole 或 OpenSwoole 扩展实现，且必须运行在 CLI 模式下——Web 服务器（如 Apache、PHP-FPM）无法启用协程上下文。

为什么 swoole_coroutine_create 在 FPM 下调用会报错？

因为协程调度器只能在 Swoole 启动的事件循环中初始化。FPM 是多进程阻塞模型，没有协程调度器，swoole_coroutine_create 调用时会直接触发 Fatal error: Uncaught Swoole\Error: No coroutines running。

• 仅当使用 swoole_http_server、swoole_websocket_server 或显式调用 Swoole\Coroutine\run() 启动协程环境后，才能创建子协程
• Swoole\Coroutine\run() 是入口级协程容器，所有协程必须在其回调内启动
• Apache / Nginx + PHP-FPM 组合下，即使装了 Swoole，co::sleep() 等函数也会直接失败

如何正确启动协程并并发请求 HTTP 接口？

不能用 curl 或 file_get_contents，它们是同步阻塞 I/O；必须用 Swoole 提供的协程版客户端，如 Swoole\Coroutine\Http\Client。

• 每个协程内需独立创建 Swoole\Coroutine\Http\Client 实例，不可复用
• 调用 $client->get() 或 $client->post() 会自动挂起当前协程，直到响应返回或超时
• 超时必须显式设置：$client->set(['timeout' => 3]);，否则默认为 0（永不超时）
• 示例片段：

Swoole\Coroutine\run(function () {
    $urls = ['https://httpbin.org/delay/1', 'https://httpbin.org/delay/2'];
    $clients = [];
    foreach ($urls as $url) {
        Swoole\Coroutine\create(function () use ($url) {
            $parse = parse_url($url);
            $client = new Swoole\Coroutine\Http\Client($parse['host'], $parse['port'] ?? 443, $parse['scheme'] === 'https');
            $client->set(['timeout' => 5]);
            if ($client->get($parse['path'] . ($parse['query'] ? '?' . $parse['query'] : ''))) {
                echo "OK: {$url}, status={$client->statusCode}\n";
            } else {
                echo "FAIL: {$url}, error={$client->errMsg}\n";
            }
        });
    }
});

go 和 Swoole\Coroutine\create 有区别吗？

没有本质区别。go 是 Swoole\Coroutine\create 的函数别名，二者完全等价，都用于在当前协程环境中启动一个新协程。

• 二者参数签名一致，都接收一个 Closure
• 注意：不是所有 Closure 都能安全传入——若闭包引用了外部大对象（如 PDO 实例、文件句柄），可能引发内存泄漏或资源竞争
• 避免在协程中使用全局静态变量或 static 局部变量存储状态，协程间不隔离
• 协程 ID（Co::getcid()）可用于日志追踪，但不能作为唯一上下文标识（ID 可复用）

协程 MySQL 查询为什么报 MySQL server has gone away？

因为协程共享连接，而 MySQL 连接在协程切换时未做状态保持。Swoole 官方推荐使用 Swoole\Coroutine\MySQL，而非原生 mysqli 或 PDO。

• Swoole\Coroutine\MySQL 内置连接池与自动重连逻辑，但需手动调用 $mysql->connect()
• 每次查询前应检查连接是否活跃：if (!$mysql->connected) { $mysql->connect(...); }
• 不要跨协程复用同一个 Swoole\Coroutine\MySQL 实例；每个协程应独占实例，或使用 Swoole\Coroutine\Pool 管理
• 连接池配置不当（如 maxIdleTime 过短）会导致连接被提前回收，引发断连错误

协程不是魔法，它把“等待 I/O”的时间腾出来跑别的逻辑，但前提是所有 I/O 操作都走协程友好的驱动。混用同步函数（比如在协程里调 sleep()、file_get_contents()、Redis::get()）会直接阻塞整个协程调度器——这点比 Go 或 Python 的 async 更容易踩坑。

以上就是《PHP协程高并发实战技巧》的详细内容，更多关于的资料请关注golang学习网公众号！