Go语言实现SSE实时推送教程

本文深入解析了使用 Go 语言安全、稳定实现 Server-Sent Events（SSE）推送的核心要点：不仅强调如何正确设置响应头、严格遵循 SSE 协议格式（如 data: 字段换行规范、UTF-8 编码、JSON 安全序列化），更聚焦于开发者极易忽视的关键挑战——如何阻止 HTTP 连接被 Go 默认机制提前关闭、如何通过 http.Flusher 显式刷新缓冲区、如何监听上下文取消信号防范 goroutine 泄漏与 OOM，以及 Chrome、Firefox 和 Safari 在实际兼容性上的隐秘差异与避坑指南，是一份兼顾原理深度与生产落地的实战精华。

Go 的 http.ResponseWriter 怎么避免提前关闭连接

Server-Sent Events 依赖长连接不中断，而 Go 默认的 HTTP handler 在函数返回时会隐式关闭响应体。一旦你写完数据就 return，连接立刻断开，客户端收不到后续事件。

关键不是“怎么发”，而是“怎么不让连接关”：

• 必须在 handler 函数内持续持有 http.ResponseWriter，不能让它被 GC 或作用域释放
• 务必设置 Content-Type: text/event-stream 和 Cache-Control: no-cache，否则浏览器可能缓存或拒绝解析
• 每次写入后调用 flusher.Flush() —— 不是 w.Write() 就完事了；没 flush，数据卡在缓冲区，客户端永远等不到
• 别用 log.Fatal 或 panic 中断 handler，会导致连接异常终止；用 return 前先 close channel、清理 goroutine

func sseHandler(w http.ResponseWriter, r *http.Request) {
    w.Header().Set("Content-Type", "text/event-stream")
    w.Header().Set("Cache-Control", "no-cache")
    w.Header().Set("Connection", "keep-alive")

    flusher, ok := w.(http.Flusher)
    if !ok {
        http.Error(w, "streaming unsupported", http.StatusInternalServerError)
        return
    }

    // 后续写入 + flush...
}

用 net/http 实现 SSE 时如何安全推送消息

直接往 ResponseWriter 写字符串容易出错：漏换行、格式错位、编码不一致，导致浏览器解析失败，表现为静默无事件或反复重连。

SSE 协议对字段名和换行极其敏感，必须严格遵循 data: ...\n\n 或 event: xxx\ndata: ...\n\n 格式：

• data: 行必须以 \n 结尾，整个消息块以 \n\n 结束（两个换行）
• 如果 data 值含换行，需拆成多行 data:，每行一个；不能直接嵌 \n
• 中文或 emoji 要确保响应头声明 charset=utf-8，否则可能乱码
• 避免用 fmt.Fprintf 拼接，改用 io.WriteString + 显式 \n，减少格式失控风险

// 正确示例（发送 JSON 数据）
msg := map[string]interface{}{"id": 123, "msg": "hello"}
b, _ := json.Marshal(msg)
io.WriteString(w, "data: ")
w.Write(b)
io.WriteString(w, "\n\n")
flusher.Flush()

goroutine 泄漏：为什么你的 SSE 服务跑几天就 OOM

每个 SSE 连接对应一个长期运行的 goroutine，如果客户端断开但服务端没感知，goroutine 就卡在 write 或 time.Sleep 上，永不退出。

根本问题是 Go HTTP Server 不主动通知连接断开，得自己探测：

• 检查 r.Context().Done()，配合 select 监听取消信号（客户端关闭、超时、server shutdown）
• 写入前先判断 flusher.Flush() 是否返回 err != nil，常见如 broken pipe 或 connection reset，此时应 break 循环
• 不要用全局 channel 广播——所有连接 goroutine 都在读同一个 channel，一个慢就拖垮全部；改用每个连接独享的 chan string + select default 防阻塞
• 设连接空闲超时（如 5 分钟），用 time.Timer 定期检测，避免僵尸连接堆积

Chrome/Firefox 对 SSE 的兼容差异点

看起来都支持 SSE，但实际行为有坑：Firefox 会严格校验响应头中的 Content-Type，少一个分号或空格就拒绝解析；Chrome 则更宽容，但对重连间隔（retry:）处理更保守。

几个真实踩过的点：

• retry: 值单位是毫秒，但 Chrome 最小只认 1000ms，设 500 会被忽略，仍按默认 3s 重连
• Firefox 要求首行必须是 data: 或 event:，如果开头有空行或 BOM，直接静默失败
• 移动端 Safari 对单次 data: 长度有限制（约 64KB），超长会截断，建议分块推送
• 所有浏览器都不支持自定义请求头（如 Authorization）用于 SSE，只能走 cookie 或 URL 参数传 token

上线前务必用真实设备抓包看 response headers 和 event stream 原始内容，别只信 console.log

以上就是《Go语言实现SSE实时推送教程》的详细内容，更多关于的资料请关注golang学习网公众号！