Swoole协程通过用户态调度实现轻量级并发，利用go函数创建协程、WaitGroup同步任务，并通过Runtime::enableCoroutine启用全局协程化，使I/O操作自动非阻塞；相比多线程/多进程，协程开销小、调度高效，共享内存但需避免全局变量污染，推荐使用协程上下文传递数据，数据库连接则通过连接池复用，提升资源利用率和系统吞吐量。
Swoole协程，简单来说，就是Swoole为PHP带来的一种轻量级并发编程方式。它让我们可以用接近编写同步代码的直观方式，去实现高性能的异步I/O操作。它不是多线程或多进程，而是在单个进程内通过用户态调度，实现任务之间的协作式切换，从而在等待I/O时，CPU可以去处理其他任务，而不是空闲着。这感觉就像在同一个房间里，一个人在等水烧开的时候，可以顺手把菜切了，而不是傻等着。
使用Swoole协程的核心，在于利用Swoole提供的
go
Swoole\Coroutine\run
Swoole\Runtime::enableCoroutine
最直接的用法就是将需要异步执行的代码块包裹在
go
<?php
use Swoole\Coroutine\WaitGroup;
use function Swoole\Coroutine\go;
use function Swoole\Coroutine\run;
run(function () {
$wg = new WaitGroup();
// 模拟第一个耗时操作
$wg->add();
go(function () use ($wg) {
echo "协程A：开始模拟耗时操作...\n";
Co::sleep(1.5); // 模拟I/O等待
echo "协程A：耗时操作完成。\n";
$wg->done();
});
// 模拟第二个耗时操作
$wg->add();
go(function () use ($wg) {
echo "协程B：开始模拟另一个耗时操作...\n";
Co::sleep(1); // 模拟I/O等待
echo "协程B：另一个耗时操作完成。\n";
$wg->done();
});
$wg->wait(); // 等待所有协程完成
echo "所有协程任务都完成了。\n";
});
?>这段代码里，
run
go
Co::sleep()
WaitGroup
立即进入“豆包AI人工智官网入口”；
立即学习“豆包AI人工智能在线问答入口”；
如果你想让大部分I/O操作（比如
file_get_contents
PDO
Redis
go
<?php
use Swoole\Runtime;
use function Swoole\Coroutine\run;
// 启用全局协程化，会将PHP标准库中的阻塞I/O函数Hook为协程版本
Runtime::enableCoroutine(true);
run(function () {
// 这里的file_get_contents在Swoole协程环境下会自动变成非阻塞
$content1 = file_get_contents('http://example.com/api/data1');
echo "获取到数据1长度：" . strlen($content1) . "\n";
// 模拟另一个数据库查询，如果数据库驱动支持协程化，也会是非阻塞
// $db = new PDO(...);
// $result = $db->query('SELECT * FROM users');
echo "所有I/O操作都在协程中异步完成。\n";
});
?>这种方式极大地简化了异步编程的复杂度，让原本需要大量回调函数或复杂状态机才能实现的异步逻辑，变得像同步代码一样清晰。
协程提升性能的关键在于它对I/O密集型任务的处理方式。在传统的PHP-FPM模式下，一个请求通常会占用一个进程，当这个进程进行数据库查询、文件读写或网络请求（这些都是I/O操作）时，它会阻塞，直到I/O完成。这意味着，在等待I/O的这段时间里，这个进程是“闲置”的，无法处理其他请求，导致服务器的并发能力受限。
协程则不同，它是一种“协作式多任务”机制。当一个协程遇到I/O操作时，它会主动或被动地让出CPU执行权。Swoole的调度器会立即切换到另一个准备就绪的协程去执行，而不是等待当前协程的I/O完成。这样，在单个进程内，CPU可以持续地执行有意义的计算任务，而不是被I/O阻塞。这就像一个多面手，在等待A任务反馈时，可以立马切换到B任务，大大提高了CPU的利用率和系统的吞吐量。
与传统多线程或多进程的区别在于：
所以，协程更像是“用户态的线程”，它在保持单进程高效利用CPU的同时，解决了传统异步编程的“回调地狱”问题，让代码更易读、易维护。
在Swoole协程环境下，全局变量和数据库连接的管理确实是需要特别注意的地方，因为它们可能导致意想不到的问题，比如数据污染或连接耗尽。
全局变量管理：
在传统PHP-FPM模式下，每个请求都是独立的进程，全局变量在请求结束后就会被销毁。但在Swoole常驻内存的模式下，多个协程可能在同一个进程内并发执行，并且共享进程的内存空间。这意味着，如果你不小心在协程中修改了全局变量，这个修改可能会影响到其他协程，导致数据混乱。
比如：
<?php
// 这是一个危险的全局变量
$config = [];
run(function () {
go(function () {
global $config;
$config['user_id'] = 1; // 协程A修改了全局变量
Co::sleep(0.1);
echo "协程A获取到的user_id: " . $config['user_id'] . "\n"; // 可能会被协程B修改
});
go(function () {
global $config;
Co::sleep(0.05); // 稍微晚一点执行
$config['user_id'] = 2; // 协程B也修改了全局变量
echo "协程B修改user_id为2\n";
});
Co::sleep(0.2); // 等待一下，让协程执行
});
?>这种情况下，协程A最后输出的
user_id
最佳实践：
避免使用全局变量：这是最根本的原则。尽量将数据通过函数参数传递，或者使用协程上下文（
Swoole\Coroutine::getContext()
使用协程上下文：对于需要在协程内传递但又不希望污染全局的数据，协程上下文是理想选择。
<?php
use Swoole\Coroutine;
use function Swoole\Coroutine\go;
use function Swoole\Coroutine\run;
run(function () {
go(function () {
// 设置协程私有数据
Coroutine::getContext()['request_id'] = uniqid('reqA_');
Co::sleep(0.1);
echo "协程A的请求ID: " . Coroutine::getContext()['request_id'] . "\n";
});
go(function () {
Coroutine::getContext()['request_id'] = uniqid('reqB_');
Co::sleep(0.05);
echo "协程B的请求ID: " . Coroutine::getContext()['request_id'] . "\n";
});
Co::sleep(0.2);
});
?>这样，即使两个协程并发执行，它们的
request_id
数据库连接管理：
数据库连接是宝贵的资源，创建和销毁连接都有开销。在协程环境下，如果每个请求都去创建新的数据库连接，很快就会耗尽数据库的最大连接数。
最佳实践：
使用连接池（Connection Pool）：这是Swoole协程环境下管理数据库连接的标准做法。连接池预先创建好一定数量的数据库连接，并维护它们。当一个协程需要数据库连接时，它从连接池中“借用”一个连接；使用完毕后，将连接“归还”给连接池，而不是关闭。这样，连接可以被多个协程复用，大大减少了连接创建和销毁的开销，也避免了连接数超限的问题。
Swoole生态中有许多成熟的连接池库，例如
swoole/pdo-coroutine
hyperf/db
<?php
use Swoole\Coroutine\Channel;
use function Swoole\Coroutine\go;
use function Swoole\Coroutine\run;
// 模拟一个简化的连接池
class DbPool
{
protected Channel $pool;
protected int $maxConnections;
public function __construct(int $maxConnections)
{
$this->maxConnections = $maxConnections;
$this->pool = new Channel($maxConnections);
for ($i = 0; $i < $maxConnections; $i++) {
// 实际生产中这里是创建真实的PDO或MySQLi连接
$this->pool->push(new class {
public $id;
public function __construct() { $this->id = uniqid('conn_'); }
public function query(string $sql) { Co::sleep(0.01); return "Result for " . $sql . " using " . $this->id; }
});
}
}
public function get()
{
return $this->pool->pop(); // 从池中获取连接
}
public function put($conn)
{
$this->pool->push($conn); // 将连接归还池中
}
}
run(function () {
$dbPool = new DbPool(5); // 创建一个包含5个连接的连接池
for ($i = 0; $i < 10; $i++) {
go(function () use ($dbPool, $i) {
$conn = null;
try {
$conn = $dbPool->get(); // 获取连接
echo "协程{$i}: 获得连接 " . $conn->id . "\n";
$result = $conn->query("SELECT * FROM users WHERE id = {$i}");
echo "协程{$i}: 查询结果: " . $result . "\n";
} finally {
if ($conn) {
$dbPool->put($conn); // 确保连接被归还
echo "协程{$i}: 归还连接 " . $conn->id . "\n";
}
}
});
}
Co::sleep(0.5); // 等待所有协程完成
});
?>通过连接池，即使有大量并发协程，实际使用的数据库连接数也始终控制在池的大小范围内，极大地提高了资源利用率和稳定性。
总结来说，在Swoole协程环境中，核心思想是“无状态”和“资源复用”。尽量避免依赖全局状态，并通过连接池等机制来高效地管理外部资源。
以上就是Swoole协程是什么？协程如何使用？的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
710
收藏
