服务端 recv(4096) 一次读到 3 条完整报文加半条,json.loads 抛 JSONDecodeError: Extra data,整条链路的解析成功率只有 62%。日志里能对上时间点,这种反而好排。

TCP 是字节流,只保证顺序不保证边界,两次 send 可能被合并成一次 recv,一条消息也可能被拆成两段。按固定长度读或者假设一次读全都不对。这一点先确认清楚,后面就不用反复试。

buf += sock.recv(4096)
while len(buf) >= 4:
    n = struct.unpack('>I', buf[:4])[0]
    if len(buf) < 4 + n: break
    body, buf = buf[4:4+n], buf[4+n:]

「TCP 粘包」确认了原因之后,改动尽量只碰那一处,顺手改的东西后面最容易出问题。能分两步做的操作就别合成一步,中间看一眼返回值,出问题好判断。

报错里带路径的,先去看那个路径在不在、权限对不对。同一份配置存在多处的,先确认改的是被加载的那一份。

新版本先放一台机器上跑一天再全量,问题一般在这段时间暴露。

处理上按这个顺序:协议加 4 字节大端长度头;先读满长度头再按值读 body;缓冲区不足时留到下一次循环;长度超过上限直接断开连接。

结果对不对很好判断,加上长度头后连续收 10 万条消息解析失败 0 次,512KB 的大报文也能完整还原。

作者 9823189