io.TeeReader用于在读取io.Reader时同步写入io.Writer,典型场景是HTTP请求体日志记录;需确保其为Body唯一上游,配合bytes.Buffer、io.Copy消费流、io.NopCloser重置Body,并注意内存与线程安全。

io.TeeReader 读取时写入日志的典型用法
io.TeeReader 的核心作用是:在读取一个 io.Reader 的同时,把读到的数据原样写入另一个 io.Writer(比如 bytes.Buffer 或文件)。它不缓冲、不修改数据流,只是“分发”一份副本。在 HTTP 请求体处理中,常用于记录原始请求体而不影响后续解析(如 json.Decode)。
关键点:必须确保 io.TeeReader 是请求体的**唯一上游 Reader**;若先调用 r.Body.Read 再套 TeeReader,数据已丢失,记录为空。
- 使用前需调用
r.Body.Close()后再重新赋值,否则会泄漏连接或触发 “body closed by handler” 错误 - 日志目标
io.Writer必须是线程安全的(如bytes.Buffer单次请求内安全,但全局log.Logger需加锁或用io.MultiWriter分离) -
io.TeeReader不实现io.Seeker,无法回退或重读 —— 记录后仍需完整读取一次才能让后续逻辑继续
HTTP handler 中安全替换 r.Body 的步骤
Go 的 http.Request.Body 是一次性读取的流,直接替换需谨慎。正确做法是:读完并记录后,用新 io.NopCloser 包装内存中的副本,再赋给 r.Body。
常见错误:r.Body = io.NopCloser(t) —— 这里 t 是 io.TeeReader,它本身没有 Close() 方法,会导致 panic 或连接未关闭。
- 先创建
bytes.Buffer作为日志写入目标 - 用
io.TeeReader(r.Body, buf)构造中间 reader - 调用
io.Copy(io.Discard, teeReader)完整消费流(触发写入buf),否则日志不全 - 用
io.NopCloser(bytes.NewReader(buf.Bytes()))构造可重复读的新 body - 务必在最后调用
r.Body.Close()(原 body)
buf := &bytes.Buffer{}
tee := io.TeeReader(r.Body, buf)
_, _ = io.Copy(io.Discard, tee) // 触发读取和记录
r.Body.Close() // 关闭原始 body
r.Body = io.NopCloser(bytes.NewReader(buf.Bytes()))
记录大请求体时的内存与性能风险
io.TeeReader 本身不分配额外缓冲,但日志目标(如 bytes.Buffer)会将整个请求体加载进内存。对上传文件或 MB 级 JSON,这极易引发 OOM。
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器,提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象,支持命名依赖等
替代方案不是不用 TeeReader,而是换写入目标:
- 写入临时文件:
os.CreateTemp("", "req-*.log"),避免内存堆积 - 限制大小:用
io.LimitReader(tee, maxLogSize)截断日志,剩余部分丢弃(需明确业务容忍度) - 跳过二进制内容:检查
r.Header.Get("Content-Type"),只对application/json或text/*类型启用记录 - 异步写入:用
chan []byte+ goroutine 转发,但需注意竞态和背压 —— 日志延迟可能掩盖真实问题
为什么不能直接用 http.Request.Body 拿到原始字节
因为 r.Body 是接口,底层可能是 http.body(带 gzip 解压、chunked 解码等透明封装),也可能是 bytes.Reader 或网络连接。直接类型断言 r.Body.(*bytes.Reader) 必然失败;而 ioutil.ReadAll(r.Body) 会消耗流,后续解析器读不到数据。
真正能拿到原始字节的唯一时机,就是流经 io.TeeReader 的那一瞬 —— 它在解码层之下工作,看到的是未经处理的原始字节流(包括可能的 gzip 压缩内容,取决于是否已由 http.Transport 自动解压)。
如果你需要解压后的明文日志,得在 TeeReader 之后再套一层解压缩逻辑,但此时已脱离标准 HTTP 处理链,容易出错。更稳妥的做法是:记录原始流,另起进程用 gzip.NewReader 解压分析。

















