必须通过主动心跳机制维持长连接活性并及时发现断连：服务端配置IdleTimeout小于中间设备超时值，客户端用Ticker或HTTP/2 PING发送心跳，服务端通过/health/ping响应并维护活跃连接映射，客户端校验PONG响应且双次失败才重连。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜
当Grok API客户端与服务端建立长连接后，若无持续数据交互，中间网络设备（如Nginx、云负载均衡器、运营商NAT网关）会在空闲超时后静默关闭TCP连接，导致后续请求失败且客户端无法感知——必须通过主动心跳机制维持链路活性并及时发现断连。
服务端配置心跳探测参数
在Grok服务启动时，需显式设置HTTP/1.1或HTTP/2连接的空闲超时与探测间隔。若使用标准Go http.Server，直接配置IdleTimeout与ReadTimeout：
srv := &http.Server{
Addr: ":8080",
IdleTimeout: 45 * time.Second,
ReadTimeout: 10 * time.Second,
WriteTimeout: 10 * time.Second,
}
【IdleTimeout必须严格小于所有中间设备的空闲超时值】。例如Nginx默认proxy_read_timeout为60秒，AWS ALB为 Idle timeout 60 秒，阿里云SLB常见为 60～300 秒；设为45秒可确保在设备切断前主动触发GOAWAY或关闭连接。
此配置不依赖应用层逻辑，由Go运行时自动管理连接生命周期，但仅解决“空闲断连”，不覆盖传输中突发断连场景。
客户端主动发送Ping消息
客户端需在每次成功建立连接后，立即启动独立goroutine执行周期性心跳发送：
方法一：基于time.Ticker的固定间隔Ping
go func() {
ticker := time.NewTicker(30 * time.Second)
defer ticker.Stop()
for {
select {
case <-ticker.C:
if err := sendPingRequest(conn); err != nil {
log.Printf("ping failed: %v", err)
return
}
case <-doneCh:
return
}
}
}()
方法二：使用HTTP/2 PING帧（仅限HTTP/2连接）
conn.(net.Conn).SetWriteDeadline(time.Now().Add(5 * time.Second))
err := http2.WritePing(conn, false, [8]byte{1,2,3,4,5,6,7,8})
注意：该操作需底层连接支持http2.Transport，且不能在HTTP/1.1连接上调用，否则panic。
服务端接收并响应Pong
第一步：注册自定义路由处理心跳路径
http.HandleFunc("/health/ping", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "text/plain")
w.WriteHeader(http.StatusOK)
w.Write([]byte("PONG"))
})
第二步：在主Handler中嵌入连接活跃度标记
connCtx := r.Context()
if _, ok := connCtx.Deadline(); !ok {
connCtx = context.WithTimeout(connCtx, 5*time.Second)
}
// 每次收到非心跳请求，刷新连接活跃时间戳
activeMap.Store(clientIP, time.Now())
第三步：启动后台goroutine定期清理过期连接
go func() {
ticker := time.NewTicker(20 * time.Second)
defer ticker.Stop()
for range ticker.C {
now := time.Now()
activeMap.Range(func(key, value interface{}) bool {
if now.Sub(value.(time.Time)) > 50*time.Second {
activeMap.Delete(key)
closeConnByKey(key)
}
return true
})
}
}()
这一步的关键是把心跳响应与连接状态绑定，避免仅靠TCP层状态判断是否存活——因为ESTABLISHED不代表可写。
客户端验证心跳响应有效性
① 发送GET /health/ping后，检查HTTP状态码是否为200且响应体等于"PONG"
② 设置单次请求总超时 ≤ 服务端IdleTimeout的1/2，例如服务端设45秒，则客户端timeout应≤20秒
③ 若连续2次心跳失败（含超时、连接重置、非200响应），立即关闭当前连接并触发重连流程
这一步必须做双次失败判定，防止因瞬时网络抖动误判断连；单次失败只记录日志，不中断连接。
