Go语言TCP流处理核心是分离读取与解析：用io.ReadFull和binary处理定长/TLV协议，bufio.Reader适用于换行分隔文本，需手动管理缓冲区解决粘包，并用goroutine+channel解耦读写逻辑。
Go语言处理TCP数据流的核心在于理解连接的生命周期、缓冲区管理以及粘包/拆包问题。直接用net.Conn.Read读取数据时，它不保证一次读完一个“逻辑消息”，而是按底层TCP窗口和系统调用返回实际到达的字节数——这是大多数初学者踩坑的起点。
使用bufio.Reader做带缓冲的流读取
标准库bufio.Reader能简化基础流读取，适合处理以换行符分隔的协议（如HTTP头部、简单文本命令）：
- 用
reader.ReadString('\n')或reader.ReadBytes('\n')可自动等待完整一行，内部会缓存多余字节 - 注意：返回的字节切片包含分隔符，需用
bytes.TrimSuffix清理 - 若遇到超长行或无换行符的数据，应设置
reader.Discard或改用reader.Peek+reader.Read组合控制
自定义定长/TLV协议解析器
对二进制协议（如游戏登录包、IoT设备指令），推荐手写解析器而非依赖bufio：
- 先读固定长度头（如4字节uint32表示body长度），再按该长度读取body
- 用
binary.Read(conn, binary.BigEndian, &length)避免字节序错误 - 始终检查
io.ReadFull返回值，它确保读满指定字节数，否则说明连接异常或数据不全
用goroutine+channel解耦读写与业务逻辑
TCP连接通常需并发处理读、写、超时、心跳等任务，建议分离职责：
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
立即学习“go语言免费学习笔记（深入）”；
- 启动独立goroutine持续
Read，将完整消息（解包后）发到chan Message - 主逻辑从channel收消息，做业务处理；另一goroutine监听
done信号控制退出 - 写操作走单独channel（如
writeCh chan []byte），由writer goroutine串行Write，避免并发写panic
处理粘包与半包的关键细节
所谓“粘包”不是TCP的问题，而是应用层未定义消息边界导致的误解。解决它不靠“修复TCP”，而靠协议设计：
- 永远假设
Read返回任意长度（0 - 维护一个临时缓冲区（如
bytes.Buffer或切片池），把每次读到的数据追加进去 - 循环检查缓冲区是否满足消息头长度→解析长度→检查是否凑够body长度→截出完整消息→剩余数据留在缓冲区
基本上就这些。Golang的TCP流处理不复杂但容易忽略边界情况，关键是把“读取”和“解析”分开，用好io.ReadFull、binary和缓冲区管理，再辅以合理的goroutine分工。
