请求体重放

来源：17golang原创 2026-11-11 15:20:49 0浏览收藏

POST 请求第一次发送后，想把同一个 http.Request 再交给 Client.Do，经常会遇到请求体为空。关键不在于把 Body 再读一遍，而在于每次发送前都拿到一个全新的 io.ReadCloser。Request.GetBody 只是“如何创建副本”的可选函数；它为空时，直接重试已经消耗过的 Body 自然只能读到 EOF。

要点速览

Body 是当前请求的读取流，读到 EOF 后不会自动回到开头。
NewRequest 只会为 *bytes.Buffer、*bytes.Reader 和 *strings.Reader 自动准备 GetBody。
面对普通流式 io.Reader，用原始字节、文件定位或请求体工厂重建请求，不要复用已读完的流。

Body 和 GetBody 不是同一个东西

Request.Body 是本次发送实际消费的流；Request.GetBody 则是一个可选工厂，调用后应返回新的 Body。官方定义还特别说明：它主要服务于客户端请求在重定向时重复读取请求体，且设置 GetBody 并不能省略 Body。服务器收到的请求不使用这个字段，所以不要在服务端 handler 里期待它替你保存原始请求体。

Go net/http Request 的 Body 与 GetBody 请求体工厂关系说明图 — 图1：请求体工厂关系说明图，区分当前 Body、GetBody 副本和 Client.Do 的客户端边界；这是原创静态说明图，不是运行截图。

下面的判断可以直接放进重试策略中：先看请求能否产生新的 Body，再决定是否允许自动重试。

func canReplay(req *http.Request) bool {
	// GetBody 能创建独立读取流时，才具备请求体重放的基础。
	return req != nil && req.Body != nil && req.GetBody != nil
}

为什么 NewRequest 有时会自动填充 GetBody

用 http.NewRequest 创建客户端请求时，如果传入的 reader 类型是 *bytes.Buffer、*bytes.Reader 或 *strings.Reader，标准库可以记录长度并生成新的 reader，因此会填充 GetBody。如果传入的是一个普通的自定义 reader、管道或网络流，标准库无法猜测怎样重新产生数据，GetBody 通常就是 nil。

请求体来源	GetBody	重放建议
`*bytes.Buffer`	通常自动提供	可调用工厂得到新的 reader
`bytes.Reader` / `strings.Reader`	通常自动提供	检查错误后使用新 Body
普通流式 `io.Reader`	通常为空	缓存原始数据或自行提供工厂

这里的“通常”是为了提醒你仍应检查实际值。不要把 ContentLength 非零误认为 Body 可以重放；长度只描述本次请求的大小，不会保存一份可重新读取的数据。

用请求体工厂为每次重试创建新 Request

更稳妥的做法是把“创建请求体”保存成函数。每次尝试都新建 Request，然后把新的 Body 交给客户端；这样不会让第二次尝试接着第一次的 EOF 继续读。

func newPost(url string, payload []byte) (*http.Request, error) {
	// 每次调用都从同一份不可变数据创建新的读取流。
	body := bytes.NewReader(payload)
	req, err := http.NewRequest(http.MethodPost, url, body)
	if err != nil {
		// URL 不合法时把创建错误交给上层，不进入重试循环。
		return nil, err
	}
	req.Header.Set("Content-Type", "application/json") // 标记请求体格式。
	return req, nil
}

func doWithRetry(client *http.Client, url string, payload []byte) (*http.Response, error) {
	for attempt := 0; attempt

Go POST 重试时用请求体工厂重新创建 Request 和 Body 的静态关系图 — 图2：POST 重试边界结构图，展示原始 payload、每次新建 Request 和新的 Body 之间的静态关系；这是原创结构图，不是运行证据。

如果拿到了响应，不论状态码是否代表业务成功，都要在消费完响应体后关闭它：

resp, err := doWithRetry(client, target, payload)
if err != nil {
	// 网络错误没有可供读取的响应体，直接返回错误。
	return err
}
defer resp.Body.Close() // 读取成功响应后释放连接相关资源。

body, err := io.ReadAll(resp.Body)
if err != nil {
	// 响应已返回，但读取正文仍可能产生 I/O 错误。
	return err
}
fmt.Println(resp.StatusCode, string(body)) // 状态码和正文交给业务判断。

GetBody 为空时应该怎么选

小型 JSON 或表单可以在进入重试前保存为 []byte，像上面的工厂一样重复创建 reader。大文件更适合使用可重新打开的文件或记录偏移的位置；真正的一次性流、上传管道和带副作用的请求，则不应因为“网络错误”就默认重放。还要把服务端是否幂等、是否已经处理成功纳入判断，GetBody 只能解决数据能否再次读取，不能保证重复 POST 没有业务副作用。