zero-doc/docs/zero/自适应融断中间件.md

自适应熔断中间件

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

这篇文章，了解下 Google SRE 中的过载保护（弹性熔断）的处理机制   [Handling Overload](https://landing.google.com/sre/sre-book/chapters/handling-overload/#eq2101)


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
}