php协程依赖swoole扩展且仅限cli模式,fpm因无协程调度器会报错;需用swoole协程客户端并发http请求,并避免同步i/o混用。

PHP 原生不支持协程,所谓“PHP 协程”实际依赖 Swoole 或 OpenSwoole 扩展实现,且必须运行在 CLI 模式下——Web 服务器(如 apache、PHP-FPM)无法启用协程上下文。
为什么 swoole_coroutine_create 在 FPM 下调用会报错?
因为协程调度器只能在 Swoole 启动的事件循环中初始化。FPM 是多进程阻塞模型,没有协程调度器,swoole_coroutine_create 调用时会直接触发 Fatal Error: Uncaught SwooleError: No coroutines running。
- 仅当使用
swoole_http_server、swoole_websocket_server或显式调用SwooleCoroutinerun()启动协程环境后,才能创建子协程 -
SwooleCoroutinerun()是入口级协程容器,所有协程必须在其回调内启动 - Apache / nginx + PHP-FPM 组合下,即使装了 Swoole,
co::sleep()等函数也会直接失败
如何正确启动协程并并发请求 HTTP 接口?
不能用 curl 或 file_get_contents,它们是同步阻塞 I/O;必须用 Swoole 提供的协程版客户端,如 SwooleCoroutineHttpClient。
- 每个协程内需独立创建
SwooleCoroutineHttpClient实例,不可复用 - 调用
$client->get()或$client->post()会自动挂起当前协程,直到响应返回或超时 - 超时必须显式设置:
$client->set(['timeout' => 3]);,否则默认为 0(永不超时) - 示例片段:
SwooleCoroutinerun(function () { $urls = ['https://httpbin.org/delay/1', 'https://httpbin.org/delay/2']; $clients = []; foreach ($urls as $url) { SwooleCoroutinecreate(function () use ($url) { $parse = parse_url($url); $client = new SwooleCoroutineHttpClient($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 和 SwooleCoroutinecreate 有区别吗?
没有本质区别。go 是 SwooleCoroutinecreate 的函数别名,二者完全等价,都用于在当前协程环境中启动一个新协程。
立即学习“PHP免费学习笔记(深入)”;
- 二者参数签名一致,都接收一个
Closure - 注意:不是所有 Closure 都能安全传入——若闭包引用了外部大对象(如 pdo 实例、文件句柄),可能引发内存泄漏或资源竞争
- 避免在协程中使用全局静态变量或
Static局部变量存储状态,协程间不隔离 - 协程 ID(
Co::getcid())可用于日志追踪,但不能作为唯一上下文标识(ID 可复用)
协程 mysql 查询为什么报 MySQL server has gone away?
因为协程共享连接,而 MySQL 连接在协程切换时未做状态保持。Swoole 官方推荐使用 SwooleCoroutineMySQL,而非原生 mysqli 或 PDO。
-
SwooleCoroutineMySQL内置连接池与自动重连逻辑,但需手动调用$mysql->connect() - 每次查询前应检查连接是否活跃:
if (!$mysql->connected) { $mysql->connect(...); } - 不要跨协程复用同一个
SwooleCoroutineMySQL实例;每个协程应独占实例,或使用SwooleCoroutinePool管理 - 连接池配置不当(如
maxIdleTime过短)会导致连接被提前回收,引发断连错误
协程不是魔法,它把“等待 I/O”的时间腾出来跑别的逻辑,但前提是所有 I/O 操作都走协程友好的驱动。混用同步函数(比如在协程里调 sleep()、file_get_contents()、redis::get())会直接阻塞整个协程调度器——这点比 Go 或 Python 的 async 更容易踩坑。