Go语言怎么实现任务失败自动重试？重试策略与错误记录-Golang-PHP中文网

Go中无自动重试，需显式实现循环+错误判断+延迟；难点在于判断何时不该重试及避免压垮系统，应使用backoff/v4等库实现带抖动的指数退避并严格分类错误。

go语言怎么实现任务失败自动重试？重试策略与错误记录

直接上结论：Go 里没有自动重试，所谓“自动”全是靠你显式控制循环 + 错误判断 + 延迟等待实现的；重试本身不难，难在「什么时候不该重试」和「重试时别把系统拖垮」。

为什么不能直接用 `for` + `time.Sleep` 硬写重试？

看似最简单的写法，实际埋了三个雷：

忽略 ctx.Done()：哪怕请求已被取消，time.Sleep 还在傻等，goroutine 卡住不退出
固定间隔压垮下游：100 个协程同时重试，全在第 2 秒准时发起第二次请求，就是重试风暴
错误无分类：把 sql.ErrNoRows 或 errors.New("invalid token") 和 net.OpError 一样重试，纯属浪费资源

所以别从零手撸，优先用成熟库封装好的退避逻辑。

用 `backoff.Retry` 实现带抖动的指数退避

社区最稳的选择是 github.com/cenkalti/backoff/v4，它把 jitter、context 取消、最大耗时都收口了，你只管定义「什么算失败」：

必须用 backoff.WithContext(bo, ctx) 包一层，否则 ctx.Done() 完全无效
必须加 backoff.WithJitter()，否则多个实例会在同一时刻重试
InitialInterval 建议设为 100 * time.Millisecond，MaxInterval 别超 2 * time.Second，避免单次等待过长
操作函数内部仍要检查 ctx.Err()，比如 HTTP 请求里传入 ctx 给 http.NewRequestWithContext

示例片段：

<pre class="brush:php;toolbar:false;">bo := &backoff.ExponentialBackOff{
    InitialInterval:     100 * time.Millisecond,
    MaxInterval:         2 * time.Second,
    MaxElapsedTime:      10 * time.Second,
    Clock:               backoff.SystemClock,
}
bo = backoff.WithJitter(bo)
<p>err := backoff.Retry(func() error {
req, _ := http.NewRequestWithContext(ctx, "GET", url, nil)
resp, err := http.DefaultClient.Do(req)
if err != nil {
return err // 网络层错误，可重试
}
defer resp.Body.Close()
if resp.StatusCode == 503 || resp.StatusCode == 429 {
return fmt.Errorf("temp error: %d", resp.StatusCode) // 临时服务错误，重试
}
if resp.StatusCode >= 400 {
return backoff.Permanent(fmt.Errorf("client error: %d", resp.StatusCode)) // 永久错误，终止重试
}
return nil
}, backoff.WithContext(bo, ctx))</p>

如何记录每次重试的错误而不干扰主逻辑？

错误日志不是可选功能，而是调试重试行为的唯一依据。关键点：

Go语言（Golang）1.26.0

Go语言（Golang）1.26.0版本官方下载，版本号 1.26.0，适合旧项目维护、兼容性测试和指定版本开发环境搭建。

下载

别在重试函数里直接 log.Printf——它会污染返回值，且无法区分是第几次失败
用 backoff.Notify 回调，在每次重试前/后拿到错误和当前尝试次数
记录内容至少包含：attempt、error、nextDelay（下次等待多久），方便排查是否卡在某类错误上
对高频重试操作，考虑加采样（如每 10 次记 1 条），避免日志刷爆磁盘

示例：

<pre class="brush:php;toolbar:false;">var attempt int
err := backoff.RetryNotify(func() error {
    attempt++
    return doSomething()
}, backoff.WithContext(bo, ctx), func(err error, t time.Duration) {
    log.Printf("retry[%d] failed: %v, next in %v", attempt, err, t)
})