限流器是服務(wù)中非常重要的一個(gè)組件，在網(wǎng)關(guān)設(shè)計(jì)、微服務(wù)、以及普通的后臺(tái)應(yīng)用中都比較常見(jiàn)。它可以限制訪問(wèn)服務(wù)的頻次和速率，防止服務(wù)過(guò)載，被刷爆。

限流器的算法比較多，常見(jiàn)的比如令牌桶算法、漏斗算法、信號(hào)量等。本文主要介紹基于漏斗算法的一個(gè)限流器的實(shí)現(xiàn)。文本也提供了其他幾種開(kāi)源的實(shí)現(xiàn)方法。

基于令牌桶的限流器實(shí)現(xiàn)

在golang 的官方擴(kuò)展包 time 中（github/go/time），提供了一個(gè)基于令牌桶算法的限流器的實(shí)現(xiàn)。

原理

令牌桶限流器，有兩個(gè)概念：

• 令牌：每次都需要拿到令牌后，才可以訪問(wèn)
• 桶：有一定大小的桶，桶中最多可以放一定數(shù)量的令牌
• 放入頻率：按照一定的頻率向通里面放入令牌，但是令牌數(shù)量不能超過(guò)桶的容量

因此，一個(gè)令牌桶的限流器，可以限制一個(gè)時(shí)間間隔內(nèi)，最多可以承載桶容量的訪問(wèn)頻次。下面我們看看官方的實(shí)現(xiàn)。

實(shí)現(xiàn)

限流器的定義

下面是對(duì)一個(gè)限流器的定義：

type Limiter struct {
 limit Limit // 放入桶的頻率  （Limit 為 float64類型）
 burst int  // 桶的大小

 mu   sync.Mutex
 tokens float64 // 當(dāng)前桶內(nèi)剩余令牌個(gè)數(shù)
 last time.Time // 最近取走token的時(shí)間
 lastEvent time.Time // 最近限流事件的時(shí)間
}

其中，核心參數(shù)是 limit，burst。 burst 代表了桶的大小，從實(shí)際意義上來(lái)講，可以理解為服務(wù)可以承載的并發(fā)量大小；limit 代表了 放入桶的頻率，可以理解為正常情況下，1s內(nèi)我們的服務(wù)可以處理的請(qǐng)求個(gè)數(shù)。

在令牌發(fā)放后，會(huì)被保留在Reservation 對(duì)象中，定義如下：

type Reservation struct {
 ok    bool // 是否滿足條件分配到了tokens
 lim    *Limiter // 發(fā)送令牌的限流器
 tokens  int  // tokens 的數(shù)量
 timeToAct time.Time // 滿足令牌發(fā)放的時(shí)間
 limit Limit // 令牌發(fā)放速度
}

Reservation 對(duì)象，描述了一個(gè)在達(dá)到 timeToAct 時(shí)間后，可以獲取到的令牌的數(shù)量tokens。 （因?yàn)橛行┬枨髸?huì)做預(yù)留的功能，所以timeToAct 并不一定就是當(dāng)前的時(shí)間。

限流器如何限流

官方提供的限流器有阻塞等待式的，也有直接判斷方式的，還有提供了自己維護(hù)預(yù)留式的，但核心的實(shí)現(xiàn)都是下面的reserveN 方法。

// 在 now 時(shí)間需要拿到n個(gè)令牌，最多可以等待的時(shí)間為maxFutureResrve
// 結(jié)果將返回一個(gè)預(yù)留令牌的對(duì)象
func (lim *Limiter) reserveN(now time.Time, n int, maxFutureReserve time.Duration) Reservation {
 lim.mu.Lock()

 // 首先判斷是否放入頻次是否為無(wú)窮大，如果為無(wú)窮大，說(shuō)明暫時(shí)不限流
 if lim.limit == Inf {
  // ...
 }

 // 拿到截至now 時(shí)間時(shí)，可以獲取的令牌tokens數(shù)量，上一次拿走令牌的時(shí)間last
 now, last, tokens := lim.advance(now)

 // 然后更新 tokens 的數(shù)量，把需要拿走的去掉
 tokens -= float64(n)

 // 如果tokens 為負(fù)數(shù)，說(shuō)明需要等待，計(jì)算等待的時(shí)間
 var waitDuration time.Duration
 if tokens  0 {
  waitDuration = lim.limit.durationFromTokens(-tokens)
 }

 // 計(jì)算是否滿足分配條件
 // ① 需要分配的大小不超過(guò)桶容量
 // ② 等待時(shí)間不超過(guò)設(shè)定的等待時(shí)常
 ok := n = lim.burst  waitDuration = maxFutureReserve

 // 最后構(gòu)造一個(gè)Reservation對(duì)象
 r := Reservation{
  ok:  ok,
  lim:  lim,
  limit: lim.limit,
 }
 if ok {
  r.tokens = n
  r.timeToAct = now.Add(waitDuration)
 }

 // 并更新當(dāng)前l(fā)imiter 的值
 if ok {
  lim.last = now
  lim.tokens = tokens
  lim.lastEvent = r.timeToAct
 } else {
  lim.last = last
 }

 lim.mu.Unlock()
 return r
}

從實(shí)現(xiàn)上看，limiter 并不是每隔一段時(shí)間更新當(dāng)前桶中令牌的數(shù)量，而是記錄了上次訪問(wèn)時(shí)間和當(dāng)前桶中令牌的數(shù)量。當(dāng)再次訪問(wèn)時(shí)，通過(guò)上次訪問(wèn)時(shí)間計(jì)算出當(dāng)前桶中的令牌的數(shù)量，決定是否可以發(fā)放令牌。

使用

下面我們通過(guò)一個(gè)簡(jiǎn)單的例子，學(xué)習(xí)上面介紹的限流器的使用。

 limiter := rate.NewLimiter(rate.Every(100*time.Millisecond), 10)
 http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
  if limiter.Allow() {// do something
   log.Println("say hello")
  }
 })
 _ = http.ListenAndServe(":13100", nil)

上面，每100 ms 放入令牌桶中1個(gè)令牌，所以當(dāng)批量訪問(wèn)該接口時(shí)，可以看到如下結(jié)果：

2020/06/26 14:34:16 say hello  有18 條記錄
2020/06/26 14:34:17 say hello  有10 條記錄
2020/06/26 14:34:18 say hello  有10 條記錄
  ...

一開(kāi)始漏斗滿著，可以緩解部分突發(fā)的流量。當(dāng)漏斗未空時(shí)，訪問(wèn)的頻次和令牌放入的頻次變?yōu)橐恢隆?/p>

其他限流器的實(shí)現(xiàn)

uber 開(kāi)源庫(kù)中基于漏斗算法實(shí)現(xiàn)了一個(gè)限流器。漏斗算法可以限制流量的請(qǐng)求速度，并起到削峰填谷的作用。 https://github.com/uber-go/ratelimit

滴滴開(kāi)源實(shí)現(xiàn)了一個(gè)對(duì)http請(qǐng)求的限流器中間件。可以基于以下模式限流。

• 基于IP，路徑，方法，header，授權(quán)用戶等限流
• 通過(guò)自定義方法限流
• 還支持基于 http header 設(shè)置限流數(shù)據(jù)
• 實(shí)現(xiàn)方式是基于 github/go/time 實(shí)現(xiàn)的，不同類別的數(shù)據(jù)都存儲(chǔ)在一個(gè)帶超時(shí)時(shí)間的數(shù)據(jù)池中。
• 代碼地址 https://github.com/didip/tollbooth

golang 網(wǎng)絡(luò)包中還有基于信號(hào)量實(shí)現(xiàn)的限流器。 https://github.com/golang/net/blob/master/netutil/listen.go 也值得我們?nèi)W(xué)習(xí)下。

總結(jié)

令牌桶實(shí)現(xiàn)的限流器算法，相較于漏斗算法可以在一定程度上允許突發(fā)的流量進(jìn)入我們的應(yīng)用中，所以在web應(yīng)用中最為廣泛。

在實(shí)際使用時(shí)，一般不會(huì)做全局的限流，而是針對(duì)某些特征去做精細(xì)化的限流。例如：通過(guò)header、x-forward-for 等限制爬蟲(chóng)的訪問(wèn)，通過(guò)對(duì) ip,session 等用戶信息限制單個(gè)用戶的訪問(wèn)等。

到此這篇關(guān)于Golang 限流器的使用和實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)Golang 限流器內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！