Golang微服务重试机制全解析

func retry(attempts int, sleep time.Duration, fn func() error) error {
    var err error
    for i := 0; i 

baseDelay := 100 * time.Millisecond
maxDelay := 1 * time.Second
<p>for i := 0; i < maxRetries; i++ {
err := callService()
if err == nil {
break
}
if !isTransient(err) {
return err
}</p><pre class="brush:php;toolbar:false"><code>delay := baseDelay * time.Duration(1<<uint(i)) // 指数增长
jitter := time.Duration(rand.Int63n(int64(delay)))
delay = delay/2 + jitter%delay // 添加随机性

time.Sleep(delay)</code>

}

operation := func() error {
    resp, err := http.Get("http://service/api")
    if err != nil {
        return err
    }
    defer resp.Body.Close()
    if resp.StatusCode != http.StatusOK {
        return fmt.Errorf("bad status: %s", resp.Status)
    }
    return nil
}
<p>err := backoff.Retry(operation, backoff.WithMaxRetries(backoff.NewExponentialBackOff(), 5))
if err != nil {
log.Fatal("Failed after retries:", err)
}
</p>