PHP如何使用协程_高并发协程编程操作方法汇总【详解】

2次阅读

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

PHP如何使用协程_高并发协程编程操作方法汇总【详解】

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_serverswoole_websocket_server 或显式调用 SwooleCoroutinerun() 启动协程环境后,才能创建子协程
  • SwooleCoroutinerun() 是入口级协程容器,所有协程必须在其回调内启动
  • Apache / nginx + PHP-FPM 组合下,即使装了 Swoole,co::sleep() 等函数也会直接失败

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

不能用 curlfile_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";             }         });     } });

goSwooleCoroutinecreate 有区别吗?

没有本质区别。goSwooleCoroutinecreate 的函数别名,二者完全等价,都用于在当前协程环境中启动一个新协程。

立即学习PHP免费学习笔记(深入)”;

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

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

因为协程共享连接,而 MySQL 连接在协程切换时未做状态保持。Swoole 官方推荐使用 SwooleCoroutineMySQL,而非原生 mysqliPDO

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

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

text=ZqhQzanResources