核心逻辑是建立持久双向WebSocket通道实现服务端主动推送。通过HTTP升级握手建立连接,绑定用户/任务ID实现精准推送,事件驱动触发状态变更通知,辅以心跳机制和前端重连保障连接稳定。

核心逻辑在于建立一条持久、双向的通信通道,让服务端能在状态变化发生时,主动、即时地把消息推送给已连接的客户端,而不是等客户端来问。
连接建立:靠 HTTP 升级握手
WebSocket 不是凭空出现的,它必须借道 HTTP 完成初始“认证”。客户端发一个带特殊头的 GET 请求(Upgrade: websocket),服务器确认支持后,返回 101 状态码完成协议切换。这条 TCP 连接就从 HTTP “转正” 成 WebSocket,后续所有通信都走这个通道,不再走请求-响应那一套。
状态绑定:让推送有明确目标
光连上还不够,得知道“给谁推”。常见做法是把用户身份、任务 ID 或会话标识嵌入连接路径或参数中(比如 /notify/task/123 或 ?userId=abc)。服务端在连接建立时解析这些信息,把 Session 或连接对象存进内存 Map、Redis 或其他存储里,形成“ID → 连接”的映射关系。这样任务状态一变,就能精准找到对应连接发消息。
WebSocket 8.18.2 是该协议规范的一个重要迭代版本,主要优化了连接稳定性与数据传输效率。它通过全双工通信机制,允许客户端与服务器在单一长连接上实时交换数据,大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力,适用于即时通讯、在线游戏及金融行情推送等低延迟场景,为开发者提供更可靠的实时网络交互基础。
事件驱动:状态变更触发推送
推送不是定时扫表,而是监听关键事件。例如 PowerJob 中,当任务从“运行中”变为“成功”,框架内部会触发一个状态变更事件。监听器捕获该事件后,查出关联的客户端连接(通过前面绑定的 ID),组装通知消息(如 JSON 格式:{“taskId”:123,“status”:“SUCCESS”,“time”:1719219600}),调用 session.getBasicRemote().sendText() 直接下发。
连接维稳:避免悄无声息断开
长连接容易被中间网络设备(代理、防火墙)因空闲超时断开。所以必须加心跳机制:服务端定期发 Ping 帧,客户端收到后立刻回 Pong;如果某次没收到 Pong,就主动关闭失效连接,并清理映射关系。前端也要做重连逻辑——连接断了自动尝试恢复,避免通知中断。

















