系统连接消息
系统消息用来告诉程序:连接、认证、订阅或后端服务发生了什么。不要只解析行情消息,也要处理系统消息。
常见消息类型
Section titled “常见消息类型”| 类型 | 说明 |
|---|---|
| 连接确认 | 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)建议记录的内容
Section titled “建议记录的内容”| 内容 | 用途 |
|---|---|
| 原始消息 | 排查解析错误。 |
| 收到时间 | 判断延迟和断流。 |
| 订阅列表 | 判断哪个 topic 导致错误。 |
| 认证状态 | 判断是否需要用户重新登录。 |
系统消息不一定稳定适合长期写死。解析时要容错,遇到未知字段时保留原文。