本文介绍如何使用 json.decoder 完成一次 json 握手后，安全地将底层 net.conn 交由后续文本协议处理，关键在于将解码器缓冲区中残留的原始字节“回填”到连接读取流中，避免数据丢失或阻塞。
在构建 TCP 代理时，常见的协议协商模式是：先通过自描述、自界定的 JSON 完成初始握手（如 REQ/REPLY），再切换至更轻量的纯文本协议（如自定义命令行协议、Redis 协议片段、或基于行的协议）。Go 标准库的 json.Decoder 是处理 JSON 握手的理想选择——它自动处理分块读取、UTF-8 验证和嵌套结构解析。但其内部缓冲机制会带来一个隐蔽陷阱：为提升性能，Decoder 在解析完一个完整 JSON 值后，可能已从底层 io.Reader（即 net.Conn）中预读了后续字节（例如文本协议的首几个命令字符）。这些字节被暂存在 Decoder.Buffered() 返回的 io.Reader 中，若直接将原 net.Conn 传递给后续协议处理器，这部分数据将永远“消失”，导致协议层读取超时或解析错位。
理想解法不是绕过 json.Decoder，而是桥接其缓冲区与原始连接，构造一个逻辑上“可重入”的读取接口。核心思路是：实现一个包装类型，同时持有 net.Conn 和 json.Decoder，并在 Read() 方法中优先返回 Decoder.Buffered() 中的残留数据，再委托给原始连接读取。这正是 io.MultiReader 的典型应用场景：
type ConnWithBufferedJSON struct {
net.Conn
*json.Decoder
}
func (c ConnWithBufferedJSON) Read(p []byte) (n int, err error) {
// MultiReader 按顺序读取：先 Buffered() 中的残留字节，再 Conn 的原始数据
return io.MultiReader(c.Decoder.Buffered(), c.Conn).Read(p)
}使用时，在完成 JSON 握手后，只需将原始连接和已使用的 json.Decoder 封装为该类型，并将其作为 net.Conn 传入后续文本协议处理器：
// 示例：完成握手后移交连接
conn, err := net.Dial("tcp", "server:8080")
if err != nil {
log.Fatal(err)
}
defer conn.Close()
// 构造带缓冲的 JSON 解码器
decoder := json.NewDecoder(conn)
encoder := json.NewEncoder(conn)
// 发送握手请求
req := map[string]string{"cmd": "HELLO", "version": "1.0"}
if err := encoder.Encode(req); err != nil {
log.Fatal(err)
}
// 接收并解析握手响应
var resp map[string]interface{}
if err := decoder.Decode(&resp); err != nil {
log.Fatal("JSON handshake failed:", err)
}
// ✅ 关键步骤：封装连接，确保 Buffered() 数据不丢失
wrappedConn := ConnWithBufferedJSON{
Conn: conn,
Decoder: decoder,
}
// 此时 wrappedConn 可直接用于文本协议处理器（它满足 net.Conn 接口）
// 后续 Read() 调用将自动先吐出 decoder 已读但未消费的字节
startTextProtocol(wrappedConn)⚠️ 注意事项：
- json.Decoder.Buffered() 返回的 io.Reader 仅在首次调用 Decode() 后有效，且同一 Decoder 实例只能调用一次 Buffered()（多次调用行为未定义）；
- 包装类型必须显式实现 net.Conn 所有方法（如 Write, Close, LocalAddr 等），上例为简化仅展示 Read；生产环境应完整委托所有方法；
- 若握手后需写入文本协议数据，Write 方法应直接委托给 c.Conn.Write()，无需干预；
- 此方案完全零拷贝，无内存复制开销，符合高性能代理要求。
总结：json.Decoder 的缓冲设计并非缺陷，而是可被优雅利用的特性。通过 io.MultiReader 组合 Buffered() 与原始连接，我们既保留了 JSON 解析的健壮性，又实现了协议切换的无缝衔接——这是 Go 接口组合哲学的典型实践。
