当前位置：首页 > 文章列表 > Golang > Go教程 > GolangHTTP重试实现及请求示例

GolangHTTP重试实现及请求示例

2026-01-24 08:24:39 0浏览收藏

“纵有疾风来，人生不言弃”，这句话送给正在学习Golang的朋友们，也希望在阅读本文《Golang HTTP重试实现与请求示例》后，能够真的帮助到大家。我也会在后续的文章中，陆续更新Golang相关的技术文章，有好的建议欢迎大家在评论留言，非常感谢！

Go的net/http客户端默认不重试，需手动实现；推荐用自定义RoundTripper封装重试逻辑，仅对GET/HEAD/OPTIONS/PUT/DELETE等幂等方法重试，配合指数退避与Body重放，并优先选用retryablehttp等成熟库。

如何使用Golang实现HTTP重试_Golang net/http 请求重试示例

HTTP客户端默认不重试，必须手动实现

Go 的 net/http 客户端在遇到网络错误（如连接超时、DNS失败、TLS握手失败）或 5xx 响应时，不会自动重试。即使设置了 http.Client.Timeout，它也只控制单次请求生命周期，不涉及重试逻辑。重试必须由业务层显式控制，否则一次临时网络抖动就会导致请求直接失败。

用 http.Client + 自定义 RoundTripper 实现可配置重试

最灵活的方式是包装 http.RoundTripper，在底层拦截请求并决定是否重试。这样能统一处理所有 HTTP 方法、保持 Header/Body 复用，并避免重复构建 *http.Request。

重试应仅针对幂等方法：GET、HEAD、OPTIONS、PUT、DELETE；POST 和 PATCH 默认不应重试，除非你确认服务端幂等
需重置请求 Body：若 Body 是 io.ReadCloser（如文件流），重试前必须能重新读取；建议用 bytes.NewReader 或 strings.NewReader 构造可重放 Body
推荐使用指数退避（exponential backoff），避免雪崩；例如首次延迟 100ms，第二次 200ms，第三次 400ms

type RetryRoundTripper struct {
    Transport http.RoundTripper
    MaxRetries int
    BaseDelay  time.Duration
}
<p>func (r <em>RetryRoundTripper) RoundTrip(req </em>http.Request) (<em>http.Response, error) {
var err error
var resp </em>http.Response</p><pre class="brush:php;toolbar:false;">for i := 0; i <= r.MaxRetries; i++ {
    resp, err = r.Transport.RoundTrip(req)
    if err == nil && resp.StatusCode >= 200 && resp.StatusCode < 300 {
        return resp, nil
    }
    if i == r.MaxRetries || !shouldRetry(req, err, resp) {
        break
    }
    time.Sleep(time.Duration(math.Pow(2, float64(i))) * r.BaseDelay)
    // 若 Body 可重放，需重置；否则需重建 req（如 req.Body = io.NopCloser(bytes.NewReader(bodyBytes))）
}
return resp, err

}

func shouldRetry(req http.Request, err error, resp http.Response) bool { if err != nil { return true // 网络错误一律重试 } if resp.StatusCode >= 500 && resp.StatusCode < 600 { return true // 5xx 服务端错误重试 } if resp.StatusCode == 408 || resp.StatusCode == 429 { return true // 请求超时、限流也常重试 } return false }

简单场景下用 for 循环 + time.Sleep 更直接

如果只是临时补丁或逻辑简单（比如只重试 GET），不必封装 RoundTripper，直接在调用处控制更清晰。注意：必须确保 req.Body 可多次读取，否则第二次 http.DefaultClient.Do(req) 会报 body closed by client。

不要用 http.Get()，它无法复用 Body；改用 http.NewRequest() 显式构造
重试前检查是否为幂等方法；非幂等方法（如含 JSON body 的 POST）跳过重试
设置总超时（context.WithTimeout）防止无限等待，和单次请求超时（client.Timeout）区分开

func doWithRetry(url string, maxRetries int) (*http.Response, error) {
    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancel()
<pre class="brush:php;toolbar:false;">req, _ := http.NewRequestWithContext(ctx, "GET", url, nil)

client := &http.Client{Timeout: 3 * time.Second}
var err error
var resp *http.Response

for i := 0; i <= maxRetries; i++ {
    resp, err = client.Do(req)
    if err == nil && resp.StatusCode < 300 {
        return resp, nil
    }
    if i == maxRetries {
        break
    }
    time.Sleep(time.Second * time.Duration(1<<uint(i))) // 1s, 2s, 4s...
}
return resp, err

}