鴻蒙OS 4.0公測機型公布：甚至連nova6都支持
華為全新的HarmonyOS 4.0操作系統將于今天下午正式登場，官方在發布會之前也已經正式給出了可升級的機型產品，這意味著這些機型會率先支持升級享用。這次的HarmonyOS 4.0支持
速率限制是構建可擴展和彈性系統的關鍵技術。它通過對指定時間范圍內允許的請求數量施加限制來幫助控制流量。在Go中實現速率限制可以確保最佳的資源利用，并保護您的應用程序免受過度流量或濫用行為的影響。在這篇博文中，我們將探索Go中的速率限制技術，并提供實用的代碼示例來幫助您有效地實現它們。
速率限制包括定義一組規則，這些規則決定客戶端在給定的時間窗口內可以發出多少請求。確保系統能夠處理負載，防止濫用或拒絕服務攻擊。限制速率的兩種常見方法是:
固定窗口速率限制:在這種方法中，速率限制在固定的時間窗口內強制執行。例如，如果速率限制設置為每分鐘100個請求，系統將在任何給定的60秒窗口中允許最多100個請求。超過此限制的請求將被拒絕或延遲到下一個時間窗口。
令牌桶速率限制:令牌桶速率限制是基于從一個桶中消耗令牌的概念。桶最初由固定數量的令牌填充，每個令牌代表一個請求。當客戶端想要發出請求時，它必須從桶中獲取令牌。如果桶為空，客戶端必須等待，直到令牌可用。
Go提供了一個名為golang.org/x/time/rate的內置包，提供速率限制功能。讓我們探討一下如何同時使用固定窗口和令牌桶方法來實現速率限制。
func fixedWindowRateLimiting() { limiter := rate.NewLimiter(rate.Limit(100), 1) // 允許每秒100次 for i := 0; i < 200; i++ { if !limiter.Allow() { fmt.Println("Rate limit exceeded. Request rejected.") continue } go process() }}// 處理請求func process() { fmt.Println("Request processed successfully.") time.Sleep(time.Millisecond) // 模擬請求處理時間}在上面的代碼片段中，我們創建了一個限制使用率。速率限制為每秒100個請求的NewLimiter。對每個請求調用limiter.Allow()方法，如果允許請求，則返回true;如果超過速率限制，則返回false。如果超過速率限制，請求將被拒絕。
對應的輸出為，清楚的看到部分請求已經被拒絕了：
Request processed successfully.Rate limit exceeded. Request rejected.Rate limit exceeded. Request rejected.Rate limit exceeded. Request rejected.Rate limit exceeded. Request rejected.Rate limit exceeded. Request rejected.Rate limit exceeded. Request rejected.Rate limit exceeded. Request rejected....func tokenBucketRateLimiting() { limiter := rate.NewLimiter(rate.Limit(10), 5) ctx, _ := context.WithTimeout(context.TODO(), time.Millisecond) for i := 0; i < 200; i++ { if err := limiter.Wait(ctx); err != nil { fmt.Println("Rate limit exceeded. Request rejected.") continue } go process() }}// 處理請求func process() { fmt.Println("Request processed successfully.") time.Sleep(time.Millisecond) // 模擬請求處理時間}在上述代碼中，我們使用 rate.NewLimiter 創建了一個限制器，其速率限制為每秒 10 個請求，突發 5 個請求。每個請求都會調用 limiter.Wait() 方法，該方法會阻塞直到有令牌可用。如果水桶是空的，沒有可用的令牌，請求就會被拒絕。
對應的輸出為，清楚的看到部分請求已經被拒絕了：
Request processed successfully.Rate limit exceeded. Request rejected.Rate limit exceeded. Request rejected.Request processed successfully.Rate limit exceeded. Request rejected.動態速率限制是指根據客戶端行為、系統負載或業務規則等動態因素調整速率限制。這種技術允許您實時調整速率限制，以優化資源利用率并提供更好的用戶體驗。讓我們看看 Go 中動態速率限制的示例：
func dynamicRateLimiting() { limiter := rate.NewLimiter(rate.Limit(10), 1) // 允許每秒100次 // Dynamic rate adjustment go func() { time.Sleep(time.Second * 10) // 每10秒調整 limiter fmt.Println("---adjust limiter---") limiter.SetLimit(rate.Limit(200)) // 將 limiter 提升到每秒 200 }() for i := 0; i < 3000; i++ { if !limiter.Allow() { fmt.Println("Rate limit exceeded. Request rejected.") time.Sleep(time.Millisecond * 100) continue } process() }}// 處理請求func process() { fmt.Println("Request processed successfully.") time.Sleep(time.Millisecond * 10) // 模擬請求處理時間}在上面的代碼片段中，我們創建了一個限制器，初始速率限制為每秒 10 個請求。然后，我們啟動一個 goroutine，在 10秒鐘后將速率限制調整為每秒 200 個請求。這樣，我們就能根據不斷變化的情況動態調整速率限制。
對應的輸出為，這里我們可以看到中途的時候，某些請求已經被拒絕掉了，后來我們通過動態調整，后續的請求都可以正常通過了：
...Request processed successfully.Rate limit exceeded. Request rejected.Request processed successfully.---adjust limiter---Rate limit exceeded. Request rejected.Request processed successfully.Request processed successfully.Request processed successfully.Request processed successfully.Request processed successfully....自適應速率限制可根據之前請求的響應時間或錯誤率動態調整速率限制。它允許系統自動適應不同的流量條件，確保最佳性能和資源利用率。讓我們看看 Go 中自適應速率限制的示例：
func adaptiveRateLimiting() { limiter := rate.NewLimiter(rate.Limit(10), 1) // 允許每秒10次 // 自適應調整 go func() { for { time.Sleep(time.Second * 10) responseTime := measureResponseTime() // 測量之前請求的響應時間 if responseTime > 500*time.Millisecond { fmt.Println("---adjust limiter 50---") limiter.SetLimit(rate.Limit(50)) } else { fmt.Println("---adjust limiter 100---") limiter.SetLimit(rate.Limit(100)) } } }() for i := 0; i < 3000; i++ { if !limiter.Allow() { fmt.Println("Rate limit exceeded. Request rejected.") time.Sleep(time.Millisecond * 100) continue } process() }}// 測量以前請求的響應時間// 執行自己的邏輯來測量響應時間func measureResponseTime() time.Duration { return time.Millisecond * 100}// 處理請求func process() { fmt.Println("Request processed successfully.") time.Sleep(time.Millisecond * 10) // 模擬請求處理時間}在上述代碼片段中，我們使用 measureResponseTime 函數模擬測量之前請求的響應時間。根據測量到的響應時間，我們通過使用 limiter.SetLimit 設置不同的值來動態調整速率限制。這樣，系統就能根據觀察到的響應時間調整其速率限制策略。
對應的輸出為:
Request processed successfully.Rate limit exceeded. Request rejected.Request processed successfully.Rate limit exceeded. Request rejected.---adjust limiter 100---Request processed successfully.Request processed successfully.Request processed successfully.Request processed successfully.Request processed successfully.速率限制是維護 Go 應用程序穩定性和安全性的基本技術。通過有效控制傳入請求的流量，您可以防止資源耗盡并確保資源的公平分配。在這篇博文中，我們探討了固定窗口和令牌桶速率限制的概念，并提供了代碼片段，演示如何使用 golang.org/x/time/rate 包在 Go 中實現它們。將速率限制納入您的應用程序，以構建能夠高效處理不同流量水平的彈性系統。
當然可以使用第三方庫來實現，比如說：go.uber.org/ratelimit。
本文鏈接：http://www.www897cc.com/showinfo-26-15601-0.htmlGo中的流量限制：有效控制流量
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： Go 中的類型斷言與靜態轉換
下一篇： 負載均衡器的八大使用場景介紹
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號