Golang实现HTTP长轮询教程详解

本文深入解析了在Golang中正确实现HTTP长轮询的关键技术要点，指出使用http.TimeoutHandler会导致连接被强制关闭、退化为短轮询这一常见误区，并强调必须禁用HTTP服务器及反向代理（如Nginx）的读写超时，转而在Handler内部通过context、time.After与select机制协同实现客户端断开、服务端主动推送和超时自动退出三重精准控制，同时结合defer确保资源及时清理，避免goroutine泄漏，从而真正发挥长轮询“有数据即推、低延迟、高实时”的核心优势。

长轮询为什么不能用 http.TimeoutHandler

因为 http.TimeoutHandler 会在超时后强制关闭连接并返回 504，而长轮询要求连接保持打开直到有数据或客户端断开。一旦被中间代理（如 Nginx）或 Go 自身的超时机制提前终止，就退化成普通短轮询，失去“有数据立刻推送”的意义。

正确做法是：禁用所有中间层和 Go 的读写超时，并在 handler 内部用 context.WithTimeout 或 time.AfterFunc 控制单次等待上限。

• 设置 http.Server.ReadTimeout 和 WriteTimeout 为 0（禁用）
• Nginx 需配 proxy_read_timeout 300（至少等于你的等待上限）
• Go handler 中用 select + time.After 实现可控等待，而非依赖 HTTP 层超时

如何安全地在 handler 中阻塞等待事件

直接用 time.Sleep 或无界 for 循环会阻塞 goroutine，浪费资源；用全局 channel 盲目 <-ch 又可能永久挂起——必须支持客户端主动断开、服务端主动通知、超时退出三者共存。

推荐模式是：为每个请求生成独立 context.Context，监听 req.Context().Done()（客户端断开）、自定义事件 channel（服务端推送）、time.After()（超时）三个信号源。

• 不要复用 channel，每次请求新建一个 chan interface{} 或用 sync.Map 管理 per-request channel
• 避免在 handler 中启动 goroutine 后丢弃引用，否则容易泄漏；用 defer close(ch) 清理
• 事件推送侧应使用 select { case ch <- data: default: } 非阻塞发送，防止因接收方未 ready 而卡住生产者

如何避免 goroutine 泄漏和内存堆积

长轮询本质是“一个连接一个 goroutine”，如果客户端网络异常断连但服务端没感知，goroutine 就永远卡在 select 里。Go 的 http.Request.Context() 是关键——它会在客户端断开、超时、取消时自动关闭。

务必在所有阻塞点检查 ctx.Done()，并在退出前清理关联资源（如从事件分发 map 中删除 channel）。

• 用 sync.Map 存储活跃连接对应的 channel，key 用 req.RemoteAddr + timestamp 避免冲突
• 每次写响应前先检查 if ctx.Err() != nil { return }，防止 write on closed connection panic
• 不要把 *http.ResponseWriter 保存到全局变量或结构体中——它不是线程安全的，且生命周期只在 handler 内有效

实际可运行的最小长轮询 handler 示例

以下代码实现了带超时、支持中断、无 goroutine 泄漏的长轮询核心逻辑，不依赖任何第三方库：

func longPollHandler(w http.ResponseWriter, r *http.Request) {
    w.Header().Set("Content-Type", "application/json")
    w.Header().Set("Cache-Control", "no-cache")
    w.Header().Set("Connection", "keep-alive")
ctx := r.Context()
eventCh := make(chan string, 1)

// 模拟注册到事件中心（真实场景可能是 pubsub 或广播 map）
registerCh(eventCh)
defer unregisterCh(eventCh)

select {
case data := <-eventCh:
    json.NewEncoder(w).Encode(map[string]string{"data": data})
case <-time.After(30 * time.Second):
    json.NewEncoder(w).Encode(map[string]string{"status": "timeout"})
case <-ctx.Done():
    // 客户端断开，不做响应（连接已关）
    return
}
}

注意：这里 registerCh 和 unregisterCh 需要你自己实现，核心是把 eventCh 加入某个可遍历的集合，在事件发生时遍历发送；而 unregisterCh 必须在 handler 返回前调用，否则下次事件会往已关闭的 channel 发送，触发 panic。

真正难的不是写这个 handler，而是设计好事件分发器的并发安全性和生命周期管理——channel 关了谁来关？map 里的 key 什么时候删？这些细节漏掉一个，跑一天就内存暴涨。

好了，本文到此结束，带大家了解了《Golang实现HTTP长轮询教程详解》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！