首页 > Golang > Go教程

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

时间：2026-04-21 09:41:35 423浏览收藏

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

Go语言如何做SSE推送_Go语言Server-Sent Events教程【技巧】

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 定期检测，避免僵尸连接堆积