如何进行Golang服务降级_结合Circuit-breaker框架-Golang-PHP中文网

gobreaker.execute的fallback仅在erropen或panic时触发，不处理超时、http 5xx等错误；须显式判断errors.is(err, gobreaker.erropen)等并单独调用签名一致的零延迟降级函数。

如何进行golang服务降级_结合circuit-breaker框架

gobreaker.Execute 的 fallback 参数根本不会处理超时和 HTTP 错误

很多人把降级逻辑塞进 cb.Execute 的第三个参数（fallback 函数），就以为万事大吉。结果线上一出问题，503、超时、连接拒绝全都不走降级——因为 gobreaker.ErrOpen 和 panic 才触发 fallback，其他错误原样返回。

常见错误现象：

context.DeadlineExceeded 被忽略，主函数继续执行直到真正失败
HTTP 返回 503 Service Unavailable，cb.Execute 直接返回该 error，不进 fallback
net.OpError（如 dial timeout）被计入失败计数，但降级函数完全没调用

正确做法是：先调 cb.Execute，再显式判断错误类型：

res, err := cb.Execute(func() (interface{}, error) {
    resp, err := client.Do(req)
    if err != nil {
        return nil, err
    }
    if resp.StatusCode >= 500 {
        return nil, fmt.Errorf("http %d", resp.StatusCode)
    }
    return resp, nil
})
if errors.Is(err, gobreaker.ErrOpen) {
    return fallbackUser()
}
if errors.Is(err, context.DeadlineExceeded) || errors.Is(err, context.Canceled) {
    return fallbackUser()
}
if err != nil {
    // 其他错误（如 5xx）也可按需降级
    return fallbackUser()
}

降级函数签名必须和主函数严格一致

主函数返回 func() (*User, error)，降级函数也得是这个签名。返回 *User 单独一个值，或只返回 error，都会导致编译失败或 panic。

容易踩的坑：

写成 func() *User —— 类型不匹配，cb.Execute 拒绝执行
在降级里调 db.QueryRow 或发新 HTTP 请求 —— 违反“零延迟”原则，拖慢主链路
用 &User{} 当默认值 —— 序列化后字段全为零值，前端可能误判为真实空数据

推荐写法：

Golang Naming

Go（Golang）命名规范 — 包括包、构造函数、结构体、接口、常量、枚举、错误、布尔值、接收器、getter/setter、函数等。

下载

func fallbackUser() (*User, error) {
    // 从 sync.Map 或本地 LRU cache 读旧数据
    if u, ok := userCache.Load(123); ok {
        return u.(*User), nil
    }
    // 否则构造明确语义的默认值
    return &User{
        ID:   123,
        Name: "用户信息暂不可用",
        Age:  0,
    }, nil
}