登录
首页 >  Golang >  Go教程

GolangHTTP重试实现及请求示例

时间:2026-01-24 08:24:39 226浏览 收藏

“纵有疾风来,人生不言弃”,这句话送给正在学习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

  • 重试应仅针对幂等方法:GETHEADOPTIONSPUTDELETEPOSTPATCH 默认不应重试,除非你确认服务端幂等
  • 需重置请求 Body:若 Body 是 io.ReadCloser(如文件流),重试前必须能重新读取;建议用 bytes.NewReaderstrings.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

}

第三方库如 retryablehttp 更适合生产环境

自己实现容易漏掉边界情况:Body 重放失败、context 取消未透传、重试次数被中间件干扰、指标埋点缺失等。成熟库如 hashicorp/go-retryablehttp 已处理这些细节,并支持自定义判断函数、回调钩子、Prometheus 指标。

  • 它默认只对 GETHEAD 重试,其他方法需显式启用
  • 内置 jitter(随机抖动)避免重试同步冲击下游
  • 注意:它返回的是 *retryablehttp.Client,不是标准 *http.Client,不能直接用于需要原生 client 的第三方库(如某些 SDK)

安装:go get github.com/hashicorp/go-retryablehttp

关键配置项:RetryMax(最大重试次数)、RetryWaitMin/RetryWaitMax(退避区间)、RetryHTTPMethods(允许重试的 method 列表)

重试逻辑看似简单,真正难的是判断“该不该重试”——网络中断、服务不可用、限流、上游超时、下游 bug,表现可能都是 connection refused503 Service Unavailable,但重试策略应完全不同。别只看错误类型,得结合业务语义和上下游 SLA 来设计。

到这里,我们也就讲完了《GolangHTTP重试实现及请求示例》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于的知识点!

前往漫画官网入口并下载 ➜
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>