Swoole协程怎么使用才能提高开发效率-Swoole-PHP中文网

swoole协程提升效率的核心是同步写法获异步性能，需在coroutine::run()中运行，替换阻塞io为协程客户端，用go并发、channel收集结果、defer释放资源，并通过setdefer实现延迟收包以压缩耗时。

swoole协程怎么使用才能提高开发效率

用Swoole协程提升开发效率，核心是让同步写法自动获得异步性能，避免回调嵌套、减少手动调度、复用连接资源。必须在Swoole专用协程上下文中运行，否则co::sleep()、协程MySQL等调用会退化为阻塞行为，完全失去并发优势。

启动协程环境并验证是否生效

第一步：确认Swoole扩展已加载且版本≥4.8，执行php -m | grep swoole查看输出；

第二步：创建入口文件，用Swoole\Coroutine\run()包裹主逻辑，不能直接在CLI或Web SAPI中调用协程函数；

第三步：在run闭包内立即执行go(function () { co::sleep(0.01); echo "协程已激活\n"; });——若输出文字且无延迟卡顿，说明协程调度器已就绪；

【未包裹在Swoole\Coroutine\run()中会导致所有协程操作同步阻塞】

替换阻塞IO为协程客户端

方法一：数据库访问

禁用new PDO()或mysqli_connect()，改用$mysql = new Swoole\Coroutine\MySQL(); $mysql->connect([...])；

方法二：HTTP请求

停用file_get_contents()和curl_exec()，改用$client = new Swoole\Coroutine\Http\Client($host, $port)；

方法三：系统命令与DNS查询

用Co::exec("ls -l")替代shell_exec()，用Co::gethostbyname("github.com")替代gethostbyname()；

这一步操作起来很简单，直接把原生调用替换成对应协程类实例即可，但必须全部替换干净，漏掉一个阻塞调用就会拖垮整个协程组。

重构串行逻辑为并发协程

① 把多个独立数据库查询从依次等待改为并行发起：

go(function () use ($mysql) { $mysql->query("SELECT * FROM user WHERE id = 1"); });

Swoole 6.1.1

Swoole 6.1.1 是一个专为 PHP 设计的高性能事件驱动并发网络引擎。作为稳定版，它修复了编译时对 zlib 依赖的缺失及 curl 模块的内存安全风险。该版本支持协程、多线程与多进程架构，内置 TCP/HTTP/WebSocket 服务器，能够显著提升 PHP 在微服务、实时通信等场景下的执行效率与并发能力。

下载

go(function () use ($mysql) { $mysql->query("SELECT * FROM order WHERE uid = 1"); });

② 批量HTTP请求统一触发，再用Channel收集结果：

$chan = new Swoole\Coroutine\Channel(2);

go(function () use ($chan) { $c = new Co\Http\Client('httpbin.org', 80); $c->get('/uuid'); $chan->push($c->body); });

go(function () use ($chan) { $c = new Co\Http\Client('httpbin.org', 80); $c->get('/user-agent'); $chan->push($c->body); });

for ($i = 0; $i pop(), "\n"; }

③ 使用defer确保资源释放：在协程开头写defer(function () { $mysql->close(); });，防止连接泄露；

【Channel容量必须预先设为协程数量，否则pop会永久阻塞】