WebSocket 服务端处理逻辑应统一封装连接管理、帧重组、类型路由、生命周期控制和发送接口,业务代码须解耦于语义回调(如OnText/OnBinary),禁止在OnNewFrame写业务;心跳由框架自动管理。

WebSocket 消息在服务器端的处理逻辑封装,核心是把连接管理、帧解析、业务解耦和生命周期控制统一收口,避免业务代码散落在回调里,提升可维护性和复用性。
按消息类型分发处理
一条 WebSocket 消息可能由多个帧(如 Text + Continuation)组成,服务端应先完成帧重组,再按语义类型路由到对应处理器。不要在 OnNewFrame 中写业务逻辑,它只适合调试;真正处理应放在 OnText、OnBinary 等语义明确的方法中。
- 文本消息(JSON)→ 解析后交由业务路由模块分发,例如根据
"type": "login"转给认证处理器 - 二进制消息 → 直接交给协议解析器(如 Protobuf/FlatBuffer),不作字符串转换
- Close/Ping 帧 → 由框架自动响应,无需业务介入;若需自定义关闭前清理,可重写 OnDisconnected
连接状态与生命周期统一托管
每个客户端连接应绑定一个独立的处理实例(如 Messager 子类),该实例负责自身连接的全周期管理。连接建立、断开、异常等事件触发时,框架调用对应钩子方法,业务只需关注“做什么”,不用操心“何时做”。
WebSocket 8.18.2 是该协议规范的一个重要迭代版本,主要优化了连接稳定性与数据传输效率。它通过全双工通信机制,允许客户端与服务器在单一长连接上实时交换数据,大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力,适用于即时通讯、在线游戏及金融行情推送等低延迟场景,为开发者提供更可靠的实时网络交互基础。
- Accept 方法启动接收循环,是业务逻辑入口点
- OnConnected 可用于初始化会话上下文、分配用户 ID、加载缓存数据
- OnDisconnected 应释放资源(如取消定时任务、退出群组、更新在线状态)
- 连接异常中断时,框架应保证 OnDisconnected 必然被调用,即使底层 socket 已失效
发送能力封装成简洁接口
对外暴露的发送操作应屏蔽帧构造细节,支持多种载荷格式,同时内置流量控制和错误反馈机制。
- Send(string) 自动 UTF-8 编码并打包为 Text 帧
- Send(byte[]) 直接封装为 Binary 帧,不经过编码转换
- Send(object) 内部序列化为 JSON 后发送,适合结构化数据
- 所有 Send 方法返回 bool 或 Task,便于判断是否成功入队;若连接已关闭,应立即返回 false 而非抛异常
心跳与连接保活由框架接管
心跳不应由业务层手动 Ping,而应作为连接级能力集成在基类中。框架在连接就绪后自动启动定时器,按策略发送 Ping 并监听 Pong 响应。
- Ping 帧由框架自动发送,收到 Pong 后刷新活跃标记
- 连续 N 次未收到 Pong → 触发超时,主动调用 Close 并执行 OnDisconnected
- 业务可通过配置项开关心跳,或调整间隔,但无需实现具体逻辑










