Skip to content

重试与容错

默认重试

go
cfg := httpc.DefaultConfig()
cfg.Retry.MaxRetries = 3           // 最多 3 次
cfg.Retry.Delay = 1 * time.Second  // 初始延迟 1s
cfg.Retry.BackoffFactor = 2.0      // 指数退避 2x
cfg.Retry.EnableJitter = true      // 启用抖动

client, err := httpc.New(cfg)
if err != nil {
    log.Fatal(err)
}
defer client.Close()

默认重试延迟序列:1s → 2s → 4s(含随机抖动)

重试条件

默认情况下,以下错误会触发重试:

条件重试
网络错误(连接拒绝、临时/超时类 DNS 失败)
超时错误
5xx 服务端错误(500/502/503/504)
408 Request Timeout / 429 Too Many Requests
其他 4xx 客户端错误
上下文取消
配置验证错误

自定义重试策略

实现 RetryPolicy 接口完全控制重试行为:

内部类型

RetryPolicy.ShouldRetry 的 resp 参数类型 ResponseReader 为内部接口(定义在 internal/types 包中),外部包无法直接引用。自定义 RetryPolicy 必须在与 httpc 同一模块内的包中实现。大多数场景可通过 RetryConfig 字段配置满足需求。

go
// 注意:ResponseReader 是内部类型(internal/types 包)。
// 此代码仅能在 github.com/cybergodev/httpc 模块内部编译。
// 大多数用户应通过 RetryConfig 和 WithMaxRetries 配置重试。

type MyRetryPolicy struct {
    maxAttempts int
}

// 判断是否应该重试
func (p *MyRetryPolicy) ShouldRetry(resp ResponseReader, err error, attempt int) bool {
    if attempt >= p.maxAttempts {
        return false
    }
    // 网络错误重试
    if err != nil {
        return true
    }
    // 仅 502、503、504 重试
    return resp.StatusCode() == 502 || resp.StatusCode() == 503 || resp.StatusCode() == 504
}

// 返回重试延迟
func (p *MyRetryPolicy) GetDelay(attempt int) time.Duration {
    return time.Second * time.Duration(attempt+1)
}

// 最大重试次数
func (p *MyRetryPolicy) MaxRetries() int {
    return p.maxAttempts
}

// 应用自定义策略
cfg := httpc.DefaultConfig()
cfg.Retry.CustomPolicy = &MyRetryPolicy{maxAttempts: 5}

按请求控制

go
// 单个请求重试 5 次
result, err := client.Get(url, httpc.WithMaxRetries(5))

// 禁用重试
result, err := client.Get(url, httpc.WithMaxRetries(0))

// 配合上下文超时
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()
result, err := client.Request(ctx, "GET", url, httpc.WithMaxRetries(3))

Retry-After 支持

HTTPC 自动解析服务端返回的 Retry-After 响应头:

go
// 服务端返回:Retry-After: 120
// HTTPC 最多等待 60 秒后重试(服务端指定的 120s 会被截断为安全上限 60s)

// 服务端返回:Retry-After: Fri, 25 Apr 2026 12:00:00 GMT
// HTTPC 会等待到指定时间后重试(若距今超过 60s 则截断为 60s)

TIP

Retry-After 在所有可重试的响应中生效(408、429、500、502、503、504),优先级高于指数退避延迟。

退避策略

指数退避

go
cfg.Retry.BackoffFactor = 2.0
// 延迟序列:delay, delay*2, delay*4, delay*8...

固定延迟

go
cfg.Retry.BackoffFactor = 1.0
// 延迟序列:delay, delay, delay...

线性增长

go
// 需要自定义 RetryPolicy 实现:
// delay * (attempt + 1)
// 详见高级示例中的自定义重试策略

随机抖动

启用抖动避免"惊群效应":

go
cfg.Retry.EnableJitter = true
// 在基础延迟上添加随机偏移,防止所有客户端同时重试

错误处理与重试

go
result, err := client.Get(url)
if err != nil {
    var clientErr *httpc.ClientError
    if errors.As(err, &clientErr) {
        if clientErr.Type == httpc.ErrorTypeRetryExhausted {
            log.Printf("重试 %d 次后仍失败", clientErr.Attempts)
        }
    }
    return err
}

最佳实践

场景建议
API 调用MaxRetries=3, Delay=1s, Backoff=2.0
微服务通信MaxRetries=2, Delay=500ms
文件下载MaxRetries=5, Delay=2s, Backoff=2.0
幂等操作可放心重试
非幂等操作(POST)建议仅在网络错误时重试(默认也会对 5xx/408/429 重试,需自定义 RetryPolicy 收窄)

WARNING

非幂等的 POST 请求默认也会重试。如需精确控制,请实现自定义 RetryPolicy

下一步