Workerman不支持全局数据库连接，因其常驻内存特性易导致连接超时、资源泄露和并发问题；正确做法是在onWorkerStart中为每个进程建立独立连接或使用连接池，并通过心跳机制与异常重连保障连接可用性。
Workerman本身并不直接“支持”特定类型的数据库，因为它是一个基于PHP的异步事件驱动框架，其核心功能是管理PHP进程和处理网络请求。换句话说，Workerman可以与任何PHP语言能够连接和操作的数据库进行交互，这包括但不限于MySQL、PostgreSQL、MongoDB、Redis等。关键在于Workerman的运行机制——常驻内存，这要求我们对数据库连接的管理方式与传统PHP-FPM模式有所不同。通常，这意味着在每个Workerman进程启动时建立独立的数据库连接，或者更推荐的做法是利用连接池来高效管理这些连接。
Workerman环境下处理数据库连接，最核心的理念是理解其长驻内存的特性与传统Web服务器（如Nginx + PHP-FPM）的短生命周期模式之间的差异。在PHP-FPM模式下，每个请求完成后，所有资源（包括数据库连接）都会被释放，下次请求会重新初始化。但在Workerman中，进程一旦启动便会持续运行，如果我们在全局范围初始化一个数据库连接，这个连接会一直存在。
这种全局或静态的单一连接方式，在Workerman中会带来一系列问题：
因此，正确的数据库连接策略是：在每个Worker进程启动时（即onWorkerStart
这个问题，我个人觉得是很多从传统PHP-FPM背景转到Workerman的开发者最容易踩的坑。我们习惯了PHP脚本执行完就“万事大吉”，所有状态都清空。但在Workerman这种长驻内存的服务里，事情就没那么简单了。
原因其实很简单，核心在于生命周期管理。PHP-FPM模式下，一个请求进来，PHP脚本执行，连接数据库，处理完业务逻辑，脚本结束，数据库连接也随之关闭。整个过程是短暂而独立的。然而，Workerman进程一旦启动，就会持续运行，监听端口，处理无数个请求。如果你在脚本的顶层或者某个静态变量里初始化了一个数据库连接，这个连接就会伴随进程的整个生命周期。
这就导致了几个关键问题：
wait_timeout
MySQL server has gone away
所以，我的建议是，永远不要在Workerman中直接依赖一个全局的、静态的数据库连接。这几乎是所有长驻内存应用都会面临的问题，不光是Workerman。理解这一点，能帮你少走很多弯路。
在Workerman这样的长驻内存应用中，数据库连接池几乎是一个标准配置，它能极大地提升数据库操作的效率和稳定性。它主要解决了频繁建立/关闭连接的开销，并能更好地管理连接的生命周期。
我通常会推荐以下几种方案：
基于onWorkerStart
use Workerman\Worker;
use PDO;
$worker = new Worker('websocket://0.0.0.0:2346');
$worker->count = 4; // 启动4个Worker进程
// 在每个Worker进程启动时，建立独立的数据库连接
$worker->onWorkerStart = function($worker) {
global $db; // 使用全局变量存储连接
try {
$db = new PDO('mysql:host=localhost;dbname=test;charset=utf8', 'user', 'password', [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_PERSISTENT => false, // 明确设置为非持久化连接
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"
]);
// 可以在这里设置一些连接属性，比如长连接的心跳检测间隔
// $db->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
} catch (PDOException $e) {
echo "Worker {$worker->id} 数据库连接失败: " . $e->getMessage() . "\n";
// 连接失败通常是致命错误，让进程退出，Workerman会自动拉起新的进程
exit(250);
}
};
$worker->onMessage = function($connection, $data) {
global $db;
// 在这里直接使用$db进行数据库操作
try {
$stmt = $db->prepare("SELECT * FROM users WHERE id = ?");
$stmt->execute([1]);
$user = $stmt->fetch(PDO::FETCH_ASSOC);
$connection->send(json_encode($user));
} catch (PDOException $e) {
// 数据库操作失败，可能是连接断开，需要进一步处理
$connection->send("数据库操作失败: " . $e->getMessage());
// 考虑在此处尝试重连或记录日志
}
};
Worker::runAll();这种方式虽然简单，但每个进程只持有一个连接，严格来说它不是一个“池”，但它解决了每个进程独立连接的问题。
使用成熟的PHP ORM/DB库的连接管理： 如果你在使用Laravel、ThinkPHP、Yii等框架，它们通常有自己的数据库抽象层和连接管理机制。在Workerman环境下，这些框架的数据库组件通常也能通过一些配置或适配器来很好地工作。例如，Laravel的Eloquent ORM在Workerman中可以配置为按需获取连接或使用更高级的连接池。许多这些库内部已经考虑了连接的重用和状态管理。
Workerman生态内的异步数据库客户端/连接池： Workerman社区提供了一些专门为Workerman设计的异步客户端，它们通常内置了连接池功能。例如，
workerman/mysql
// 假设使用 workerman/mysql 异步客户端
use Workerman\Worker;
use Workerman\MySQL\Connection; // 假设这是 workerman/mysql 的类
$worker = new Worker('websocket://0.0.0.0:2346');
$worker->count = 4;
$worker->onWorkerStart = function($worker) {
global $db_pool;
// 这里可以初始化一个连接池实例，或者直接在onMessage中按需获取
// workerman/mysql 自身就支持连接池模式
$db_pool = new Connection('127.0.0.1', 3306, 'user', 'password', 'test');
// $db_pool 实际上是一个连接池，可以从中获取连接
};
$worker->onMessage = function($connection, $data) {
global $db_pool;
// 从连接池中获取一个连接并执行查询
$db_pool->query("SELECT * FROM users LIMIT 1", function($result) use ($connection) {
$connection->send(json_encode($result));
});
};
Worker::runAll();使用异步客户端的好处是，当数据库查询耗时较长时，不会阻塞Workerman进程，提高了整体的并发处理能力。
选择哪种方案，取决于你的项目规模、性能要求以及你对异步编程的熟悉程度。对于大多数中小项目，第一种
onWorkerStart
数据库连接断开，这是在任何长驻内存应用中都无法避免的问题，它可能由多种原因引起：数据库服务器重启、网络波动、数据库服务器主动关闭空闲连接（
wait_timeout
我通常会从以下几个层面来考虑和实现：
心跳检测（Keep-Alive）： 这是预防连接断开的有效手段。你可以设置一个定时器（例如，每隔几分钟），向数据库发送一个非常轻量级的查询，比如
SELECT 1
use Workerman\Worker;
use Workerman\Timer;
use PDO;
// ... (onWorkerStart 部分，确保 $db 是全局变量)
$worker->onWorkerStart = function($worker) {
global $db;
// ... 建立 $db 连接的代码 ...
// 每60秒发送一次心跳
Timer::add(60, function() use (&$db, $worker) {
try {
$db->query("SELECT 1");
} catch (PDOException $e) {
echo "Worker {$worker->id} 数据库心跳失败，尝试重连...\n";
// 尝试重连
try {
$db = new PDO('mysql:host=localhost;dbname=test;charset=utf8', 'user', 'password', [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_PERSISTENT => false,
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"
]);
echo "Worker {$worker->id} 数据库重连成功。\n";
} catch (PDOException $reconnectE) {
echo "Worker {$worker->id} 数据库重连失败: " . $reconnectE->getMessage() . "\n";
// 重连失败，考虑让进程退出，Workerman会拉起新进程
exit(250);
}
}
});
};
// ...异常捕获与按需重连： 这是最直接的应对方式。在每次执行数据库操作时，都用
try-catch
PDOException
server has gone away
// ... (接上面的onWorkerStart部分)
$worker->onMessage = function($connection, $data) {
global $db;
$maxRetries = 3; // 最大重试次数
for ($i = 0; $i < $maxRetries; $i++) {
try {
$stmt = $db->prepare("SELECT * FROM users WHERE id = ?");
$stmt->execute([1]);
$user = $stmt->fetch(PDO::FETCH_ASSOC);
$connection->send(json_encode($user));
return; // 成功则返回
} catch (PDOException $e) {
// 判断是否是连接断开错误
if (strpos($e->getMessage(), 'server has gone away') !== false ||
strpos($e->getMessage(), 'SQLSTATE[HY000]') !== false ||
strpos($e->getMessage(), 'Broken pipe') !== false) {
echo "数据库连接断开，尝试重连... (Worker {$connection->worker->id}, 尝试次数: " . ($i + 1) . ")\n";
// 尝试重新建立连接
try {
$db = new PDO('mysql:host=localhost;dbname=test;charset=utf8', 'user', 'password', [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_PERSISTENT => false,
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"
]);
echo "数据库重连成功。\n";
// 重连成功后，继续尝试执行原始查询以上就是Workerman支持哪些数据库？Workerman数据库连接方式？的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
1010
收藏
