如何在Golang中实现WebSocket心跳检测_Golang WebSocket心跳检测实现方法汇总-Golang-PHP中文网

如何在Golang中实现WebSocket心跳检测_Golang WebSocket心跳检测实现方法汇总

P粉602998670

发布： 2025-11-01 18:15:18

原创

210人浏览过

使用定时器发送Ping消息并监听Pong响应，结合读取超时与上下文控制，可实现可靠的WebSocket心跳检测机制。

如何在golang中实现websocket心跳检测_golang websocket心跳检测实现方法汇总

WebSocket连接在长时间运行中可能因网络异常、客户端离线等原因中断，而连接双方无法立即感知。为确保连接的可靠性，心跳检测机制必不可少。Golang中实现WebSocket心跳检测有多种方式，以下汇总几种常见且实用的方法。

使用定时器发送Ping消息

WebSocket协议支持Ping/Pong帧用于心跳检测。服务端可以定期向客户端发送Ping消息，客户端收到后自动回复Pong。若在指定时间内未收到Pong响应，则判定连接失效。

关键点：

利用time.Ticker定时触发Ping操作
设置读写超时，防止阻塞
通过SetWriteDeadline控制发送时限

示例代码片段：

立即学习“go语言免费学习笔记（深入）”；

func (c *Client) sendPing() {
    ticker := time.NewTicker(30 * time.Second)
    defer ticker.Stop()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">for {
    select {
    case <-ticker.C:
        c.conn.SetWriteDeadline(time.Now().Add(10 * time.Second))
        if err := c.conn.WriteMessage(websocket.PingMessage, nil); err != nil {
            return
        }
    case <-c.done:
        return
    }
}

登录后复制

}

监听Pong消息并重置读取超时

客户端或服务端应处理对方发来的Pong帧，以确认连接存活。Gorilla WebSocket库允许注册Pong处理函数，在收到Pong时更新状态。

说明：

调用SetPongHandler设置回调函数
在回调中刷新读取截止时间，避免因等待数据导致超时断开

典型实现：

百度文心百中

百度大模型语义搜索体验中心

查看详情

conn.SetPongHandler(func(string) error {
    conn.SetReadDeadline(time.Now().Add(60 * time.Second))
    return nil
})

登录后复制

这样每次收到Pong时都会延长下一次读取操作的等待时间，实现动态保活。

结合读取循环检测连接状态

在读取消息的主循环中集成心跳逻辑，可统一管理连接生命周期。

建议做法：

在ReadMessage前设置SetReadDeadline
超时后检查是否收到预期的Pong
未收到则关闭连接

例如：

conn.SetReadDeadline(time.Now().Add(60 * time.Second))
_, data, err := conn.ReadMessage()
if err != nil {
    // 连接可能已断开
    closeConnection()
    return
}

登录后复制