Go HTTP 请求转发时 POST 数据丢失的排查与解决方案

go 中转发 http 请求时，若目标服务不支持分块传输编码（chunked encoding），需手动设置 ContentLength，否则请求体数据无法被正确解析。

go 中转发 http 请求时，若目标服务不支持分块传输编码（chunked encoding），需手动设置 `contentlength`，否则请求体数据无法被正确解析。

在 Go Web 开发中，将上游请求（如 POST/PUT）透明转发至下游服务是常见需求。但许多开发者会遇到一个隐蔽问题：原始请求体看似正常读取并复制，下游服务却收不到表单字段或 json 数据（如 email: NULL）。你提供的代码片段正是典型场景：

func forwarderHandlerFunc(w http.ResponseWriter, r *http.Request) {     client := &http.Client{}     u, _ := url.Parse(r.RequestURI)     req, _ := http.NewRequest(r.Method, fmt.Sprintf("%s%s", apiUrl, u.Path), r.Body)     // ❌ 缺少关键配置：req.ContentLength 未设置     resp, _ := client.Do(req)     resp.Write(w) }

问题根源在于：Go 的 http.Request 在 Body 为非 nil 且未显式设置 ContentLength 时，默认启用 Transfer-Encoding: chunked（分块传输）。而许多后端框架（如 Python flask、某些 Java servlet 容器或老旧 API 网关）默认不处理或拒绝 chunked 编码的请求体，尤其当它们期望 Content-Length 头 + 非分块正文时——此时虽请求成功发出，但服务端解析失败，字段值为 null 或空。

你观察到的打印输出 email=meh%!g(MISSING)mail.com 实际是 fmt.Printf 对 %g 格式符误用导致的格式化错误（应使用 %s），但这恰好掩盖了更深层的问题：r.Body 被读取后不可重放，而 http.NewRequest 直接复用该 io.ReadCloser，导致下游服务因缺少明确长度声明而无法可靠消费流。

✅ 正确做法是：显式设置 ContentLength，并确保 Body 可被完整读取一次。推荐方案如下：

func forwarderHandlerFunc(w http.ResponseWriter, r *http.Request) {     // 1. 提前读取原始 Body（避免多次读取）     bodyBytes, err := io.ReadAll(r.Body)     if err != nil {         http.Error(w, "Failed to read request body", http.StatusBadRequest)         return     }     r.Body.Close() // 必须关闭原始 Body      // 2. 构造新请求     u, _ := url.Parse(r.RequestURI)     targetURL := fmt.Sprintf("%s%s", apiUrl, u.Path)     req, _ := http.NewRequest(r.Method, targetURL, bytes.NewReader(bodyBytes))      // 3. ✅ 关键：显式设置 ContentLength（否则默认 chunked）     req.ContentLength = int64(len(bodyBytes))      // 4. 复制关键 Header（如 Content-Type、Authorization 等）     for name, values := range r.Header {         for _, value := range values {             req.Header.Add(name, value)         }     }      // 5. 发起请求     client := &http.Client{}     resp, err := client.Do(req)     if err != nil {         http.Error(w, "Upstream request failed", http.StatusBadGateway)         return     }     defer resp.Body.Close()      // 6. 复制响应头和状态码     for name, values := range resp.Header {         for _, value := range values {             w.Header().Add(name, value)         }     }     w.WriteHeader(resp.StatusCode)     io.copy(w, resp.Body) }

⚠️ 重要注意事项：

• 永远不要忽略错误：示例中省略了部分 err 检查，生产环境必须校验 io.ReadAll、http.NewRequest、client.Do 等调用结果。
• Header 复制需谨慎：避免透传敏感头（如 cookie、Authorization），应按需过滤。
• 大文件场景优化：若需支持大上传，可改用 io.Copy 流式转发（配合 req.ContentLength 和禁用 Transfer-Encoding: chunked），但需确保下游服务支持 Content-Length。
• 调试技巧：用 curl -v 或 wireshark 抓包，确认发出的请求是否含 Content-Length 头且无 Transfer-Encoding: chunked。

总结：Go 的 HTTP 客户端行为严谨，但与某些服务端实现存在兼容性差异。当转发 POST/PUT 请求失败时，优先检查 ContentLength 是否设置、Transfer-Encoding 是否被意外引入，而非假设是 Go 代码逻辑错误。这一课提醒我们：分布式系统调试需全局视角，协议细节往往决定成败。