如何在 Go 中实现 WebSocket 心跳检测和自动重连-Golang-PHP中文网

go标准库及主流websocket库无内置心跳，需业务层主动实现ping/pong；服务端默认自动回pong，客户端须设setpinghandler并定时发ping；读写应使用context.withtimeout防阻塞和泄漏。

如何在 go 中实现 websocket 心跳检测和自动重连

为什么 `net/http` 的 WebSocket 连接会悄无声息断开

Go 标准库没有内置 WebSocket 心跳机制，gorilla/websocket 和 gobwas/ws 等主流库也只提供底层读写能力。TCP 连接空闲时，中间 NAT、代理或防火墙可能在 30–300 秒内主动清理连接，而 Go 客户端/服务端完全感知不到——WriteMessage 不报错，ReadMessage 却突然返回 io.EOF 或 websocket.CloseAbnormalClosure。

必须由业务层主动发 ping/pong，并配合超时控制，否则连接会在无提示下失效。

用 `SetPingHandler` 和定时 `WriteMessage(websocket.PingMessage, nil)` 实现双向心跳

服务端和客户端都要同时处理 ping/pong：服务端收到 ping 自动回 pong（gorilla/websocket 默认已做），但客户端必须自己发 ping；反过来，客户端也要注册 SetPingHandler 处理服务端 ping，否则连接会被对方视为不活跃而关闭。

服务端启用自动 pong：conn.SetPingHandler(nil)（默认行为，可不设）
服务端主动发 ping（可选，用于探测客户端存活）：conn.WriteMessage(websocket.PingMessage, nil)，需在单独 goroutine 中定时调用，间隔建议 ≤ 25 秒
客户端必须设 conn.SetPingHandler(func(appData string) error { return nil })，否则服务端 ping 会导致连接被关
客户端也要定时发 ping：conn.WriteMessage(websocket.PingMessage, nil)，避免被中间设备断连

注意：WriteMessage 发送 ping 时，appData 必须为 nil 或空字节切片，否则某些服务端（如 Nginx）会拒绝。

WebSocket 8.18.2

WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。

下载

`context.WithTimeout` 控制读写超时，避免 goroutine 泄漏

单纯用 conn.SetReadDeadline 和 conn.SetWriteDeadline 容易出错：deadline 是绝对时间，每次读写前都得重设；一旦忘记，后续操作就永远阻塞。更可靠的方式是用 context.WithTimeout 包裹读写操作，并在超时后主动关闭连接。

读消息时：ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)，然后用 conn.ReadJSON(...) 前先检查 ctx.Err()
写消息前，同样用带 timeout 的 ctx 控制 conn.WriteMessage，失败则触发重连
所有心跳 goroutine 都要监听 conn.Close 或上下文取消，及时退出，否则连接关闭后 goroutine 仍运行，导致内存泄漏

示例片段：

go func() {
    ticker := time.NewTicker(25 * time.Second)
    defer ticker.Stop()
    for {
        select {
        case <h3>重连不能只靠 <code>for</code> 循环，要加退避 + 连接状态锁</h3><p>裸写 <code>for { conn, _ = dial(); if conn != nil { break } }</code> 会瞬间打爆服务端，且多个 goroutine 可能并发重连同一连接。必须引入指数退避和单次连接状态控制。</p>