Golang实现Socket长连接的核心是断连可发现、可重连、数据不丢:服务端用net.Listener监听并启goroutine处理每连接,设读写超时;客户端定时心跳+指数退避重连;协议需解决粘包,连接池用sync.Map管理并定期清理超时连接。

使用 Golang 实现 Socket 长连接,核心在于:服务端持续监听、客户端主动保活、双方正确处理连接异常与超时。关键不是“一直不关”,而是“断了能发现、能重连、数据不丢”。
服务端:用 net.Listener 持续接受连接,为每个 Conn 启协程处理
服务端不阻塞在单个连接上,而是通过 net.Listen 监听端口,每次 Accept() 到新连接后,立即启动一个 goroutine 专门处理该连接的读写和心跳逻辑。
- 设置
SetReadDeadline和SetWriteDeadline防止读写永久阻塞 - 用
bufio.Reader/Writer提升文本协议处理效率(如 JSON、自定义帧) - 收到心跳包(如
{"type":"ping"})立即回{"type":"pong"},不存状态 - 读取错误(如
io.EOF或超时)即关闭该 Conn,清理资源(如从 map 中删除 client ID)
客户端:主动发送心跳 + 自动重连机制
客户端不能只等服务端发消息,必须自己定时发心跳,并监听响应。一旦读失败或超时,立刻尝试重连。
- 用
time.Ticker每 15–30 秒发一次心跳(避开 NAT 超时,通常 60s) - 连接建立后,单独启一个 goroutine 读消息(
conn.Read()),出错就通知主流程重连 - 重连需加退避策略:首次 1s,失败后 2s、4s、8s… 最大不超过 30s,避免雪崩
- 重连前先关闭旧 Conn(防止文件描述符泄漏),重连成功后再恢复心跳和消息发送
通信协议:定义简单帧格式,避免粘包/半包
TCP 是字节流,不保证消息边界。直接 Read([]byte) 可能一次读到多个消息,或只读到半个消息。
立即学习“go语言免费学习笔记(深入)”;
- 推荐定长头 + 变长体:前 4 字节存 body 长度(
binary.BigEndian.PutUint32),再读对应字节数 - 或用分隔符(如
\n),配合bufio.Scanner的Split(bufio.ScanLines) - 所有读写操作都包装在
io.ReadFull/io.WriteFull中,确保整帧收发完成
连接管理:服务端需维护活跃连接池,支持按 ID 查找与广播
真实场景中常需向指定用户或某类用户推送消息,不能只靠裸 Conn。
- 用
sync.Map存map[string]*Client,key 是客户端唯一标识(如 token 或 UUID) -
Client结构体包含*net.Conn、登录时间、最后心跳时间、写锁等字段 - 定期(如每 30s)遍历 Map,踢掉超时未心跳的 Conn(配合
time.AfterFunc或后台 goroutine) - 广播时对每个 Conn 加写锁,写完立即释放,避免阻塞其他客户端消息
不复杂但容易忽略。重点不在代码多长,而在超时控制、错误归因、资源清理这三处是否闭环。










