关于在 Go 代码中使用退避方法，啰嗦几句（Yak Shaving With Backoff Libraries in Go）

我相信你有过调用 API 接口需要使用退避算法的时候。在 Go 语言现有技术中，有 github.com/cenkalti/backoff，github.com/jpillora/backoff，和其它库可以使用。

我曾经使用过 github.com/cenkalti/backoff，但是有一件让我感到困惑的事：它要求你为操作加上闭包，强制输入为 func() error 的形式。

举个例子，当你需要一个可以自动重试的函数（如下面的 myFunc 函数），返回 3 个值和一个 error，你需要和作用域斗智斗勇。

var a, b, c Result
backoff.Retry(func() error {
    var err error
    a, b, c, err = myFunc(arg, ...)
    return err
}, backoffObject)

在性能方面，这可能可以忽略不计，但作用域全搞乱了，这个时候你必须要小心，在赋值时不要使用 :=，而是使用 = 来确保获得正确的值。

这是我写 github.com/lestrrat-go/backoff 库的主要原因。

使用这个库，你将不得不写更多的样板代码（使用库需要执行的函数：NewExponential()，Start() 等），但是你不需要实现一个闭包，我发现这样更加符合 Go 的风格。计算退避持续时间仍然很难，如果你有更好的算法，请告诉我。

使用 github.com/lestrrat-go/backoff 库，首先你要创建一个策略对象：

policy := backoff.NewExponential(...)

传入的参数也会影响到策略，例如配置最大重试次数或者不重试。策略对象可以被多个消费者重用。

实际上 backoff 对象是通过调用策略对象的 Start() 方法创建的：

b, cancel := policy.Start(ctx)

该方法接收一个 context 对象，因此你可以通过父作用域内的释放操作终止退避算法。

当退避对象 b 不再需要时，cancel 用于释放资源。

退避对象 b 包含两个方法，Done() 和 Next()。他们都返回一个可以通知我们事件的管道变量。

当退避算法停止时，Done() 变得可读：（停止的情况）包括父 context 被取消导致退避算法被取消或者某个条件发生（例如当我们已经重试了 MaxRetries 参数指定的次数时）。

当调用过了足够的时候后，Next() 才变为可读。在指数级回退的情况下，在调用 Next() 之后，你可能得等 1， 2， 4， 8， 16...（乘以基本区间）。

使用这些方法，你的退避方法将看起来就像这样：

func MyFuncWithRetries(ctx context.Context, ... ) (Result1, Result2, Result3, error) {
    b, cancel := policy.Start(ctx)
    defer cancel()
    for {
        ret1, ret2, ret3, err := MyFunc(...)
        if err == nil { // success
            return ret1, ret2, ret3, nil
        }
        select {
        case <-b.Done():
            return nil, nil, nil, errors.New(`all attempts failed`)
        case <-b.Next():
            // continue to beginning of the for loop, execute MyFunc again
        }
    }
}

使用这种方法的缺点是你需要更多的样板代码。优点是你不再需要奇怪的作用域技巧，操作变得更加直接。

我认为这是一个关于口味的问题，所以你应该选择符合你口味或者习惯的库。这恰好是我想要的库，希望也对你有帮助。

编程快乐！