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

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
}
func (r RetryRoundTripper) RoundTrip(req http.Request) (http.Response, error) {
var err error
var resp http.Response
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
简单场景下用 for 循环 + time.Sleep 更直接
如果只是临时补丁或逻辑简单(比如只重试 GET),不必封装 RoundTripper,直接在调用处控制更清晰。注意:必须确保 req.Body 可多次读取,否则第二次 http.DefaultClient.Do(req) 会报 body closed by client。
立即学习“go语言免费学习笔记(深入)”;
- 不要用
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()
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<}
第三方库如 retryablehttp 更适合生产环境
自己实现容易漏掉边界情况:Body 重放失败、context 取消未透传、重试次数被中间件干扰、指标埋点缺失等。成熟库如 hashicorp/go-retryablehttp 已处理这些细节,并支持自定义判断函数、回调钩子、Prometheus 指标。
- 它默认只对
GET 和 HEAD 重试,其他方法需显式启用
- 内置 jitter(随机抖动)避免重试同步冲击下游
- 注意:它返回的是
*retryablehttp.Client,不是标准 *http.Client,不能直接用于需要原生 client 的第三方库(如某些 SDK)
安装:go get github.com/hashicorp/go-retryablehttp
关键配置项:RetryMax(最大重试次数)、RetryWaitMin/RetryWaitMax(退避区间)、RetryHTTPMethods(允许重试的 method 列表)
重试逻辑看似简单,真正难的是判断“该不该重试”——网络中断、服务不可用、限流、上游超时、下游 bug,表现可能都是 connection refused 或 503 Service Unavailable,但重试策略应完全不同。别只看错误类型,得结合业务语义和上下游 SLA 来设计。










