如何使用Golang实现Socket长连接_保持客户端与服务端持续通信

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

使用 Golang 实现 Socket 长连接,核心在于:服务端持续监听、客户端主动保活、双方正确处理连接异常与超时。关键不是“一直不关”,而是“断了能发现、能重连、数据不丢”。

服务端:用 net.Listener 持续接受连接,为每个 Conn 启协程处理

服务端不阻塞在单个连接上,而是通过 net.Listen 监听端口,每次 Accept() 到新连接后,立即启动一个 goroutine 专门处理该连接的读写和心跳逻辑。

  • 设置 SetReadDeadlineSetWriteDeadline 防止读写永久阻塞
  • 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) 可能一次读到多个消息,或只读到半个消息。

  • 推荐定长头 + 变长体:前 4 字节存 body 长度(binary.BigEndian.PutUint32),再读对应字节数
  • 或用分隔符(如 \n),配合 bufio.ScannerSplit(bufio.ScanLines)
  • 所有读写操作都包装在 io.ReadFull / io.WriteFull 中,确保整帧收发完成

连接管理:服务端需维护活跃连接池,支持按 ID 查找与广播

真实场景中常需向指定用户或某类用户推送消息,不能只靠裸 Conn。

  • sync.Mapmap[string]*Client,key 是客户端唯一标识(如 token 或 UUID)
  • Client 结构体包含 *net.Conn、登录时间、最后心跳时间、写锁等字段
  • 定期(如每 30s)遍历 Map,踢掉超时未心跳的 Conn(配合 time.AfterFunc 或后台 goroutine)
  • 广播时对每个 Conn 加写锁,写完立即释放,避免阻塞其他客户端消息

不复杂但容易忽略。重点不在代码多长,而在超时控制、错误归因、资源清理这三处是否闭环。