Go语言如何用断路器模式_Go语言断路器实现教程【进阶】-Golang-PHP中文网

应直接使用 github.com/sony/gobreaker，禁用手写状态机、归档的 afex/hystrix-go 及外层包裹 http.get；必须实现自定义 roundtripper 在 roundtrip 中调用 cb.execute 并透传 req 和 ctx；timeout 设为下游 p95 耗时的 2–3 倍，readytotrip 需按错误类型过滤，仅将超时类错误计入失败，降级逻辑须纯内存无副作用。

go语言如何用断路器模式_go语言断路器实现教程【进阶】

直接用 github.com/sony/gobreaker，别手写、别碰 afex/hystrix-go（已归档）、也别在外层套 cb.Execute 包裹 http.Get —— 这三种做法线上基本等于裸奔。

为什么必须包装 `RoundTripper` 而不是外层调用 `Execute`

HTTP 客户端的熔断粒度是「单次请求」，不是「整个 Client」。Go 的 http.Client 本身不提供拦截点，cb.Execute 外层包裹会绕过底层 Transport 的连接复用、超时透传和 context 控制。

超时失效：context.WithTimeout 无法穿透到 net.Conn 层，连接可能卡死几十秒
连接池泄漏：每次调用都新建 http.Client 或跳过 Transport.RoundTrip，FD 数暴涨
错误误判：cb.Execute 只捕获闭包 panic 和 error，但无法感知 HTTP 状态码（如 503）或区分 net/url.Error 和业务 404

正确做法是实现自定义 http.RoundTripper，在 RoundTrip(*http.Request) 内部调用 cb.Execute，并把原始 req 和 req.Context() 透传给底层 http.DefaultTransport.RoundTrip。

`ReadyToTrip` 和 `Timeout` 怎么配才不翻车

这两个参数默认值只适合本地调试，90% 的“熔断不生效”或“一直不恢复”都出在这儿。

Timeout（熔断持续时间）：设为下游 P95 耗时的 2–3 倍；默认 60s 太长，下游服务已恢复，你的服务还在拒流
ReadyToTrip（触发条件）：不要用默认的“100 次失败率 > 60%”。应显式过滤错误类型，例如只将 context.DeadlineExceeded、net/http.ErrTimeout 视为失败；sql.ErrNoRows、HTTP 404、401 必须放过
RequestVolumeThreshold（统计窗口最小请求数）：低频服务（如管理后台接口）要调小（比如设为 5），否则永远达不到统计条件，断路器形同虚设

`cb.Execute` 闭包里传参的坑怎么避

这是线上最隐蔽的 panic 来源：循环中直接闭包捕获可变变量，导致所有请求共享同一内存地址。

错误写法：

Go语言（Golang）1.26.0

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

下载

for _, url := range urls {
    req, _ := http.NewRequest("GET", url, nil)
    cb.Execute(func() (interface{}, error) {
        return http.DefaultClient.Do(req) // 所有闭包共用同一个 req 指针
    })
}

结果是 http: Request.Write on Body closed 或请求错乱。

正确写法（显式传参）：

for _, url := range urls {
    req, _ := http.NewRequest("GET", url, nil)
    cb.Execute(func(req *http.Request) func() (interface{}, error) {
        return func() (interface{}, error) {
            return http.DefaultClient.Do(req)
        }
    }(req))
}

更安全的方式是封装成独立函数，避免闭包捕获逻辑。