要深入理解workerman 4.0.41需直接阅读源码：src/为核心目录，worker.php为启动入口，connection/、events/、protocols/各司其职；其生命周期始于runall()，经init()、reloadworkers()至事件循环；自定义钩子可通过继承worker重写回调或onworkerstart注入拦截器；插件应实现plugininterface并挂载到$connection->plugin，支持热加载。
要深入理解 Workerman 4.0.41 的运行机制并为其添加自定义功能，必须直接阅读其源码结构、掌握核心类职责划分，并在不破坏事件循环的前提下注入扩展逻辑。
定位源码入口与目录结构
克隆或下载 Gitee 上的 walkor/workerman 仓库，检出 tag v4.0.41。主目录下 src/ 是全部核心代码所在：Worker.php 是唯一对外暴露的启动类；Connection/ 下封装各类连接对象（TcpConnection、WebSocketConnection 等）；Events/ 中是不同事件驱动实现（Libevent、Event、Select、Stream）；Protocols/ 包含文本、HTTP、WebSocket 等协议解析器。
注意：Workerman 没有 config/ 或 resources/ 目录，所有行为由 PHP 代码动态控制，【修改 src/ 下任何文件都等同于修改框架本身，极易导致升级失败】。
读懂 Worker 类的生命周期流程
打开 src/Worker.php，从 runAll() 方法开始追踪：
① 调用 init() 初始化进程模型、信号处理、PID 文件路径；
② 执行 reload() → reloadWorkers() 加载所有 Worker 实例；
③ 进入主循环：startWorker() 启动每个 Worker 子进程 → listen() 绑定 socket → setProcessTitle() 设置进程名 → 最终调用 loop() 进入事件循环。
关键点在于：所有 Worker 实例共享同一个全局事件循环（通过 Events\Select::getInstance() 或其它驱动实例），【onMessage/onConnect 等回调不是同步执行，而是被投递到事件循环中异步触发】。
为 Worker 添加自定义事件钩子
Workerman 原生不提供“onBeforeMessage”或“onAfterClose”等中间钩子，但可通过继承 + 方法包装实现：
方法一：重写 Worker 构造函数，在内部保存原始回调并替换为包装函数
在你的项目中新建 MyWorker.php：
class MyWorker extends \Workerman\Worker { public function __construct($socket_name = '', $context_option = []) { parent::__construct($socket_name, $context_option); $this->onMessageWrapper = $this->onMessage; $this->onMessage = [$this, 'wrapOnMessage']; } public function wrapOnMessage($connection, $data) { // 在此处插入预处理逻辑，如日志、鉴权、数据脱敏 if ($this->onMessageWrapper) { call_user_func($this->onMessageWrapper, $connection, $data); } } }
方法二：利用 onWorkerStart 注入全局拦截器（仅适用于单进程调试）
在 start.php 中添加：
$worker->onWorkerStart = function($worker) { $original_onMessage = $worker->onMessage; $worker->onMessage = function($conn, $data) use ($original_onMessage) { if (is_callable($original_onMessage)) { // 阻塞式校验，仅限低并发场景 if (!validateToken($conn)) { $conn->close(); return; } } call_user_func($original_onMessage, $conn, $data); }; };
编写可热加载的插件模块
插件不应修改 src/，而应通过 Composer 自动加载机制注入：
第一步：创建插件类，实现 Workerman\Protocols\PluginInterface 接口
第二步：在 onConnect 中注册连接级状态管理器，例如记录客户端 IP 地址和首次连接时间
第三步：在 onMessage 中调用插件的 handle() 方法，传入 $connection 和 $data，返回是否继续向下传递
第四步：将插件实例挂载到 $connection->plugin 属性上，供后续回调复用
这一步操作起来很简单，直接把插件类 require_once 进启动脚本即可生效，无需重启服务。
