快捷導(dǎo)航

Sentinel流控規(guī)則實現(xiàn)限流保護詳解

更新時間：2023年05月20日 10:29:34 作者：小白的救贖

這篇文章主要介紹了Sentinel流控規(guī)則實現(xiàn)限流保護，Sentinel是一個分布式系統(tǒng)的流量控制組件，它可以實現(xiàn)限流，流控，降級等功能，提高系統(tǒng)的穩(wěn)定性和可靠性，感興趣想要詳細了解可以參考下文

概念

資源名：唯一名稱，默認請求路徑

針對來源：Sentinel可以針對調(diào)用者進行限流，填寫微服務(wù)名，默認default (不區(qū)分來源)

閱值類型單機閱值：
QPS(每秒鐘的請求數(shù)量)：當調(diào)用該api的QPS達到值的時候，進行限流
線程數(shù)：當調(diào)用該api的線程數(shù)達到闊值的時候，進行限流

是否集群：不需要集群

流控模式：
直接：api達到限流條件時，直接限流
關(guān)聯(lián)：當關(guān)聯(lián)的資源達到聞值時，就限流自己
鏈路：只記錄指定鏈路上的流量(指定資源從入口資源進來的流量，如果達到闊值，就進行限流)[api級別的針對來源]
流控效果：
快速失?。褐苯邮?，拋異常
Warm Up(預(yù)熱)：根據(jù)codeFactor (冷加載因子，默認3) 的值，從聞值/codeFactor，經(jīng)過預(yù)熱時長，才達到設(shè)置的QPS閩值
排隊等待：勻速排隊，讓請求以勻速的速度通過，闊值類型必須設(shè)置為QPS，否則無效

流控規(guī)則

直接（默認）

控制層方法如下：

@RestController
public class SentinelController {
    @GetMapping("/testA")
    public String testA(){
        return "Sentinel testA run";
    }
    @GetMapping("/testB")
    public String testB(){
        return "Sentinel testB run";
    }
}

QPS+快速失敗

通過地址欄輸入：localhost:8401/testA

測試發(fā)現(xiàn)當每秒刷新頁面的次數(shù)大于1則會彈出以下頁面（表示限流），否則正常

線程數(shù)+直接控制

而直接控制的線程數(shù)設(shè)置為1表示如果超過一個頁面訪問此連接那就會限流否則正常。這里就不再對線程數(shù)做測試了

QPS+Warming up

Warm Up（RuleConstant.CONTROL_BEHAVIOR_WARM_UP）方式，即預(yù)熱/冷啟動方式。當系統(tǒng)流量長期處于低水位的情況下，當流量突然增加時，直接把系統(tǒng)拉升到高水位可能瞬間把系統(tǒng)壓垮。通過"冷啟動"，讓通過的流量緩慢增加，在一定時間內(nèi)逐漸增加到閾值上限，給冷系統(tǒng)一個預(yù)熱的時間，避免冷系統(tǒng)被壓垮。

舉例：當預(yù)熱時長=8，QPS單機閾值=3

當并發(fā)請求到達的時候，實際的單機閾值是：QPS單機閾值配置 / coldFactoer= 3 / 3 =1,也就是每秒鐘只能一個請求訪問成功。
預(yù)熱時長為8秒，實際的單機閾值在8秒鐘內(nèi)逐步由1 -> 2 -> 3,最終等于QPS單機閾值配置。
這里有一個注意點是QPS單機閾值一定要大于或等于3否則會一直請求不成功

QPS+排隊等待

排隊等待方式會嚴格的控制請求通過的間隔時間，就是讓請求勻速的通過，對應(yīng)的是漏桶算法。

言簡意賅：QPS對應(yīng)每秒處理的線程為1，超時時間表示超過10s則不接受其他線程的請求。也就是說將超時時間(ms) / 單機閾值(s/個) = 線程通過數(shù)。

關(guān)聯(lián)

使用了testA關(guān)聯(lián)testB那么當二者其一越界了即二者其一或者觸犯了閾值規(guī)則，那么規(guī)則的時長內(nèi)即QPS內(nèi)testA是無法訪問的，換句通俗易懂的就是：其中一個犯錯，testA就得扛鍋。但要注意的是不是永久失效，只是閾值內(nèi)失效。