Workerman中直接调用ThinkPHP的Db类会报错，根本原因是Db依赖容器和连接池初始化，而Workerman不走HTTP生命周期，需手动创建Connection实例并用Db::setConnection绑定；务必在Worker fork前完成初始化，避免连接泄漏。
Workerman里直接调用ThinkPHP的Db类会报错
Workerman是常驻内存的长连接服务，不走ThinkPHP的HTTP生命周期，Db类依赖的容器、配置、连接池初始化逻辑在非框架上下文中根本没执行。直接use think\facade\Db;然后Db::table('user')->select()大概率抛出ClassNotFoundException或Call to a member function query() on null。
根本原因不是“不能用”，而是“没初始化”。ThinkPHP 6 的Db facade 底层依赖think\Container和think\db\Connection实例，而这些默认只在App::run()启动时注入。
- 别在
onMessage里临时require入口文件试图“启动框架”——会导致重复加载、内存泄漏、连接句柄失控 - 不要手动
new Connection再塞进Dbfacade——facade内部有静态绑定，绕不过容器 - ThinkPHP 6.1+ 支持独立使用
think-swoole或think-worker扩展，但Workerman原生项目不推荐混用，冲突风险高
正确做法：手动初始化Db并复用连接
核心思路是跳过App容器，直接构造think\db\Connection实例，并用think\facade\Db的setConnection方法绑定。这样既保持语法一致，又避免框架耦合。
示例（放在Worker启动前，如start.php顶部）：
立即学习“PHP免费学习笔记（深入）”；
use think\facade\Db; use think\db\Connection; <p>// 读取数据库配置（建议从config/database.php中提取，不要硬编码） $config = [ 'type' => 'mysql', 'hostname' => '127.0.0.1', 'database' => 'test', 'username' => 'root', 'password' => '', 'hostport' => '3306', 'charset' => 'utf8mb4', ];</p><p>// 手动创建Connection实例 $connection = new Connection($config);</p><p>// 绑定到Db facade（关键一步） Db::setConnection($connection);
- 必须在所有Worker子进程fork前完成初始化，否则每个子进程都会新建连接，导致MySQL Too Many Connections
- 如果用了读写分离，需传入数组格式的
config，并确保Connection支持该模式（TP6.0+ 默认支持） - 连接断开后不会自动重连，可在查询前加
if (!$connection->getPDO()) { $connection->connect(); }兜底
在onMessage里安全使用Db要注意连接泄漏
Workerman每条连接对应一个事件循环，Db::table()->select()这类操作默认用的是长连接，但TP的连接管理器在常驻进程中不会自动清理闲置连接。连续高频查询可能耗尽MySQL连接数。
- 每次查询后显式关闭连接：
Db::getConnection()->close();（仅适用于单次查询场景） - 更稳妥的方式是用
Db::connect($config)->table(...)临时创建新连接，用完即弃（适合低频、偶发查询） - 高频业务务必启用连接池——但ThinkPHP原生不提供，需自行封装或改用
spiral/database、hyperf/database等兼容Swoole/Workerman的方案 - 注意事务：在
onMessage里开启事务后，必须显式commit或rollback，否则连接会一直被占用
替代方案：绕过Db facade，直接用PDO更可控
如果项目对性能、连接生命周期要求严格，或者只是偶尔查几条数据，直接上PDO反而更轻量、无隐式依赖。
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;charset=utf8mb4', 'root', '');
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
<p>$stmt = $pdo->prepare('SELECT * FROM user WHERE id = ?');
$stmt->execute([1]);
$user = $stmt->fetch(PDO::FETCH_ASSOC);
- 无需引入任何ThinkPHP类，启动快、内存干净
- 可配合
PDO::ATTR_PERSISTENT => true启用持久连接（注意Workerman多进程下需配合mysqlnd和正确配置） - 缺点是失去Query Builder、模型关联、自动类型转换等便利性，适合简单CRUD
真正难的不是“怎么调用Db”，而是想清楚这个查询是否真的需要ThinkPHP那套抽象——很多Workerman后台任务，查个配置、写条日志、校验token，PDO一行预处理就够了。
