thinkphp 8.1 在 swoole 协程下需配置协程连接池防“too many connections”,须满足:安装 think-swoole ≥3.1.0、swoole ≥4.8.0、php ≥8.1、启用 mysqlnd 驱动,并在 config/swoole.php 中配置 db_pool,代码中显式调用 db::pool()。

ThinkPHP 8.1 项目在 Swoole 协程环境下需要真正复用数据库连接、避免 Too many connections 报错,必须配置协程连接池——但这不是改个 config/database.php 就能生效的,它依赖扩展、驱动、调用方式三者严格对齐。
确认运行环境与依赖
第一步:执行 php think swoole 启动服务,【不是 php think run】;若命令报错或提示“Command not found”,说明 think-swoole 扩展未安装。
第二步:运行 php -m | grep swoole,确保输出包含 swoole,且版本 ≥ 4.8.0;低于此版本无法支持协程 MySQL 客户端。
第三步:检查 PHP 版本是否为 8.1 或 8.2:php -v;TP8.1 的协程适配层要求 PHP ≥ 8.1,PHP 8.0 或更低版本会跳过协程连接池初始化逻辑。
第四步:确认已安装 topthink/think-swoole ≥ 3.1.0:composer show topthink/think-swoole;旧版(如 3.0.x)存在 Db::pool() 不拦截模型查询的 bug,会导致连接池形同虚设。
配置连接池参数(仅在 config/swoole.php 中生效)
在 config/swoole.php 文件中添加或修改 db_pool 配置块:
方法一:基础安全配置(推荐新手)'db_pool' => [ 'max_active' => 32, 'max_idle' => 8, 'wait_timeout' => 2000, 'idle_timeout' => 60,],
⚠️ 注意:max_active 是硬上限,不是并发数;设为 32 表示整个 Worker 进程最多维持 32 条连接(空闲 + 忙碌),超过则排队等待,而非新建连接。
方法二:按压测结果动态调优
先压测获取真实峰值并发请求数(如 ab -n 5000 -c 200),再设 max_active = ceil(峰值并发 × 1.2);但必须同步检查 MySQL 的 @@max_connections,确保其 ≥ max_active × worker_num,否则多余连接直接被 MySQL 拒绝。
切换 MySQL 驱动为协程安全版本
TP8 默认使用 pdo_mysql,但它在协程下不安全:多个协程共用一个 PDO 实例会导致字段错乱或 MySQL server has gone away;必须替换为 mysqlnd + swoole_mysql 兼容层。
编辑 config/database.php,将数据库类型改为:'type' => 'mysqlnd',
同时删除所有 'params' => [PDO::ATTR_PERSISTENT => true] 类配置——协程连接池本身已接管复用逻辑,PDO 持久化在此场景下不仅无效,还会干扰连接归还。
【关键前提】:PHP 编译时必须启用 mysqlnd(非 libmysqlclient),可通过 php --ri mysqlnd 验证;若无输出,需重新编译 PHP 并启用 --with-mysql=mysqlnd。
代码中显式启用连接池
Db::connect() 和 Db::table() 默认走短连接,【必须手动调用 Db::pool()】 才进入池化路径:
方法一:普通查询Db::pool()->table('user')->where('id', 1)->find();
方法二:事务操作(注意:Db::transaction() 默认绕过池子)Db::pool()->transaction(function () { Db::pool()->table('order')->insert(['sn' => 'SN2026']); Db::pool()->table('log')->insert(['msg' => 'created']);});
方法三:模型类中接入池子(以 UserModel 为例)
在 app/model/UserModel.php 中重写 db() 方法:public function db(){ return Db::pool();}
这样 UserModel::find(1) 才会复用池中连接;否则模型仍走传统短连接。
验证连接池是否生效
在任意控制器中插入调试代码:
$pdo1 = Db::pool()->getPdo();Co::sleep(0.1);$pdo2 = Db::pool()->getPdo();var_dump($pdo1 === $pdo2); // 输出 true 表示复用成功
同时打开 MySQL 终端,执行:SHOW PROCESSLIST;
观察 Command 列:协程池正常工作时,活跃连接数应稳定在 max_active 附近,且 State 多为 Query 或 Sleep(非长时间阻塞);若大量出现 Unauthenticated user 或连接数持续飙升,则说明池子未生效或驱动不匹配。
php免费学习视频:立即使用
踏上前端学习之旅,开启通往精通之路!从前端基础到项目实战,循序渐进,一步一个脚印,迈向巅峰!











