workerman 物联网 workerman物联网
Workerman不支持全局数据库连接，因其常驻内存特性易导致连接超时、资源泄露和并发问题；正确做法是在onWorkerStart中为每个进程建立独立连接或使用连接池，并通过心跳机制与异常重连保障连接可用性。
Workerman本身并不直接“支持”特定类型的数据库，因为它是一个基于PHP的异步事件驱动框架，其核心功能是管理PHP进程和处理网络请求。换句话说，Workerman可以与任何PHP语言能够连接和操作的数据库进行交互，这包括但不限于MySQL、PostgreSQL、MongoDB、Redis等。关键在于Workerman的运行机制——常驻内存，这要求我们对数据库连接的管理方式与传统PHP-FPM模式有所不同。通常，这意味着在每个Workerman进程启动时建立独立的数据库连接，或者更推荐的做法是利用连接池来高效管理这些连接。
解决方案Workerman环境下处理数据库连接，最核心的理念是理解其长驻内存的特性与传统Web服务器（如Nginx + PHP-FPM）的短生命周期模式之间的差异。在PHP-FPM模式下，每个请求完成后，所有资源（包括数据库连接）都会被释放，下次请求会重新初始化。但在Workerman中，进程一旦启动便会持续运行，如果我们在全局范围初始化一个数据库连接，这个连接会一直存在。
这种全局或静态的单一连接方式，在Workerman中会带来一系列问题：
连接超时与失效： 数据库服务器通常会设置连接超时时间。如果一个Workerman进程长时间没有数据库操作，数据库服务器可能会主动关闭这个空闲连接。但Workerman进程端对此毫不知情，下次尝试使用这个“死连接”时，就会抛出类似“MySQL server has gone away”的错误。资源泄露风险： 如果不妥善管理连接的生命周期，可能导致连接句柄泄露，最终耗尽数据库服务器的连接资源。多进程并发问题： 在Workerman的多进程架构中，如果多个进程共享同一个数据库连接，可能会引发意想不到的并发问题和数据混乱。每个进程都应该拥有自己的独立连接。因此，正确的数据库连接策略是：在每个Worker进程启动时（即
onWorkerStart登录后复制登录后复制登录后复制回调函数中）为该进程建立独立的数据库连接。 这样确保了每个进程都有一个健康的、独立的连接。对于高并发或需要更高效率的场景，使用数据库连接池则是更优的选择，它能有效复用连接，减少连接建立和关闭的开销。在Workerman中，为什么不能直接使用全局数据库连接？
这个问题，我个人觉得是很多从传统PHP-FPM背景转到Workerman的开发者最容易踩的坑。我们习惯了PHP脚本执行完就“万事大吉”，所有状态都清空。但在Workerman这种长驻内存的服务里，事情就没那么简单了。
原因其实很简单，核心在于生命周期管理。PHP-FPM模式下，一个请求进来，PHP脚本执行，连接数据库，处理完业务逻辑，脚本结束，数据库连接也随之关闭。整个过程是短暂而独立的。然而，Workerman进程一旦启动，就会持续运行，监听端口，处理无数个请求。如果你在脚本的顶层或者某个静态变量里初始化了一个数据库连接，这个连接就会伴随进程的整个生命周期。
这就导致了几个关键问题：
连接“腐烂”： 数据库服务器为了节省资源，会对长时间不活动的连接进行清理。比如MySQL的wait_timeout登录后复制登录后复制参数，默认可能只有8小时。Workerman进程如果在这段时间内没有与数据库交互，其持有的连接就会被数据库服务器单方面关闭。当Workerman进程再次尝试使用这个连接时，就会收到
MySQL server has gone away登录后复制这样的错误。这就像你和朋友通电话，你以为对方还在听，但其实他已经挂断了。资源浪费与冲突： 即使没有超时，一个全局连接也可能被多个请求或任务在不恰当的时机并发访问，导致数据不一致或锁等待。更糟糕的是，如果连接在某个地方意外断开，整个进程都会受到影响。扩展性差： 全局连接难以适应动态的数据库集群变化，比如主从切换、读写分离等。
所以，我的建议是，永远不要在Workerman中直接依赖一个全局的、静态的数据库连接。这几乎是所有长驻内存应用都会面临的问题，不光是Workerman。理解这一点，能帮你少走很多弯路。
Copymatic Cowriter是一款AI写作工具，可以通过为你生成内容来帮助你加快写作速度和激发写作灵感。
63 查看详情 
Workerman推荐的数据库连接池方案有哪些？在Workerman这样的长驻内存应用中，数据库连接池几乎是一个标准配置，它能极大地提升数据库操作的效率和稳定性。它主要解决了频繁建立/关闭连接的开销，并能更好地管理连接的生命周期。
我通常会推荐以下几种方案：
基于
onWorkerStart登录后复制登录后复制登录后复制的单连接模式（简易版连接池）：这其实是最基础、最直接的实现方式，对于并发量不是特别高，或者每个Worker进程独立处理请求的场景非常适用。每个Worker进程在启动时，都会建立一个独立的数据库连接，并将其存储在进程的全局变量中。
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登录后复制（注意，它是一个异步MySQL客户端，不是简单的PHP MySQL扩展封装），它提供了一个非阻塞的MySQL客户端，可以更好地配合Workerman的异步特性，并且通常会自带连接池的管理能力。这种方案对于需要高性能、高并发的异步应用来说是理想选择。
// 假设使用 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登录后复制登录后复制登录后复制的单连接模式已经足够稳定和高效。如何处理Workerman数据库连接断开与重连问题？
数据库连接断开，这是在任何长驻内存应用中都无法避免的问题，它可能由多种原因引起：数据库服务器重启、网络波动、数据库服务器主动关闭空闲连接（
wait_timeout登录后复制登录后复制）、甚至是Workerman进程本身长时间不活跃。处理这个问题，需要一套健壮的机制。
我通常会从以下几个层面来考虑和实现：
心跳检测（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登录后复制或特定的SQLSTATE错误码），那么就尝试重新建立连接。
// ... (接上面的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数据库连接方式？的详细内容，更多请关注乐哥常识网其它相关文章！
相关标签： mysql php thinkphp word laravel redis js json go nginx php laravel mysql nginx 架构 thinkphp 封装 select try catch 全局变量 回调函数 并发 事件 异步 redis mongodb postgresql 数据库 YII Workerman