pdo在swoole协程中不安全，因连接状态（事务、变量、字符集等）会话级绑定，协程切换导致污染；正确做法是每个协程独占连接，使用连接池并归还前重置会话状态。
PHP 7.4 + Swoole 4 环境下，直接在协程中复用同一个 PDO 实例会导致连接污染——因为 PDO 连接是会话级资源，事务状态、临时表、用户变量、字符集、autocommit 模式等都绑定在连接上。协程切换时若未隔离连接上下文，一个协程开启的事务可能被另一个协程意外提交或回滚，或残留 LIMIT/SET 语句影响后续查询。
根本原因：PDO 不是协程安全的
PDO 本身不感知协程，其底层 MySQL 连接（libmysql 或 mysqlnd）是阻塞式、非线程/协程安全的。Swoole 协程调度时，多个协程共享同一线程和全局资源，若共用一个 PDO 实例：
- 事务未显式 commit/rollback 就切换协程，状态滞留；
- 执行
SET @var = 1后，另一协程读取@var得到错误值； - 前一个协程设置了
SET NAMES utf8mb4，后一个协程却因连接复用误用旧字符集； - 持久连接（
PDO::ATTR_PERSISTENT）在 Swoole 长生命周期中加剧污染风险。
正确做法：每个协程独占连接（连接池）
不能靠“手动 reset”或“set null”，而应让每个协程获取独立、干净的 PDO 连接。推荐使用轻量连接池（如 swoole/co 生态的 co-pool 或自建池），关键逻辑：
- 池中预创建固定数量 PDO 实例（非持久连接），每个连接初始化时执行
SET autocommit=1和SET NAMES utf8mb4； - 协程调用
$pdo = $pool->get()获取连接，用完必须$pool->put($pdo)归还； - 归还前强制重置会话状态：
$pdo->exec('ROLLBACK'); $pdo->exec('RESET CONNECTION');（MySQL 5.7.3+ 支持）； - 若用 MySQL 5.6 或更低版本，归还前需执行
$pdo->exec('KILL ' . $pdo->getAttribute(PDO::ATTR_CONNECTION_STATUS));并重建连接（开销较大，建议升级）。
避免踩坑的编码习惯
即使用了连接池，以下写法仍会引入污染：
- 将 PDO 实例存为类属性或全局变量（
static $pdo），协程间共享； - 在协程内开启事务后未配对 commit/rollback，直接 return 或抛异常；
- 使用
PDO::ATTR_PERSISTENT => true—— Swoole 下持久连接完全不可控，必须禁用； - 依赖析构函数（
__destruct）清理连接 —— 协程结束不触发析构，对象可能长期驻留。
简单可落地的初始化示例
不依赖第三方池，用 Swoole 自带协程容器快速实现：
（注意：仅作示意，生产环境请用成熟连接池库）// 初始化连接工厂（单例）
class PdoFactory {
private static $instance;
private function __construct() {}
public static function getInstance(): self {
if (!self::$instance) {
self::$instance = new self();
}
return self::$instance;
}
public function create(): PDO {
$pdo = new PDO(
'mysql:host=127.0.0.1;dbname=test',
'user', 'pass',
[PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION]
);
// 清理会话状态
$pdo->exec('SET autocommit = 1');
$pdo->exec('SET NAMES utf8mb4');
return $pdo;
}
}
// 协程内安全使用
go(function () {
$pdo = PdoFactory::getInstance()->create(); // 每次新建，无共享
try {
$pdo->beginTransaction();
$pdo->exec("INSERT INTO log VALUES ('test')");
$pdo->commit();
} catch (Exception $e) {
$pdo->rollback();
throw $e;
}
});php免费学习视频：立即使用
踏上前端学习之旅，开启通往精通之路！从前端基础到项目实战，循序渐进，一步一个脚印，迈向巅峰！
