# Go 請求處理頻率控制 頻率控制是控制資源利用和保證服務高質量的重要機制。Go可以使用goroutine，channel和ticker來以優雅的方式支持頻率控制。 ```go package main import "time" import "fmt" func main() { // 首先我們看下基本的頻率限制。假設我們得控制請求頻率， // 我們使用一個通道來處理所有的這些請求，這里向requests // 發送5個數據，然后關閉requests通道 requests := make(chan int, 5) for i := 1; i <= 5; i++ { requests <- i } close(requests) // 這個limiter的Ticker每隔200毫秒結束通道阻塞 // 這個limiter就是我們頻率控制處理器 limiter := time.Tick(time.Millisecond * 200) // 通過阻塞從limiter通道接受數據，我們將請求處理控制在每隔200毫秒 // 處理一個請求，注意`<-limiter`的阻塞作用。 for req := range requests { <-limiter fmt.Println("request", req, time.Now()) } // 我們可以保持正常的請求頻率限制，但也允許請求短時間內爆發 // 我們可以通過通道緩存來實現，比如下面的這個burstyLimiter // 就允許同時處理3個事件。 burstyLimiter := make(chan time.Time, 3) // 填充burstyLimiter，先發送3個數據 for i := 0; i < 3; i++ { burstyLimiter <- time.Now() } // 然后每隔200毫秒再向burstyLimiter發送一個數據，這里是不斷地 // 每隔200毫秒向burstyLimiter發送數據 go func() { for t := range time.Tick(time.Millisecond * 200) { burstyLimiter <- t } }() // 這里模擬5個請求，burstyRequests的前面3個請求會連續被處理， // 因為burstyLimiter被先連續發送3個數據的的緣故，而后面兩個 // 則每隔200毫秒處理一次 burstyRequests := make(chan int, 5) for i := 1; i <= 5; i++ { burstyRequests <- i } close(burstyRequests) for req := range burstyRequests { <-burstyLimiter fmt.Println("request", req, time.Now()) } } ``` 運行結果 ``` request 1 2014-02-21 14:20:05.2696437 +0800 CST request 2 2014-02-21 14:20:05.4696637 +0800 CST request 3 2014-02-21 14:20:05.6696837 +0800 CST request 4 2014-02-21 14:20:05.8697037 +0800 CST request 5 2014-02-21 14:20:06.0697237 +0800 CST request 1 2014-02-21 14:20:06.0697237 +0800 CST request 2 2014-02-21 14:20:06.0697237 +0800 CST request 3 2014-02-21 14:20:06.0707238 +0800 CST request 4 2014-02-21 14:20:06.2707438 +0800 CST request 5 2014-02-21 14:20:06.4707638 +0800 CST ``` 我們從輸出的結果上可以看出最后的5個輸出結果中，前三個的時間是連續的，而后兩個的時間是隔了200毫秒。