workerman 4.0.41 通过 websocket 实现服务端主动推送：需锁定该版本避免协程兼容问题；启用 websocketworker 类建立浏览器直连；维护全局连接池并绑定 uid 实现按用户精准推送，同时务必在 onclose 中清理连接防内存泄漏。
要在 Web 应用中让服务器主动把新消息推送给在线用户，比如聊天消息、订单状态更新或通知提醒，Workerman 4.0.41 提供了稳定可靠的长连接支持，无需依赖第三方服务即可自建推送通道。
安装 Workerman 4.0.41 并初始化项目结构
执行 composer require workerman/workerman:4.0.41 安装指定版本，【必须锁定 4.0.41，高版本默认启用协程模式，与传统回调写法不兼容】。
新建 start.php 文件，写入基础服务启动代码：引入 Autoloader、实例化 Worker、设置监听地址和进程数、调用 Worker::runAll() 启动。
运行 php start.php start -d 后，终端应显示 “Workerman[xxx] start in daemon mode” 表示后台常驻成功。
启用 WebSocket 协议实现浏览器直连
方法一：直接使用 WebsocketWorker 类替代普通 Worker：
将 $worker = new Worker('text://0.0.0.0:2346'); 改为 $worker = new WebsocketWorker('websocket://0.0.0.0:2346');，其余逻辑保持不变；这一步改完后，前端可用 new WebSocket('ws://your-domain:2346') 建立连接。
方法二：在普通 Worker 中手动解析 WebSocket 握手（不推荐）——需自行处理 Sec-WebSocket-Key、生成 Accept 值并发送响应头，极易因 base64 或换行符格式错误导致握手失败。
维护在线客户端连接池
第一步：定义全局连接容器，在 start.php 顶部添加 $connections = [];。
第二步：在 $worker->onConnect 回调中，为每个新连接分配唯一 ID 并存入数组：$connections[$connection->id] = $connection;。
第三步：在 $worker->onClose 回调中，用 unset($connections[$connection->id]) 清理断开连接 —— 【漏掉这步会导致内存持续增长，最终 OOM】。
第四步：所有推送操作都基于该数组遍历发送，例如向全员广播：foreach ($connections as $conn) { $conn->send('hello'); }。
接收并路由客户端消息
在 $worker->onMessage 回调中，先用 json_decode($data, true) 解析客户端发来的 JSON 字符串；如果解析失败，直接 return 跳过处理，避免后续逻辑崩溃。
检查 data['type'] 字段判断消息类型：值为 'login' 时记录用户身份到连接对象的 $connection->uid 属性；值为 'chat' 时提取 data['to'] 目标 UID，从连接池中查找对应连接并调用 send() 推送。
这一步操作起来很简单，直接把解析后的数组字段当变量用就行，但注意不要在 onMessage 里做耗时操作（如查数据库），否则会阻塞整个事件循环。
实现按用户 ID 精准推送
方法一：连接建立时要求客户端发送登录凭证，服务端验证后将 $connection->uid = $uid 绑定到连接对象上；推送时遍历 $connections 查找匹配 $conn->uid === $target_uid 的连接。
方法二：用关联数组替代索引数组存储连接，键名为 UID：$connections[$uid] = $connection;，推送时直接 $connections[$target_uid]->send($msg)；但需确保 UID 全局唯一且无重复登录覆盖风险。
方法三：结合 Redis 存储 UID → connection_id 映射关系，适合多进程部署场景；每次推送先查 Redis 获取目标 connection_id，再从内存连接池中取出连接发送 —— 这种方式能跨进程定位用户，但增加了网络 IO 和序列化开销。
