go 的 http.responsewriter 自动处理 http/1.1 chunked 编码,无需手动拼接;需显式 flush、禁用 content-length、正确设置 header,并通过类型断言安全使用 flusher,同时监听 context.done 防 goroutine 泄漏。

HTTP/1.1 chunked 编码在 Go 中由 http.ResponseWriter 自动处理
Go 的 http.ResponseWriter 在未设置 Content-Length 且未关闭连接时,会自动启用 chunked 编码——你不需要手动拼接 "size\r\npayload\r\n"。只要不调用 WriteHeader 前写死长度,也不提前 Flush 失败,流式下发就已就绪。
常见错误现象:net/http: request method or response status code does not allow body(比如对 HEAD 请求调用了 Write),或写入后没 Flush 导致客户端卡住等半天才收到第一批数据。
- 必须在每次写入后显式调用
Flush(),否则底层 buffer 可能滞留(尤其小数据) - 不要设置
Content-Length,否则 chunked 被禁用,且写超长会 panic - 避免在 handler 中 defer
responseWriter.(http.Flusher).Flush()—— 它可能在写完前就被调用,导致空 chunk 或 error
如何安全地向客户端持续写入 JSON 流(如 SSE 或 NDJSON)
典型场景是推送日志、事件或模型推理 token 流。关键不是“怎么编码”,而是“怎么保持连接不被中间件或客户端断开”。Go 默认不设超时,但反向代理(如 Nginx)、浏览器、甚至某些移动网络栈会主动 kill 空闲连接。
- 写入前用
w.Header().Set("Content-Type", "text/event-stream")或"application/json",视格式而定 - 务必加
w.Header().Set("Cache-Control", "no-cache")和"Connection", "keep-alive" - 每条消息后调用
flusher.Flush();若需保活,可定期写入注释行(如fmt.Fprintf(w, ": keepalive\n\n"))并 flush - 注意:SSE 要求换行符为
\n,不能混用\r\n,否则部分客户端解析失败
http.Flusher 不可用时的降级判断和 fallback
不是所有 ResponseWriter 都实现了 http.Flusher。例如测试用的 httptest.ResponseRecorder 就没有,某些自定义中间件也可能包装掉它。直接断言 w.(http.Flusher) 会 panic。
狼群淘客系统基于canphp框架进行开发,MVC结构、数据库碎片式缓存机制,使网站支持更大的负载量,结合淘宝开放平台API实现的一个淘宝客购物导航系统采用php+mysql实现,任何人都可以免费下载使用 。狼群淘客的任何代码都是不加密的,你不用担心会有任何写死的PID,不用担心你的劳动成果被窃取。
立即学习“go语言免费学习笔记(深入)”;
- 用类型断言 + ok 模式判断:
if f, ok := w.(http.Flusher); ok { f.Flush() } - 如果不可 flush,说明当前环境不支持流式响应(如单元测试、某些 serverless 运行时),应退回到一次性返回完整 payload
- 别试图用
time.Sleep模拟流式——它既不解决根本问题,又拖慢测试和本地调试
并发写入与 context 取消的协同处理
流式响应常伴随长时间 goroutine(如监听 channel、轮询数据库)。用户关闭页面或网络中断时,request.Context() 会 Done,但你的 goroutine 若没监听,就会泄漏。
- 所有阻塞读操作(如
ch := )必须绑定到 <code>r.Context(),而不是包级或全局 context - 写入前检查
if ctx.Err() != nil { return },因为Write和Flush在连接断开后可能返回io.ErrClosedPipe或类似错误 - 不要忽略
Write和Flush的返回值——它们可能返回net/http: request canceled或write: broken pipe,此时应立即退出 goroutine
chunked 流真正的复杂点不在编码逻辑,而在连接生命周期管理:你得同时盯住客户端状态、中间件行为、context 取消信号和底层 write 错误。漏掉任意一环,都会表现为“有时能流,有时卡住,有时 502”。









