跳转到内容

系统连接消息

系统消息用来告诉程序:连接、认证、订阅或后端服务发生了什么。不要只解析行情消息,也要处理系统消息。

类型说明
连接确认WebSocket 后端响应心跳或初始 topic。
认证异常Gateway 登录失效、权限不足或会话冲突。
订阅错误topic 格式错误、字段不合法、conid 不存在。
服务提示后端维护、连接状态变化或限速提示。
import json
def on_message(ws, raw_message):
try:
message = json.loads(raw_message)
except json.JSONDecodeError:
log_raw_message(raw_message)
return
if is_system_message(message):
handle_system_message(message)
else:
handle_data_message(message)
内容用途
原始消息排查解析错误。
收到时间判断延迟和断流。
订阅列表判断哪个 topic 导致错误。
认证状态判断是否需要用户重新登录。

系统消息不一定稳定适合长期写死。解析时要容错,遇到未知字段时保留原文。