本文介绍在 go 服务端中间件中动态修改 *http.request 请求体的标准实践，包括替换 r.body 为自定义 io.readcloser、同步更新 contentlength 等关键字段，并强调内存与编码一致性注意事项。
本文介绍在 go 服务端中间件中动态修改 *http.request 请求体的标准实践，包括替换 r.body 为自定义 io.readcloser、同步更新 contentlength 等关键字段，并强调内存与编码一致性注意事项。
在 Go 的 HTTP 服务开发中，若需在请求到达业务处理器前拦截并重写请求体（例如实现日志脱敏、A/B 测试路由、协议转换等），不能直接修改原始 r.Body 的底层数据——因为 r.Body 是只读的 io.ReadCloser 接口，且其内容可能已被流式读取或缓冲。正确做法是完全替换 r.Body 字段为一个新的、符合 io.ReadCloser 接口的实例，并确保相关元信息同步更新。
✅ 标准替换步骤
- 构造新请求体内容：使用 strings.NewReader()（推荐，轻量只读）或 bytes.NewBufferString()（支持后续写入）生成 io.Reader；
- 包装为 io.ReadCloser：调用 io.NopCloser()（Go 1.16+ 已移至 io 包；旧版本用 ioutil.NopCloser）将其转为 ReadCloser；
- 更新 ContentLength：显式设置 r.ContentLength = int64(len(newBodyString))，否则下游可能因长度不匹配导致解析失败或截断；
- （可选）处理 TransferEncoding：若原始请求使用分块传输（Transfer-Encoding: chunked）而新内容为固定长度，应清空该字段（r.TransferEncoding = nil），避免协议冲突。
func requestModifier(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
// 示例：将所有 POST 请求体统一替换为 JSON
if r.Method == "POST" {
newBody := `{"modified": true, "timestamp": 1717023456}`
// ✅ 安全替换 Body
r.Body = io.NopCloser(strings.NewReader(newBody))
r.ContentLength = int64(len(newBody))
r.Header.Set("Content-Type", "application/json")
// ⚠️ 若原请求含 TransferEncoding，需手动清理
if len(r.TransferEncoding) > 0 {
r.TransferEncoding = nil
}
}
next.ServeHTTP(w, r) // 传递给下一中间件或 handler
})
}
⚠️ 关键注意事项
- 不可复用原 r.Body：r.Body 通常为单次读取流（如 http.bodyEOFSignal），多次 Read() 将返回 io.EOF，直接修改其内部 buffer 极易引发 panic 或数据错乱；
- 避免内存泄漏：若新 Body 来自大字符串或文件，建议使用 bytes.NewReader() + io.NopCloser() 组合，而非 bytes.Buffer（后者会额外分配可写内存）；
- 编码一致性：确保新内容字符编码（如 UTF-8）与 Content-Type 头声明一致，否则接收方可能解析异常；
- 中间件顺序敏感：若上游中间件已读取过 r.Body（如 r.ParseForm()），此时 r.Body 可能已关闭，需在链路最前端执行重写。
通过以上方式，你可在保持 HTTP 协议语义完整性的前提下，安全、可控地实现请求体重写，适用于网关、审计、Mock 服务等多种服务端场景。
