Go原生HTTP服务器支持SSE，需设置Content-Type、Cache-Control、Connection响应头，事件格式为data: xxx\n\n，每次发送后必须调用http.Flusher.Flush()，并监听客户端断连及时退出goroutine。
Go 原生 HTTP 服务器完全支持 SSE（Server-Sent Events），不需要额外框架，关键在于正确设置响应头、保持连接不关闭、按规范输出事件流数据——否则浏览器会直接关闭连接或解析失败。
必须设置的三个响应头
SSE 要求服务端明确声明内容类型和缓存策略，否则 Chrome/Firefox 会拒绝解析为事件流：
—— 缺少这个，
实例状态永远卡在
—— 浏览器可能缓存初始响应，导致后续事件不触发
事件
—— 显式声明长连接，避免代理（如 Nginx）或负载均衡器中途断连
示例写法：
每次事件必须以 data: 开头并以双换行结尾
SSE 协议对格式极其敏感：每条消息必须以
开头，末尾必须是两个连续的
（即
），中间不能有空格或多余字符。漏掉一个换行，整个事件就会被丢弃。
立即学习
“
go语言免费学习笔记（深入）
”；
✅ 正确：
❌ 错误：
（少一个
）
❌ 错误：
（
后缺空格，部分浏览器不认）
❌ 错误：
（Windows 换行符，应统一用
）
推荐封装成辅助函数避免手误：
必须调用 Flush()，否则事件永远发不出去
Go 的
默认带缓冲，不主动
，数据会一直卡在内存里。SSE 是流式响应，每条事件都得立刻送达客户端。
必须把
断言为
并调用
不能只依赖
或
—— 它们不触发刷新
如果用了
包裹，要确保它也 flush，但更推荐直接用原生
典型错误写法：
客户端断连后，服务端 goroutine 必须能及时退出
每个 SSE 连接对应一个长生命周期的 goroutine。如果客户端关掉页面或网络中断，而服务端还在往已关闭的连接里写数据，会触发
错误，并且 goroutine 泄露。
务必检查
或
的返回值，遇到
或
就立即 return
不要用
无条件推送，应在每次写之前判断连接是否还活跃
可配合
监听请求取消（比如客户端关闭连接时 context 会被 cancel）
简单防护示例：
真正难的不是写出第一行
，而是让连接在各种网络抖动、代理转发、浏览器重连机制下稳定维持——header、换行、flush、错误回收，四者缺一不可。
Content-Type: text/event-streamEventSourceconnectingCache-Control: no-cachemessageConnection: keep-alivefunc 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")
// 后续写入事件...
}data:\n\n\ndata: hello\n\ndata: hello\n\ndata:hello\n\n:data: hello\r\n\r\n\nfunc sendEvent(w io.Writer, msg string) {
fmt.Fprintf(w, "data: %s\n\n", msg)
w.(http.Flusher).Flush() // 强制刷出缓冲
}http.ResponseWriterFlush()whttp.FlusherFlush()fmt.Printlnw.Writebufio.WriterFlusher// ❌ 不会实时推送
fmt.Fprint(w, "data: ping\n\n")
// ✅ 正确（需先断言）
if f, ok := w.(http.Flusher); ok {
fmt.Fprint(w, "data: ping\n\n")
f.Flush()
}
write: broken pipew.WriteFlush()io.ErrClosedPipenet.ErrClosedtime.Tickerr.Context().Done()for {
select {
case <-r.Context().Done():
return // 客户端断开
default:
sendEvent(w, "tick")
time.Sleep(5 * time.Second)
}
}data: