该中间件，go-zero内建，不需要使用者手动配置。当请求失败比率达到一定阈值之后，熔断器开启，并休眠一段时间（由配置决定），这段休眠期过后，熔断器将处于半开状态，在此状态下将试探性的放过一部分流量，如果这部分流量调用成功后，再次将熔断器关闭，否则熔断器继续保持开启并进入下一轮休眠周期。

这篇文章，了解下 Google SRE 中的过载保护（弹性熔断）的处理机制   Handling Overload

go-zreo 为了防止小流量熔断，对该公式做了一定的修改

params

参数说明

requests总请求数量
accepts正常请求数量
K

倍值 (Google SRE 推荐值为 2)

protection

保护值（防止小流量熔断 推荐值为5）

 









可以通过修改 K 的值来修改熔断发生的激进程度，降低 K 的值会使得自适应熔断算法更加激进，增加 K 的值则自适应熔断算法变得不再那么激进

func (b *googleBreaker) accept() error {
    accepts, total := b.history()
    weightedAccepts := b.k * float64(accepts)
  
    dropRatio := math.Max(0, (float64(total-protection)-weightedAccepts)/float64(total+1))
    // 当max<=0的时候，会将熔断关闭，并且正常接受请求返回结果
    if dropRatio <= 0 {
        if atomic.LoadInt32(&b.state) == StateOpen {
            atomic.CompareAndSwapInt32(&b.state, StateOpen, StateClosed)
        }
        return nil
    }

    // 当max > 0 时，会开启熔断，并有几率正常请求，max值越高，正常请求的概率越低。
    if atomic.LoadInt32(&b.state) == StateClosed {
        atomic.CompareAndSwapInt32(&b.state, StateClosed, StateOpen)
    }
    if b.proba.TrueOnProba(dropRatio) {
        return ErrServiceUnavailable
    }

    return nil
}

// 取0-1之间的随机数，传入的浮点数越大，返回true的概率越大
func (p *Proba) TrueOnProba(proba float64) (truth bool) {
    p.lock.Lock()
    truth = p.r.Float64() < proba 
    p.lock.Unlock()
    return
}