Go/io 与 net/http 流式复制

用最小读写接口复用 HTTP 正文复制

Go 的 HTTP 正文传输复用 io.CopyBuffer；复制器以 Reader/Writer 为基础，并探测可选的专用传输能力。

go1.23.0通信与流量核验 2026-10-09

工程问题#

文件、连接、内存缓冲和限长包装器都可能作为传输端点；通用复制需要保持可组合，同时允许某些端点使用自己的高效路径。

实际实现#

net/http 的 doBodyCopy 提供缓冲并调用 io.CopyBuffer。内部 copyBuffer 先检查源是否实现 WriterTo，再检查目标是否实现 ReaderFrom；均不支持时才进入普通读写循环。调用者只需满足小接口，额外能力通过可选接口参与。

处理流程#

HTTP 传输层把正文源和目标作为 io.Reader / io.Writer 传入
若源实现 WriterTo，则将复制交给源
否则若目标实现 ReaderFrom，则将复制交给目标
两者都不支持时，使用缓冲区反复读取、写出并处理错误

源码片段#

固定版本 · 原文摘录

src/io/io.gogo1.23.0 · L405–L426

查看原文件

405// copyBuffer is the actual implementation of Copy and CopyBuffer.406// if buf is nil, one is allocated.407func copyBuffer(dst Writer, src Reader, buf []byte) (written int64, err error) {408	// If the reader has a WriteTo method, use it to do the copy.409	// Avoids an allocation and a copy.410	if wt, ok := src.(WriterTo); ok {411		return wt.WriteTo(dst)412	}413	// Similarly, if the writer has a ReadFrom method, use it to do the copy.414	if rf, ok := dst.(ReaderFrom); ok {415		return rf.ReadFrom(src)416	}417	if buf == nil {418		size := 32 * 1024419		if l, ok := src.(*LimitedReader); ok && int64(size) > l.N {420			if l.N < 1 {421				size = 1422			} else {423				size = int(l.N)424			}425		}426		buf = make([]byte, size)

copyBuffer

先以类型断言选择两个可选接口；只有二者都不匹配、且调用者未提供缓冲时，才分配通用缓冲。片段结束后继续进入读写循环。

GOBSD-3-Clause

src/net/http/transfer.gogo1.23.0 · L408–L421

查看原文件

408// doBodyCopy wraps a copy operation, with any resulting error also409// being saved in bodyReadError.410//411// This function is only intended for use in writeBody.412func (t *transferWriter) doBodyCopy(dst io.Writer, src io.Reader) (n int64, err error) {413	buf := getCopyBuf()414	defer putCopyBuf(buf)415416	n, err = io.CopyBuffer(dst, src, buf)417	if err != nil && err != io.EOF {418		t.bodyReadError = err419	}420	return421}

transferWriter.doBodyCopy

HTTP 正文传输的实际调用点取得并归还复制缓冲，再调用 io.CopyBuffer；这不是单独的教学示例。

GOBSD-3-Clause

第一段是 copyBuffer 的分派与缓冲分配部分，第二段展示真实 HTTP 调用。完整回退循环及错误检查可从源码链接继续阅读。

收益与取舍#

工程分析

带来的收益

端点可通过小接口自由组合，复制逻辑无需认识每个具体类型
保持通用回退路径，同时允许已有类型提供专用实现
HTTP 层能够复用缓冲，避免每次都在通用路径重新分配

付出的代价

包装器可能只暴露基础接口，从而隐藏底层可选能力
WriterTo 优先于 ReaderFrom；两端同时提供能力时并非自动挑选最快的一方
快路径是否减少拷贝或使用内核特性取决于具体类型与平台，接口探测本身不保证零拷贝

可比较的选择

始终手写 Read / Write 循环控制直接，但需要自行处理短写、错误、缓冲和可选优化，容易重复逻辑。

要求所有端点实现大接口调用端容易统一，却增加简单类型和包装器的实现负担。

版本与适用范围#

对应 Go go1.23.0 的 io 包与 net/http HTTP/1 传输代码。传入的缓冲在 WriterTo / ReaderFrom 路径上不参与复制；Reader、Writer 的错误与短读短写约定仍由各实现遵守。

参考来源#

源码、官方文档与原始论文

go · CopyBuffer / copyBuffer / Reader / Writer

src/io/io.go · CopyBuffer / copyBuffer / Reader / Writer

源码go1.23.0

go · transferWriter.doBodyCopy

src/net/http/transfer.go · transferWriter.doBodyCopy