当 HTTP 流式响应（Transfer-Encoding: chunked）中途出错时，可通过 http.Hijacker 接管底层连接并主动关闭，避免 panic，同时让客户端（如 curl）感知到连接异常中断。
当 http 流式响应（transfer-encoding: chunked）中途出错时，可通过 http.hijacker 接管底层连接并主动关闭，避免 panic，同时让客户端（如 curl）感知到连接异常中断。
在 Go 的 net/http 中，标准 http.ResponseWriter 不提供直接中断已开始流式响应的机制。一旦调用 w.WriteHeader() 并开始写入响应体（尤其是启用 chunked 编码的流式场景），后续无法通过常规方式“取消”响应——return 或 http.Error() 均无效，数据仍可能被部分发送或缓冲，客户端无法可靠识别失败。
此时，唯一可控且符合 HTTP/1.1 协议语义的中断方式是主动关闭底层 TCP 连接。这会触发客户端收到类似 curl: (18) transfer closed with outstanding read data remaining 的提示，明确传达“服务端异常终止”，而无需依赖 panic。
实现的关键是使用 http.Hijacker 接口（仅对 HTTP/1.1 有效，不适用于 HTTP/2）：
func handler(w http.ResponseWriter, r *http.Request) {
// 设置流式响应头（显式禁用压缩，确保 chunked 生效）
w.Header().Set("Content-Type", "application/json")
w.Header().Set("X-Content-Type-Options", "nosniff")
// 注意：不要调用 w.WriteHeader() 之前设置 Transfer-Encoding —— net/http 会自动添加
// 模拟流式写入（例如从数据库逐行扫描）
encoder := json.NewEncoder(w)
for i := 0; i < 100; i++ {
if err := encoder.Encode(map[string]int{"id": i}); err != nil {
// 发生错误：记录日志，并主动断开连接
log.Printf("stream error at item %d: %v", i, err)
// 尝试接管连接并关闭
if hijacker, ok := w.(http.Hijacker); ok {
conn, _, err := hijacker.Hijack()
if err != nil {
log.Printf("failed to hijack connection: %v", err)
return
}
// 立即关闭底层连接 → 客户端将收到传输中断信号
conn.Close()
return
}
// 若非 HTTP/1.1（如 HTTP/2），Hijacker 不可用，降级处理（如写入错误帧后返回）
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
return
}
// 可选：强制刷新 chunk（尤其在小数据量时避免缓冲延迟）
if f, ok := w.(http.Flusher); ok {
f.Flush()
}
}
}✅ 关键注意事项：
-
Hijacker仅在 HTTP/1.1 连接中可用；HTTP/2 使用多路复用，不支持连接级中断，需改用http.Pusher或自定义错误帧协议； - 调用
Hijack()后，ResponseWriter不再可用，不得再调用Write,WriteHeader等方法； -
conn.Close()是立即、粗粒度的中断，适合严重错误场景；若需更优雅的终止（如发送最后错误 chunk），可考虑在关闭前写入一个带错误信息的 JSON 对象并 flush，但需确保客户端能解析该约定； - 生产环境建议配合超时控制（
context.WithTimeout）与数据库连接健康检查，尽量避免走到强制中断逻辑。
总结：主动关闭连接是 Go 中终止 chunked 响应最直接、客户端兼容性最好的方式。它绕过了 ResponseWriter 的抽象限制，回归网络层本质，在保障可观测性的同时，完全规避了 panic 的副作用。
