快捷導(dǎo)航

Sentinel中三種流控模式的使用詳解

更新時(shí)間：2023年08月30日 08:59:54 作者：小威要向諸佬學(xué)習(xí)呀

這篇文章主要為大家詳細(xì)介紹了Sentinel中三種流控模式（預(yù)熱模式,排隊(duì)等待模式和熱點(diǎn)規(guī)則）的使用,文中的示例代碼講解詳細(xì),感興趣的可以了解下

預(yù)熱模式

Sentinel的warm up模式是一種流量控制模式，它可以在系統(tǒng)剛啟動(dòng)的時(shí)候，通過預(yù)熱的方式逐步放開限流的限制，讓系統(tǒng)逐步達(dá)到穩(wěn)定狀態(tài)，避免系統(tǒng)啟動(dòng)時(shí)因?yàn)橄蘖鬟^于嚴(yán)格而導(dǎo)致的性能問題。

具體來說，Sentinel的warm up模式會(huì)在系統(tǒng)啟動(dòng)時(shí)，先限制一定的流量，然后逐步放開限制，直到系統(tǒng)達(dá)到一個(gè)穩(wěn)定的狀態(tài)。在逐步放開限制的過程中，Sentinel會(huì)根據(jù)系統(tǒng)的實(shí)際情況，動(dòng)態(tài)調(diào)整限制的值，以確保系統(tǒng)的穩(wěn)定性和性能。

在實(shí)際應(yīng)用中，可以通過以下代碼來使用Sentinel的warm up模式：

public class WarmUpDemo {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)規(guī)則實(shí)例
        FlowRule rule = new FlowRule();
        rule.setResource("test");
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        rule.setCount(10);
        rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);
        rule.setWarmUpPeriodSec(10);
        rule.setMaxQueueingTimeMs(500);
        // 加載規(guī)則
        List<FlowRule> rules = new ArrayList<>();
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
        // 定義資源
        Entry entry = null;
        try {
            entry = SphU.entry("test");
            // 執(zhí)行業(yè)務(wù)邏輯
            // ...
        } catch (BlockException e) {
            // 處理限流
            // ...
        } finally {
            if (entry != null) {
                entry.exit();
            }
        }
    }
}

在上述代碼中，我們創(chuàng)建了一個(gè)FlowRule實(shí)例，將其控制行為設(shè)置為CONTROL_BEHAVIOR_WARM_UP，表示使用Sentinel的warm up模式。同時(shí)，我們還設(shè)置了warmUpPeriodSec參數(shù)，表示預(yù)熱的時(shí)間為10秒。在執(zhí)行業(yè)務(wù)邏輯時(shí)，我們使用SphU.entry方法來獲取資源的Entry實(shí)例，并在try-catch-finally語句塊中處理限流和資源釋放的邏輯。

需要注意的是，使用Sentinel的warm up模式需要根據(jù)實(shí)際情況調(diào)整預(yù)熱時(shí)間和限制的值，以確保系統(tǒng)的穩(wěn)定性和性能。

排隊(duì)等待模式

Sentinel的排隊(duì)等待模式是一種流量控制模式，它可以在流量超出閾值時(shí)，將請(qǐng)求放入隊(duì)列中進(jìn)行等待，直到系統(tǒng)處理完之前的請(qǐng)求后再進(jìn)行處理。這種模式可以避免系統(tǒng)因瞬間流量過大而崩潰的情況。

在Sentinel中，排隊(duì)等待模式需要配置一個(gè)等待隊(duì)列的大小，當(dāng)流量超過閾值時(shí)，請(qǐng)求就會(huì)被放入等待隊(duì)列中。同時(shí)，還需要配置一個(gè)等待時(shí)間，如果請(qǐng)求在等待隊(duì)列中等待的時(shí)間超過了設(shè)定的等待時(shí)間，那么請(qǐng)求將會(huì)被直接拒絕。

下面是一個(gè)使用Sentinel的排隊(duì)等待模式的代碼示例：

@SentinelResource(value = "test", blockHandler = "handleBlock")
public String test() {
    // 方法實(shí)現(xiàn)
}
public String handleBlock(BlockException ex) {
    // 處理被拒絕的請(qǐng)求
    return "請(qǐng)求被拒絕，請(qǐng)稍后再試";
}

在上面的代碼中，@SentinelResource注解用于標(biāo)識(shí)該方法需要進(jìn)行流量控制。blockHandler參數(shù)指定了當(dāng)請(qǐng)求被拒絕時(shí)的處理方法。如果使用排隊(duì)等待模式，那么可以在@SentinelResource注解中添加waitQueue和maxQueueingTimeMs參數(shù)來配置等待隊(duì)列的大小和等待時(shí)間：

@SentinelResource(value = "test", blockHandler = "handleBlock", waitQueue = true, maxQueueingTimeMs = 5000)
public String test() {
    // 方法實(shí)現(xiàn)
}

在上面的代碼中，waitQueue參數(shù)設(shè)置為true表示開啟排隊(duì)等待模式，maxQueueingTimeMs參數(shù)設(shè)置為5000表示等待時(shí)間為5秒。這樣，當(dāng)請(qǐng)求被拒絕時(shí)，它就會(huì)被放入等待隊(duì)列中等待處理。如果等待時(shí)間超過了5秒，請(qǐng)求將會(huì)被直接拒絕。

熱點(diǎn)規(guī)則

Sentinel的熱點(diǎn)規(guī)則是一種特殊的限流規(guī)則，用于對(duì)系統(tǒng)中的熱點(diǎn)資源進(jìn)行限流。熱點(diǎn)資源是指在系統(tǒng)中訪問頻率較高或者訪問量較大的資源，例如某個(gè)接口、某個(gè)方法等。如果這些熱點(diǎn)資源沒有得到有效的限流控制，就容易導(dǎo)致系統(tǒng)崩潰或者性能下降。

Sentinel的熱點(diǎn)規(guī)則可以通過以下幾個(gè)方面來進(jìn)行限流控制：

參數(shù)限流：根據(jù)指定的參數(shù)進(jìn)行限流，例如根據(jù)某個(gè)接口的請(qǐng)求參數(shù)進(jìn)行限流。
URL限流：根據(jù)URL進(jìn)行限流，例如對(duì)某個(gè)接口的請(qǐng)求URL進(jìn)行限流。
IP限流：根據(jù)IP地址進(jìn)行限流，例如對(duì)某個(gè)IP地址的請(qǐng)求進(jìn)行限流。
關(guān)聯(lián)流控：根據(jù)某個(gè)關(guān)聯(lián)的資源進(jìn)行限流，例如對(duì)某個(gè)接口的關(guān)聯(lián)接口進(jìn)行限流。

Sentinel的熱點(diǎn)規(guī)則可以通過以下幾個(gè)參數(shù)進(jìn)行配置：