在 Go Web 应用中，若需通过 http.ResponseWriter 持续输出实时数据（如日志流、监控指标），必须显式调用 http.Flusher.Flush() 手动刷新缓冲区，否则数据将滞留在内存中无法及时送达浏览器。
在 go web 应用中，若需通过 `http.responsewriter` 持续输出实时数据（如日志流、监控指标），必须显式调用 `http.flusher.flush()` 手动刷新缓冲区，否则数据将滞留在内存中无法及时送达浏览器。
实现真正的服务端实时流式响应（Server-Sent Events 风格或简单流式 HTML），关键在于打破默认的 HTTP 响应缓冲机制。Go 的 http.ResponseWriter 默认基于 bufio.Writer，所有 Write/Fprintln 调用均被缓存，直到响应结束或缓冲区满才发送——这对长连接、持续输出场景完全不适用。
正确做法是：类型断言 http.ResponseWriter 是否实现了 http.Flusher 接口，并在每次写入后立即调用 Flush()。该接口由标准库的 *http.response 类型实现，因此在绝大多数 HTTP 服务器（包括 net/http 默认服务器和 gin、echo 等主流框架）中均可安全使用。
以下是一个生产就绪的示例（含基础 HTTP 头设置与终止保护）：
func streamHandler(w http.ResponseWriter, r *http.Request) {
// 设置必要头信息：禁用缓存 + 声明内容类型（text/event-stream 或 text/plain）
w.Header().Set("Content-Type", "text/plain; charset=utf-8")
w.Header().Set("Cache-Control", "no-cache")
w.Header().Set("Connection", "keep-alive")
// 确保首块数据尽快发出（可选：写入初始提示）
fmt.Fprintln(w, "▶ Streaming started...")
if f, ok := w.(http.Flusher); ok {
f.Flush()
} else {
http.Error(w, "streaming not supported", http.StatusInternalServerError)
return
}
ticker := time.NewTicker(1 * time.Second)
defer ticker.Stop()
for {
select {
case <-r.Context().Done(): // 支持客户端断开或超时自动退出
fmt.Fprintln(w, "⏹ Stream closed by client.")
if f, ok := w.(http.Flusher); ok {
f.Flush()
}
return
case <-ticker.C:
msg := fmt.Sprintf("[%s] tick: %d", time.Now().Format("15:04:05"), time.Now().Unix())
fmt.Fprintln(w, msg)
if f, ok := w.(http.Flusher); ok {
f.Flush() // ✅ 关键：每次写入后强制刷新
}
// 注意：此处不 sleep —— ticker 已控制频率
}
}
}? 重要注意事项：
- 始终检查 http.Flusher 实现：虽然 net/http 默认支持，但在某些中间件、测试环境（如 httptest.ResponseRecorder）或自定义 ResponseWriter 中可能不满足 ok == true，务必做防御性判断；
- 配合 r.Context().Done() 监听客户端断连：避免 goroutine 泄漏，提升服务健壮性；
- 合理设置响应头：Cache-Control: no-cache 和 Connection: keep-alive 是流式传输的基础保障；
- 避免高频无节制 Flush：过度调用 Flush() 可能增加系统调用开销，应结合业务节奏（如每秒 1–10 次）平衡实时性与性能；
- 前端需适配流式读取：HTML 页面建议使用 EventSource（SSE）或 fetch().body.getReader() 流式解析，而非普通 innerHTML 追加（后者可能因未闭合标签导致渲染异常）。
综上，http.Flusher 是 Go 实现低延迟服务端推送的核心原语。掌握其用法，即可在不引入 WebSocket 或第三方消息队列的前提下，构建轻量、可控、高兼容性的实时数据通道。
