pinia actions 是 websocket 消息管理核心,负责解耦网络层与业务层:统一接收、校验、路由消息;更新 state 并广播事件;协调重连与补位;推荐用 definestore options api 以提升可维护性与类型安全。

Pinia Actions 管理 WebSocket 消息的核心,是把“网络层接收”和“业务层响应”彻底解耦——Actions 不直接操作 socket 实例,而是作为消息的统一入口、校验器与分发中枢。
用 Actions 封装消息接收逻辑
在 store 中定义一个 action(比如 handleMessage),专门处理从 WebSocket 实例传来的原始 event.data。它不关心连接怎么建、心跳怎么发,只做三件事:解析 JSON、基础校验(如 type 字段是否存在)、按类型路由到对应子逻辑。
- 避免在 onmessage 回调里写业务代码,防止污染网络层
- 统一做错误捕获,比如 JSON.parse 失败时打日志但不中断后续消息
- 可加简单过滤,例如忽略 timestamp 过期 30 秒的消息
用 Actions 触发状态更新与事件广播
接收到合法消息后,Actions 负责两路分发:
- 一路更新 Pinia state,比如往 notifications 数组 push 新条目,或更新 unreadCount
- 另一路触发外部通信,比如调用 eventBus.emit('msg:notification', payload) 或 notifyApp(payload) 通知 UI 层
这样 UI 组件只需订阅 store 的响应式字段或事件总线,完全不感知 WebSocket 存在。
WebSocket 8.18.2 是该协议规范的一个重要迭代版本,主要优化了连接稳定性与数据传输效率。它通过全双工通信机制,允许客户端与服务器在单一长连接上实时交换数据,大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力,适用于即时通讯、在线游戏及金融行情推送等低延迟场景,为开发者提供更可靠的实时网络交互基础。
用 Actions 协调重连与消息补位
当连接断开又恢复,Actions 可封装 reconnectAndSync 逻辑:
- 先清空本地未确认队列(如有)
- 向服务端请求最近 N 条未读消息(通过 HTTP 接口兜底)
- 对每条补位消息调用 handleMessage,保持处理路径一致
不需要在组件里重复写“重连后拉历史”的代码,所有同步逻辑收束在 store 内部。
配合 defineStore 的 options API 更清晰
推荐用 defineStore({ actions: { ... } }) 形式,而非 setup 语法糖。因为:
- actions 可以直接访问 this(即 store 实例),方便读写 state 和调用其他 action
- TypeScript 类型推导更稳定,payload 结构变更时 IDE 能立刻提示
- 便于单元测试:mock 一个 store 实例,直接调用 handleMessage 测各种消息分支
不复杂但容易忽略。










