Go http.Request.GetBody 怎样让请求重试仍能读取原始内容

Go 的 http.Request.GetBody 不是当前请求体 Body 的别名，而是一个“重新生成一份请求体”的工厂。请求第一次发送后，Body 的读取位置已经向前移动；如果还要重定向或手动重试，就需要通过 GetBody 得到新的 io.ReadCloser。

最容易记住的判断是：使用 http.NewRequest 配合 *bytes.Buffer、*bytes.Reader 或 *strings.Reader 时，标准库会自动填充 GetBody；换成普通的一次性 io.Reader 后，就不要假设请求可以重放。

Body 和 GetBody 到底分别负责什么

Body 是这一份请求实例当前要交给 Transport 读取的对象，GetBody 则负责在需要第二份内容时重新返回一个副本。两者必须同时存在：只设置 GetBody 而让 Body 为空，并不能让第一次请求发送成功。

标准库把这项能力用于客户端重定向。对于 307 和 308，原方法和请求体需要被保留；如果请求没有可用的 GetBody，客户端就没有可靠的方式重新提供已经读过的内容。这个契约也正是手动重试时要复用的思路。

NewRequest 什么时候会自动填充 GetBody

下面的写法把原始字节放进可重新创建的读取器。NewRequest 会记录精确的 ContentLength，并为这些常见类型准备新的读取入口：

package main

import (
    "bytes"
    "fmt"
    "net/http"
)

func main() {
    payload := []byte(`{"name":"go"}`)

    // bytes.Reader 可从同一份不可变字节重新创建读取器。
    req, err := http.NewRequest(http.MethodPost, "https://api.example.com/items", bytes.NewReader(payload))
    if err != nil {
        panic(err)
    }

    // Body 供第一次发送使用，GetBody 供后续重放使用。
    fmt.Println(req.Body != nil, req.GetBody != nil, req.ContentLength)
}

这段代码只说明请求对象的静态契约，不代表已经访问了示例地址。若把同样的内容包成普通自定义 io.Reader，标准库无法猜出怎样从头构造第二份数据，GetBody 通常会是 nil。

自定义请求体怎样保留重试能力

自定义输入的关键不是把已经读完的 Body 倒带，而是提前保存“如何生成同样内容”的函数。下面用一个工厂为每次重试创建新的请求体；第一次请求仍然使用原来的 Body。

package retrybody

import (
    "bytes"
    "fmt"
    "io"
    "net/http"
)

func NewRequest(method, url string, data []byte) (*http.Request, error) {
    // 工厂捕获不可变数据；每次调用都会得到独立 Reader。
    makeBody := func() (io.ReadCloser, error) {
        return io.NopCloser(bytes.NewReader(data)), nil
    }

    // Body 负责第一次发送，GetBody 负责之后的重放。
    req, err := http.NewRequest(method, url, makeBodyReader(data))
    if err != nil {
        return nil, err
    }
    req.GetBody = makeBody
    return req, nil
}

func makeBodyReader(data []byte) io.Reader {
    // 这里返回新的 Reader，避免多个请求共享同一个读取游标。
    return bytes.NewReader(data)
}

func cloneForRetry(req *http.Request) (*http.Request, error) {
    if req.GetBody == nil {
        return nil, fmt.Errorf("request body is not replayable")
    }
    body, err := req.GetBody()
    if err != nil {
        return nil, err
    }
    retry := req.Clone(req.Context())
    retry.Body = body
    // 手动持有副本时，由调用方负责在发送失败或结束后关闭它。
    return retry, nil
}

示例中的 makeBody 是可重放能力的核心。真实项目里如果数据来自文件、压缩流或大对象，工厂可以重新打开文件或从受控缓存读取，但必须处理打开失败、文件关闭和内存占用。不要把一个已经消费过的 Reader 反复塞回多个请求。

用三个指标判断方案是否合适

排查“重试后请求体为空”时，可以把现象拆成三个可观察指标：

• 可重放性：req.GetBody != nil 只说明工厂存在，不代表工厂一定能成功打开数据；仍要处理返回的错误。
• 内容长度：内存中的 bytes.Reader 适合小而稳定的负载；大请求体若每次复制，会把重试成本放大。
• 资源所有权：手动调用 GetBody 得到的副本要由使用方关闭；正常交给 Client.Do 的请求体则由 Transport 负责关闭。

常见问题

GetBody 设置了，为什么第一次请求还是发不出去？

因为 GetBody 只负责未来创建副本，第一次发送仍然需要非空的 Body。两者是“当前实例”和“副本工厂”的关系。

手动重试应该复用原 Request 吗？

更稳妥的是保留原请求作为模板，用 GetBody 创建新读取器，再放进克隆请求；不要让多个请求共享同一个读取游标或未关闭的副本。

官方资料：https://pkg.go.dev/net/http#Request.GetBody

源码参考：https://go.dev/src/net/http/request.go、https://go.dev/src/net/http/client.go