Go中无装饰器语法，需用高阶函数模拟重试逻辑，核心是分离重试与业务逻辑；应避免硬编码循环、忽略context取消、滥用reflect，推荐用闭包封装带指数退避和上下文控制的WithRetry函数。
Go 里没有装饰器，但可以用函数式封装模拟
Go 语言本身不支持 Python 那种 @decorator 语法，所谓“重试装饰器”本质是返回新函数的高阶函数。关键不是语法糖，而是把重试逻辑和业务逻辑干净分离。
常见错误是直接在原函数里硬塞 for 循环或递归调用，导致测试难、超时控制失效、错误类型被吞掉。正确做法是让重试逻辑只关心「怎么重试」，不碰「做什么」。
-
retry.Do这类工具函数适合简单场景，但无法包裹已有函数签名；你需要的是retry.Wrap这类返回func() error或带参数闭包的封装 - 如果原函数带参数（比如
func(id string, timeout time.Duration) (string, error)），必须用闭包捕获参数，不能试图“泛化”所有函数签名——Go 没有泛型函数重载，硬搞会写出大量重复模板代码 - 别用
reflect动态调用：性能差、堆栈丢失、panic 不易捕获，且绝大多数重试场景参数固定可预知
如何实现一个带指数退避和上下文取消的重试包装器
生产环境最常踩的坑是忽略 context.Context：重试过程中用户已取消请求，但 goroutine 还在傻等下次重试。真正的重试控制必须和 context 绑定。
以下是一个轻量但可用的封装示例（不依赖第三方库）：
立即学习“go语言免费学习笔记（深入）”；
func WithRetry(fn func() error, opts ...RetryOption) func() error {
cfg := defaultRetryConfig()
for _, opt := range opts {
opt(cfg)
}
return func() error {
var lastErr error
for i := 0; i < cfg.maxTries; i++ {
select {
case <-cfg.ctx.Done():
return cfg.ctx.Err()
default:
}
if err := fn(); err != nil {
lastErr = err
if i == cfg.maxTries-1 {
break
}
// 指数退避 + jitter
sleepDur := time.Duration(math.Pow(2, float64(i))) * time.Second
sleepDur += time.Duration(rand.Int63n(int64(cfg.jitter)))
time.Sleep(sleepDur)
continue
}
return nil
}
return lastErr
}
}-
cfg.ctx必须由调用方传入，不能在包装器里新建context.Background()，否则取消信号进不来 -
sleepDur计算后应做上限限制（比如min(sleepDur, 30*time.Second)），避免第 10 次重试等 17 分钟 - 使用
rand.Int63n前要rand.Seed(time.Now().UnixNano())，但更推荐从外部传入*rand.Rand实例，方便测试时固定随机序列
重试判定逻辑必须显式声明，不能只看 error 是否为 nil
很多同学默认「非 nil error 就重试」，结果数据库唯一约束失败、用户输入校验失败也被反复重试，浪费资源还误导前端。
真正需要重试的错误往往有明确特征：
- 网络类：
net.OpError、os.SyscallError（底层 connect timeout）、grpc.Status.Code() == codes.Unavailable - 临时服务不可用：
strings.Contains(err.Error(), "i/o timeout")或自定义错误类型如IsTransient(err) - 绝不能重试：
errors.Is(err, sql.ErrNoRows)、errors.Is(err, ErrInvalidInput)、HTTP 400/401/403/404 等客户端错误
建议把重试判定抽成独立函数，例如：
func ShouldRetry(err error) bool {
if err == nil {
return false
}
var netErr net.Error
if errors.As(err, &netErr) && netErr.Timeout() {
return true
}
if s, ok := status.FromError(err); ok && s.Code() == codes.Unavailable {
return true
}
return false
}然后在重试循环中显式调用它，而不是无差别重试。
并发调用下要注意重试函数的状态隔离
如果你把重试包装器用在 HTTP handler 中，每个请求都该有独立的重试状态（比如已尝试次数、上次失败时间）。错误做法是把计数器存在全局变量或结构体字段里——多个请求会互相干扰。
- 所有重试相关状态（当前重试次数、上次 sleep 时间、随机 jitter 值）必须放在闭包内或作为函数参数传入，不能跨调用共享
- 不要在包装器里启动 goroutine 处理重试：同步阻塞更可控，异步容易导致 panic 捕获失效、context 取消后 goroutine 泄漏
- 如果业务本身是并发的（比如批量调用 100 个下游接口），每个子任务应单独套一层重试包装，而不是对整个 batch 函数加一层重试
重试不是银弹，它掩盖不了设计缺陷。当发现某个接口需要频繁重试才能成功，优先检查连接池配置、下游稳定性、是否该改用异步补偿，而不是堆 retry 参数。
