[TOC] ### 漏桶算法 漏桶算法思路很簡單，我們把水比作是`請求`，漏桶比作是`系統處理能力極限`，水先進入到漏桶里，漏桶里的水按一定速率流出，當流出的速率小于流入的速率時，由于漏桶容量有限，后續進入的水直接溢出（拒絕請求），以此實現限流。 它的主要目的是控制數據注入到網絡的速率，平滑網絡上的突發流量  <details> <summary>main.go</summary> ``` package main import ( "fmt" "math" "sync" "time" ) type LeakyBucket struct { rate float64 //固定每秒出水速率 capacity float64 //桶的容量 water float64 //桶中當前水量 lastLeakMs int64 //桶上次漏水時間戳 ms lock sync.Mutex } func (l *LeakyBucket) Allow() bool { l.lock.Lock() defer l.lock.Unlock() now := time.Now().UnixNano() / 1e6 eclipse := float64(now - l.lastLeakMs) * l.rate / 1000 //先執行漏水 l.water = l.water - eclipse //計算剩余水量 l.water = math.Max(0, l.water) //桶干了 l.lastLeakMs = now if (l.water + 1) < l.capacity { // 嘗試加水,并且水還未滿 l.water++ return true } else { // 水滿，拒絕加水 return false } } func (l *LeakyBucket) Set(r, c float64) { l.rate = r l.capacity = c l.water = 0 l.lastLeakMs = time.Now().UnixNano() / 1e6 } func main() { var leak LeakyBucket leak.Set(5,100) for i:=0; i<100000; i++ { if leak.Allow() { fmt.Printf("%+v s,i=%d\n", i/100,i ) }else if i%100==0 { fmt.Printf("%+v s\n", i/100 ) } time.Sleep(1*time.Millisecond) } } ``` </details> <br/> **特點**： - 漏桶具有固定容量，出水速率是固定常量（流出請求） - 如果桶是空的，則不需流出水滴 - 可以以任意速率流入水滴到漏桶（流入請求） - 如果流入水滴超出了桶的容量，則流入的水滴溢出（新請求被拒絕） 漏桶限制的是常量流出速率（即流出速率是一個固定常量值），所以最大的速率就是出水的速率，不能出現突發流量 **缺陷**: 漏桶算法不能夠有效地使用網絡資源。因為漏桶的漏出速率是固定的參數,漏桶算法對于存在突發特性的流量來說缺乏效率