本文介绍如何使用 `io.copy` 将上游 http 响应直接流式写入 `http.responsewriter`，避免内存积压，实现零拷贝式代理转发。
在构建反向代理、文件网关或 API 聚合服务时，常需将外部 HTTP 接口返回的响应（如图片、PDF、视频流）不经过完整加载就透传给客户端。关键诉求是：低内存占用、高吞吐、无缓冲阻塞。此时，io.Pipe() 并非首选——它适用于需要手动协调生产者/消费者 goroutine 的场景（例如异步生成数据），而 http.Response.Body 和 http.ResponseWriter 本身已是就绪的 io.Reader 和 io.Writer，直接使用 io.Copy 即可完成高效、阻塞安全的流式复制。
以下是推荐实现：
func pipeReq(w http.ResponseWriter, r *http.Request) {
// 发起上游请求（建议使用带超时的 client）
client := &http.Client{
Timeout: 30 * time.Second,
}
resp, err := client.Get("https://example.com/large-file.pdf")
if err != nil {
http.Error(w, "Upstream request failed", http.StatusBadGateway)
return
}
defer resp.Body.Close() // 确保资源释放
// 复制响应头（谨慎选择需透传的 header）
for name, values := range resp.Header {
for _, value := range values {
w.Header().Add(name, value)
}
}
// 设置状态码（默认 200，若需保留上游状态码则显式设置）
w.WriteHeader(resp.StatusCode)
// 核心：流式复制，底层使用 buffer（默认 32KB）分块读写，内存恒定
_, err = io.Copy(w, resp.Body)
if err != nil && err != io.ErrUnexpectedEOF {
// 客户端提前断开连接时 io.Copy 返回 err != nil，通常可忽略
log.Printf("Copy to client failed: %v", err)
}
}⚠️ 重要注意事项：
- ✅ 不要手动设置 Content-Length：io.Copy 无法预知总长度，且现代 HTTP 服务（尤其含 gzip、chunked transfer）依赖动态编码；强行设置可能引发协议错误或截断。应让 http.ResponseWriter 自动处理编码与长度。
- ✅ 务必 defer resp.Body.Close()：防止连接泄漏，即使 io.Copy 出错也需关闭。
- ✅ 使用带超时的 http.Client：避免上游挂起导致服务线程耗尽。
- ⚠️ 避免并发写入 ResponseWriter：io.Copy 是同步操作，无需额外 goroutine；若自行启协程写入，会破坏 HTTP 协议状态机，导致 panic 或乱序响应。
- ? 如需修改响应体（如注入水印、重编码），则应使用 io.TeeReader 或中间 bytes.Buffer（仅限小文件），但会牺牲流式优势。
总结：io.Copy(dst, src) 是 Go 标准库为流式 I/O 设计的黄金方案，它自动选择最优缓冲策略，在内存可控前提下实现最高吞吐。对于“接收即转发”的典型代理场景，它是简洁、健壮、高性能的不二之选。
