go 中使用标准 http 客户端消费 sse 时出现延迟，通常并非 go 自身缓冲所致，而是代理（如 nginx）启用了压缩或中间层缓存；禁用传输层压缩并配合流式读取可实现真正的低延迟事件接收。
go 中使用标准 http 客户端消费 sse 时出现延迟，通常并非 go 自身缓冲所致，而是代理（如 nginx）启用了压缩或中间层缓存；禁用传输层压缩并配合流式读取可实现真正的低延迟事件接收。
在构建实时通知、日志流或状态推送类应用时，Server-Sent Events（SSE）是一种轻量、基于 HTTP 的单向流协议，非常适合服务端向客户端持续推送文本事件。然而，许多 Go 开发者在实现 SSE 客户端时会遇到「事件明显延迟」的问题——明明服务端已即时发送 data: ... 行，客户端却要等待数秒甚至更久才收到，误以为是 bufio.Reader 或 http.Transport 的内部缓冲导致。
实际上，Go 标准库的 http.Transport 默认不会对响应体做应用层缓冲；ReadBytes('\n') 或 ReadSlice('\n') 本身是阻塞但即时的底层读取操作。真正常见的罪魁祸首是反向代理（尤其是 Nginx）默认开启的 gzip 压缩 和 响应缓冲（buffering）。Nginx 在启用 gzip on 且未显式配置 gzip_disable "msie6"; 或 proxy_buffering off 时，会对响应流进行累积压缩，直到缓冲区满或连接关闭，从而破坏 SSE 的实时性。
✅ 正确解法：在 Go 客户端显式禁用 HTTP 传输层压缩，并确保使用适合流式解析的读取方式：
client := &http.Client{
Transport: &http.Transport{
DisableCompression: true, // 关键：禁用 gzip 压缩，避免代理/服务端延迟 flush
},
}
req, err := http.NewRequest("GET", sseURL, nil)
if err != nil {
log.Fatal("failed to create request:", err)
}
// 推荐添加 SSE 必需的请求头
req.Header.Set("Accept", "text/event-stream")
req.Header.Set("Cache-Control", "no-cache")
req.Header.Set("Connection", "keep-alive")
resp, err := client.Do(req)
if err != nil {
log.Fatal("HTTP request failed:", err)
}
if resp.StatusCode != 200 {
log.Fatal("SSE server returned non-200 status:", resp.Status)
}
defer resp.Body.Close()
reader := bufio.NewReader(resp.Body)
// 按行流式解析（SSE 协议以 \n 分隔事件字段）
for {
line, err := reader.ReadSlice('\n')
if err != nil {
if errors.Is(err, io.EOF) || errors.Is(err, io.ErrUnexpectedEOF) {
log.Println("SSE stream ended gracefully")
break
}
log.Printf("read error: %v", err)
break
}
// 去除行尾换行符，跳过空行和注释行（以 : 开头）
trimmed := bytes.TrimSpace(line)
if len(trimmed) == 0 || bytes.HasPrefix(trimmed, []byte{':'}) {
continue
}
log.Printf("Raw event line: %s", string(trimmed))
// 此处可进一步按 SSE 规范解析 field:value（如 data:, event:, id:, retry:）
}
⚠️ 注意事项：
- DisableCompression = true 是关键：它不仅禁用 Go 客户端的解压逻辑，更重要的是向服务端（及中间代理）发出明确信号 —— 客户端不接受压缩响应，促使 Nginx 等代理直接透传原始字节流。
- 务必设置 Accept: text/event-stream：帮助服务端识别客户端意图，可能触发服务端的流式优化行为。
- 避免使用 ReadBytes + json.Unmarshal 直接解析整行：SSE 事件不是完整 JSON 对象，而是多行键值对（data: {...}\n, event: message\n），应按行解析后组装事件对象。
-
服务端与代理配置需同步调整：若你控制服务端或 Nginx，还需确认：
location /events { proxy_pass http://backend; proxy_buffering off; # 关键：禁用 Nginx 响应缓冲 proxy_cache off; proxy_http_version 1.1; proxy_set_header Connection ''; chunked_transfer_encoding off; # 防止分块编码干扰流式读取 }
总结：Go 本身对 SSE 支持良好，延迟问题绝大多数源于基础设施层（如 Nginx）的默认压缩与缓冲策略。通过客户端显式禁用压缩、服务端/代理关闭缓冲，并采用 ReadSlice('\n') 流式读取，即可获得毫秒级响应的真正实时 SSE 流。无需重写 Transport，也不必引入第三方库——标准库足矣。
