4. 建立首个行情流连接并观察原始消息

在完成环境准备之后，下一步不是急着写业务解析代码，而是先建立一条最“裸”的连接，把服务端发回来的原始消息看清楚。这一步的价值在于：行情推送系统的所有后续逻辑——快照合并、增量叠加、断线重连、序列号校验——都建立在对原始报文结构的准确理解之上。如果跳过观察直接套用示例代码，一旦遇到字段缺失、消息乱序或连接被拒，就很难判断问题出在协议层还是业务层。

本节以常见的加密货币行情 WebSocket 接口为示例对象（示例地址与参数均为教学假设，实际以所用交易所文档为准），完成三件事：用浏览器 DevTools 与 wscat 两种方式抓包、记录连接生命周期日志、识别首条快照与后续增量消息，并解读常见连接错误码。

一、两种抓包方式的选择

浏览器 DevTools 适合快速验证：打开目标页面后按 F12，切换到 Network 面板并筛选 WS，刷新页面即可看到 WebSocket 握手请求。点击该请求，Messages 标签页会按时间顺序列出收发的每一帧，绿色为上行、白色为下行，点击单帧可查看完整 JSON。它的优点是零配置、能直接看到浏览器实际收到的内容；缺点是无法脱离页面单独测试，也不方便保存长会话日志。

wscat 适合命令行验证与日志留存。安装后直接连接：

npm install -g wscat
wscat -c wss://stream.example-exchange.com/ws/btcusdt@depth

连接成功后终端提示 Connected (press CTRL+C to quit)，此时可手动输入订阅报文。若服务端要求先订阅再推送，典型上行消息如下（示例）：

{"method":"SUBSCRIBE","params":["btcusdt@depth@100ms"],"id":1}

建议同时开启日志留存，便于事后比对：wscat -c wss://... | tee depth-raw.log。这样每一帧原始报文都会落盘，后续排查“某条增量为什么对不上”时可以直接回放。

二、连接生命周期日志

一条 WebSocket 连接从建立到关闭会经历若干可观测节点，把它们按时间记录下来，是判断连接健康度的基础。下图展示了一次典型行情连接的生命周期与各阶段应记录的关键信息：

在代码中，这些节点应各自打一条结构化日志，例如记录 event=ws_open url=... ts=...、event=ws_message type=snapshot lastUpdateId=...、event=ws_close code=1006 reason=...。日志字段统一后，后续做连接质量统计和故障复盘会非常省力。

三、识别首条快照与增量消息

行情推送通常遵循“先快照、后增量”的模式。首条消息往往是全量快照，特征是数据量大、包含完整买卖盘数组、带有一个基准序列号（示例中记为 lastUpdateId）。随后的消息是增量，只包含发生变化的价位，并携带起始与结束序列号（示例中记为 U 与 u）。

判断依据不能只看“第一条”，而要看结构。示例快照帧：

{"type":"snapshot","lastUpdateId":102345678,
 "bids":[["65000.10","1.25"],["64999.80","0.80"]],
 "asks":[["65000.50","0.95"],["65001.20","2.10"]]}

示例增量帧：

{"type":"update","U":102345679,"u":102345682,
 "b":["65000.10","0.00"],"a":["65000.50","1.40"]}

关键衔接规则是：第一条增量的 U 应不大于快照的 lastUpdateId 加一，且 u 不小于 lastUpdateId，说明增量与快照有重叠、可以无缝拼接；若第一条增量的 U 已经大于 lastUpdateId + 1，说明中间丢了帧，必须丢弃本地盘口重新拉取快照。这条规则是后续实现正确盘口的前提，务必在观察阶段就用真实报文验证一遍。

四、常见连接错误码解读

连接失败时，先看 close code 再谈业务。下表列出常见情形与处理方向（示例值，具体以服务端文档为准）：

需要特别区分“握手阶段失败”和“连接建立后被关闭”：前者在 DevTools 中表现为请求状态码非 101，wscat 会直接报 Unexpected server response；后者能看到 101 成功，随后收到 close 帧。把这两类错误分开记录，能显著缩短排障时间。

完成本节后，你应当能够独立回答三个问题：这条连接是否成功握手并完成订阅？首条快照的基准序列号是多少？第一条增量能否与快照无缝衔接？如果三个答案都清晰，就可以进入下一阶段的解析与盘口维护实现。