概念

• 商品 ID 為參數(shù)，統(tǒng)計一段時間內(nèi)最常購買的商品 ID 并進行限制
• 用戶 ID 為參數(shù)，針對一段時間內(nèi)頻繁訪問的用戶 ID 進行限制

熱點參數(shù)限流會統(tǒng)計傳入?yún)?shù)中的熱點參數(shù)，并根據(jù)配置的限流閾值與模式，對包含熱點參數(shù)的資源調(diào)用進行限流。

熱點參數(shù)限流可以看做是一種特殊的流量控制，僅對包含熱點參數(shù)的資源調(diào)用生效。

Sentinel 利用 LRU 策略統(tǒng)計最近最常訪問的熱點參數(shù)，結(jié)合令牌桶算法來進行參數(shù)級別的流控。

使用熱單參數(shù)限流式不能使用資源路徑，必須要使用資源名的方式。

Sentinel提供了@SentinelResource 注解用于定義資源

@SentinelResource

@SentinelResource 用于定義資源，并提供可選的異常處理和 fallback 配置項。

@SentinelResource 注解包含以下屬性：

• value：資源名稱，必需項（不能為空）
• entryType：entry 類型，可選項（默認(rèn)為 EntryType.OUT）
• blockHandler / blockHandlerClass: blockHandler 對應(yīng)處理 BlockException 的函數(shù)名稱，可選項。blockHandler 函數(shù)訪問范圍需要是 public，返回類型需要與原方法相匹配，參數(shù)類型需要和原方法相匹配并且最后加一個額外的參數(shù)，類型為 BlockException。blockHandler 函數(shù)默認(rèn)需要和原方法在同一個類中。若希望使用其他類的函數(shù)，則可以指定 blockHandlerClass 為對應(yīng)的類的 Class 對象，注意對應(yīng)的函數(shù)必需為 static 函數(shù)，否則無法解析。
• fallbac/fallbackClass：fallback 函數(shù)名稱，可選項，用于在拋出異常的時候提供 fallback 處理邏輯。fallback 函數(shù)可以針對所有類型的異常（除了exceptionsToIgnore里面排除掉的異常類型）進行處理。fallback 函數(shù)簽名和位置要求：
  

1.返回值類型必須與原函數(shù)返回值類型一致；
2.方法參數(shù)列表需要和原函數(shù)一致，或者可以額外多一個 Throwable 類型的參數(shù)用于接收對應(yīng)的異常。

3.fallback 函數(shù)默認(rèn)需要和原方法在同一個類中。若希望使用其他類的函數(shù)，則可以指定

 fallbackClass 為對應(yīng)的類的 Class 對象，注意對應(yīng)的函數(shù)必需為 static 函數(shù)，否則無法解析。

• defaultFallback（since 1.6.0）：默認(rèn)的 fallback 函數(shù)名稱，可選項，通常用于通用的 fallback 邏輯（即可以用于很多服務(wù)或方法）。默認(rèn) fallback 函數(shù)可以針對所有類型的異常（除了exceptionsToIgnore里面排除掉的異常類型）進行處理。若同時配置了 fallback 和 defaultFallback，則只有 fallback 會生效。defaultFallback 函數(shù)簽名要求：

1.返回值類型必須與原函數(shù)返回值類型一致；

2.方法參數(shù)列表需要為空，或者可以額外多一個 Throwable 類型的參數(shù)用于接收對應(yīng)的異常。

3.defaultFallback 函數(shù)默認(rèn)需要和原方法在同一個類中。若希望使用其他類的函數(shù)，

則可以指定 fallbackClass 為對應(yīng)的類的 Class 對象，注意對應(yīng)的函數(shù)必需為 static 函數(shù)，否則無法解析。

• exceptionsToIgnore（since 1.6.0）：用于指定哪些異常被排除掉，不會計入異常統(tǒng)計中，也不會進入 fallback 邏輯中，而是會原樣拋出。

注意：注解方式埋點不支持 private 方法特別地，若 blockHandler 和 fallback 都進行了配置，

則被限流降級而拋出 BlockException 時只會進入 blockHandler 處理邏輯。

若未配置 blockHandler、fallback 和 defaultFallback，

則被限流降級時會將 BlockException 直接拋出

（若方法本身未定義 throws BlockException 則會被 JVM 包裝一層 UndeclaredThrowableException）。

小試牛刀

TestController.java

我們將之前的TestController中的/test/hello方法做以下處理：

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeException;
import com.alibaba.csp.sentinel.slots.block.flow.FlowException;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
 * @Author Christy
 * @Date 2021/8/6 10:17
 **/
@RestController
@RequestMapping("/test")
public class TestController {
    private static final Logger log = LoggerFactory.getLogger(TestController.class);
    /**
     * @SentinelResource: 代表這是一個sentinel資源
     * value: 資源名稱
     * blockHandler: 使用sentinel進行不同規(guī)則控制時的默認(rèn)處理方案
     * fallback: 自定義業(yè)務(wù)出錯時默認(rèn)處理方案
     * defaultFallback: 業(yè)務(wù)錯誤時的默認(rèn)處理方案
     */
    @RequestMapping("/hello")
    @SentinelResource(value = "hello",blockHandler = "blockHandler",fallback = "fallback",defaultFallback = "defaultFallback")
    public String sayHello(Integer id){
        log.info("Hello, Sentinel!");
        if(id < 0){
            throw new RuntimeException();
        }
        return "Hello, Sentinel!";
    }
    public String blockHandler(Integer id, BlockException e){
        if(e instanceof FlowException){
            return  "當(dāng)前請求被流控！";
        }
        if(e instanceof DegradeException){
            return  "當(dāng)前請求被降級！";
        }
        if(e instanceof ParamFlowException){
            return  "當(dāng)前請求被熱點參數(shù)限流!";
        }
        return "當(dāng)前訪問人數(shù)太多，請稍后再試！";
    }
    public String fallback(Integer id){
        return "fallback函數(shù)處理的異常!";
    }
   public String defaultFallback(){
        return "默認(rèn)的fallback函數(shù)處理的異常！";
    }
    @RequestMapping("/bye")
    public String sayBye(){
        log.info("Bye, Sentinel!");
        return "Bye, Sentinel!";
    }
}

defaultFallback

首先我們來試下沒有自定義fallback的情況，我們將TestControler中的/test/hello修改如下：

@RequestMapping("/hello")
@SentinelResource(value = "hello",blockHandler = "blockHandler",defaultFallback = "defaultFallback")
public String sayHello(Integer id){
  log.info("Hello, Sentinel!");
  if(id < 0){
    throw new RuntimeException();
  }
  return "Hello, Sentinel!";
}

然后我們啟動項目，在瀏覽器中訪問http://localhost:8990/test/hello?id=-1，

界面會返回默認(rèn)的fallback函數(shù)處理的異常！如下圖所示：

fallback

同樣的方式我們將TestControler中的/test/hello修改如下

@RequestMapping("/hello")
@SentinelResource(value = "hello",blockHandler = "blockHandler",fallback = "fallback",defaultFallback = "defaultFallback")
public String sayHello(Integer id){
  log.info("Hello, Sentinel!");
  if(id < 0){
    throw new RuntimeException();
  }
  return "Hello, Sentinel!";
}

我們再次啟動項目，在瀏覽器中訪問http://localhost:8990/test/hello?id=-1，

界面會返回默認(rèn)的fallback函數(shù)處理的異常！

如下圖所示：

流量控制

我們在Sentinel中的流控規(guī)則中新增一個規(guī)則，

如下所示：

然后我們在瀏覽器中訪問http://localhost:8990/test/hello，

發(fā)現(xiàn)結(jié)果被流控

熔斷降級

我們刪除上面的流控規(guī)則，按照下圖所示新增一個熔斷規(guī)則，

如圖所示：

然后我們在瀏覽器中訪問http://localhost:8990/test/hello?id=-1，

發(fā)現(xiàn)結(jié)果被降級

熱點參數(shù)限流

同樣的我們刪除上面的熔斷規(guī)則，按照下圖所示新增一個熱點參數(shù)規(guī)則。

如圖所示：

然后我們在瀏覽器中訪問http://localhost:8990/test/hello?id=-1

發(fā)現(xiàn)結(jié)果被熱點參數(shù)限流

高級選項

在熱點規(guī)則的底部有高級選項功能，點開它如下圖所示：

• 參數(shù)類型：是上述參數(shù)索引對應(yīng)參數(shù)的類型。比如我們訪問：http://localhost:8990/test/hello?id=?值得就是id的類型
• 參數(shù)值：我們上面寫的是2，意思是只對id=2這個進行熱點參數(shù)限流，其余的放過；
• 限流閾值：在統(tǒng)計時長內(nèi)超過設(shè)定的閾值就會被限流

我們在瀏覽器訪問http://localhost:8990/test/hello?id=1可以發(fā)現(xiàn)是沒有問題的，沒有被限流。

但是當(dāng)訪問http://localhost:8990/test/hello?id=2時就會被限流。

如圖所示

熱點限流的高級選項中可以添加多個參數(shù)例外項

以上就是Sentinel熱點規(guī)則示例詳解分析的詳細(xì)內(nèi)容，更多關(guān)于Sentinel熱點規(guī)則的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論