17370845950

Go中Socket心跳检测需客户端每30秒发ping、服务端及时回pong，并维护lastActive时间戳，超时45秒关闭连接；结合TCP Keepalive与退避重连策略实现可靠连接管理。

在 Go 中实现 Socket 心跳检测，核心是客户端与服务端定期互发轻量协议包（如 ping/pong），以判断连接是否存活、及时发现假死或异常断连。关键不在于“发什么”，而在于“怎么发、何时发、发了没回怎么办”。

使用 net.Conn 配合定时器主动探测

Go 的 net.Conn 本身不提供心跳机制，需手动实现。推荐在连接建立后，启动独立 goroutine 负责发送心跳包，并监听响应：

• 客户端每 30 秒向服务端写入一个固定字节（如 []byte{0x01} 表示 ping）
• 同时设置读超时（如 5 秒），若在超时内未收到服务端返回的 pong（如 []byte{0x02}），则判定连接异常
• 利用 time.AfterFunc 或 time.Ticker 控制发送节奏，避免阻塞主逻辑

服务端需同步响应 + 连接级超时管理

光客户端发不够，服务端必须及时回 pong，且要对每个连接维护“最后活跃时间”：

• 每次收到 ping 或业务数据，更新该连接的 lastActive 时间戳
• 另起 goroutine 定期（如每 10 秒）扫描所有连接，若 time.Now().Sub(lastActive) > 45s，主动关闭 Conn
• 写 pong 时用 SetWriteDeadline 防止因对方卡住导致 goroutine 泄漏

结合 TCP Keepalive 减少底层僵死连接

操作系统级的 keepalive 可作为补充，但不能替代应用层心跳（因默认周期长、不可控）：

• 创建 Conn 后，调用 conn.(*net.TCPConn).SetKeepAlive(true)
• 用 SetKeepAlivePeriod（Go 1.19+）设为 30 秒左右，比应用心跳略长即可
• Keepalive 仅探测链路可达性，不保证上层协议可用，仍需应用层 ping/pong 确认业务通道正常

错误处理与重连策略要闭环

心跳失败不是终点，而是触发恢复流程的信号：

• 客户端检测到心跳超时，先关闭旧 Conn，再尝试按退避策略重连（如 1s → 2s → 4s → 最大 30s）
• 重连成功后，清空本地缓存状态，重新同步必要上下文（如会话 ID、序列号）
• 服务端关闭连接时，应从管理 map 中安全删除，避免内存泄漏和误操作

不复杂但容易忽略：心跳包尽量用固定长度、无编解码开销的原始字节；避免在心跳 goroutine 中执行耗时操作；所有 SetDeadline 必须配对使用，防止后续读写意外阻塞。