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 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 的函数别名,二者完全等价,都用于在当前协程环境中启动一个新协程。
本书图文并茂,详细讲解了使用LAMP(PHP)脚本语言开发动态Web程序的方法,如架设WAMP平台,安装与配置开源Moodle平台,PHP程序设计技术,开发用户注册与验证模块,架设LAMP平台。 本书适合计算机及其相关专业本、专科学生作为学习LAMP(PHP)程序设计或动态Web编程的教材使用,也适合对动态Web编程感兴趣的读者自觉使用,对LAMP(PHP)程序设计人员也具有一定的参考价值。
立即学习“PHP免费学习笔记(深入)”;
- 二者参数签名一致,都接收一个
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 更容易踩坑。










