Sentinel熱點(diǎn)規(guī)則示例詳解分析
概念
- 商品 ID 為參數(shù)，統(tǒng)計(jì)一段時(shí)間內(nèi)最常購(gòu)買的商品 ID 并進(jìn)行限制
- 用戶 ID 為參數(shù)，針對(duì)一段時(shí)間內(nèi)頻繁訪問的用戶 ID 進(jìn)行限制
熱點(diǎn)參數(shù)限流會(huì)統(tǒng)計(jì)傳入?yún)?shù)中的熱點(diǎn)參數(shù)，并根據(jù)配置的限流閾值與模式，對(duì)包含熱點(diǎn)參數(shù)的資源調(diào)用進(jìn)行限流。
熱點(diǎn)參數(shù)限流可以看做是一種特殊的流量控制，僅對(duì)包含熱點(diǎn)參數(shù)的資源調(diào)用生效。
Sentinel 利用 LRU 策略統(tǒng)計(jì)最近最常訪問的熱點(diǎn)參數(shù)，結(jié)合令牌桶算法來進(jìn)行參數(shù)級(jí)別的流控。
使用熱單參數(shù)限流式不能使用資源路徑，必須要使用資源名的方式。
Sentinel提供了@SentinelResource 注解用于定義資源
@SentinelResource
@SentinelResource 用于定義資源，并提供可選的異常處理和 fallback 配置項(xiàng)。
@SentinelResource 注解包含以下屬性：
value：資源名稱，必需項(xiàng)（不能為空）entryType：entry 類型，可選項(xiàng)（默認(rèn)為EntryType.OUT）blockHandler/blockHandlerClass:blockHandler對(duì)應(yīng)處理BlockException的函數(shù)名稱，可選項(xiàng)。blockHandler 函數(shù)訪問范圍需要是public，返回類型需要與原方法相匹配，參數(shù)類型需要和原方法相匹配并且最后加一個(gè)額外的參數(shù)，類型為BlockException。blockHandler 函數(shù)默認(rèn)需要和原方法在同一個(gè)類中。若希望使用其他類的函數(shù)，則可以指定blockHandlerClass為對(duì)應(yīng)的類的Class對(duì)象，注意對(duì)應(yīng)的函數(shù)必需為 static 函數(shù)，否則無法解析。fallbac/fallbackClass：fallback 函數(shù)名稱，可選項(xiàng)，用于在拋出異常的時(shí)候提供 fallback 處理邏輯。fallback 函數(shù)可以針對(duì)所有類型的異常（除了exceptionsToIgnore里面排除掉的異常類型）進(jìn)行處理。fallback 函數(shù)簽名和位置要求：
1.返回值類型必須與原函數(shù)返回值類型一致；
2.方法參數(shù)列表需要和原函數(shù)一致，或者可以額外多一個(gè) Throwable 類型的參數(shù)用于接收對(duì)應(yīng)的異常。
3.fallback 函數(shù)默認(rèn)需要和原方法在同一個(gè)類中。若希望使用其他類的函數(shù)，則可以指定
fallbackClass 為對(duì)應(yīng)的類的 Class 對(duì)象，注意對(duì)應(yīng)的函數(shù)必需為 static 函數(shù)，否則無法解析。
defaultFallback（since 1.6.0）：默認(rèn)的 fallback 函數(shù)名稱，可選項(xiàng)，通常用于通用的 fallback 邏輯（即可以用于很多服務(wù)或方法）。默認(rèn) fallback 函數(shù)可以針對(duì)所有類型的異常（除了exceptionsToIgnore里面排除掉的異常類型）進(jìn)行處理。若同時(shí)配置了 fallback 和 defaultFallback，則只有 fallback 會(huì)生效。defaultFallback 函數(shù)簽名要求：
1.返回值類型必須與原函數(shù)返回值類型一致；
2.方法參數(shù)列表需要為空，或者可以額外多一個(gè) Throwable 類型的參數(shù)用于接收對(duì)應(yīng)的異常。
3.defaultFallback 函數(shù)默認(rèn)需要和原方法在同一個(gè)類中。若希望使用其他類的函數(shù)，
則可以指定 fallbackClass 為對(duì)應(yīng)的類的 Class 對(duì)象，注意對(duì)應(yīng)的函數(shù)必需為 static 函數(shù)，否則無法解析。
exceptionsToIgnore（since 1.6.0）：用于指定哪些異常被排除掉，不會(huì)計(jì)入異常統(tǒng)計(jì)中，也不會(huì)進(jìn)入 fallback 邏輯中，而是會(huì)原樣拋出。
注意：注解方式埋點(diǎn)不支持 private 方法特別地，若 blockHandler 和 fallback 都進(jìn)行了配置，
則被限流降級(jí)而拋出 BlockException 時(shí)只會(huì)進(jìn)入 blockHandler 處理邏輯。
若未配置 blockHandler、fallback 和 defaultFallback，
則被限流降級(jí)時(shí)會(huì)將 BlockException 直接拋出
（若方法本身未定義 throws BlockException 則會(huì)被 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: 代表這是一個(gè)sentinel資源
* value: 資源名稱
* blockHandler: 使用sentinel進(jìn)行不同規(guī)則控制時(shí)的默認(rèn)處理方案
* fallback: 自定義業(yè)務(wù)出錯(cuò)時(shí)默認(rèn)處理方案
* defaultFallback: 業(yè)務(wù)錯(cuò)誤時(shí)的默認(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)前請(qǐng)求被流控！";
}
if(e instanceof DegradeException){
return "當(dāng)前請(qǐng)求被降級(jí)！";
}
if(e instanceof ParamFlowException){
return "當(dāng)前請(qǐng)求被熱點(diǎn)參數(shù)限流!";
}
return "當(dāng)前訪問人數(shù)太多，請(qǐng)稍后再試！";
}
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!";
}
然后我們啟動(dòng)項(xiàng)目，在瀏覽器中訪問http://localhost:8990/test/hello?id=-1，
界面會(huì)返回默認(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!";
}
我們?cè)俅螁?dòng)項(xiàng)目，在瀏覽器中訪問http://localhost:8990/test/hello?id=-1，
界面會(huì)返回默認(rèn)的fallback函數(shù)處理的異常！
如下圖所示：
流量控制
我們?cè)赟entinel中的流控規(guī)則中新增一個(gè)規(guī)則，
如下所示：
然后我們?cè)跒g覽器中訪問http://localhost:8990/test/hello，
發(fā)現(xiàn)結(jié)果被流控
熔斷降級(jí)
我們刪除上面的流控規(guī)則，按照下圖所示新增一個(gè)熔斷規(guī)則，
如圖所示：
然后我們?cè)跒g覽器中訪問http://localhost:8990/test/hello?id=-1，
發(fā)現(xiàn)結(jié)果被降級(jí)
熱點(diǎn)參數(shù)限流
同樣的我們刪除上面的熔斷規(guī)則，按照下圖所示新增一個(gè)熱點(diǎn)參數(shù)規(guī)則。
如圖所示：
然后我們?cè)跒g覽器中訪問http://localhost:8990/test/hello?id=-1
發(fā)現(xiàn)結(jié)果被熱點(diǎn)參數(shù)限流
高級(jí)選項(xiàng)
在熱點(diǎn)規(guī)則的底部有高級(jí)選項(xiàng)功能，點(diǎn)開它如下圖所示：
- 參數(shù)類型：是上述參數(shù)索引對(duì)應(yīng)參數(shù)的類型。比如我們?cè)L問：http://localhost:8990/test/hello?id=?值得就是id的類型
- 參數(shù)值：我們上面寫的是2，意思是只對(duì)id=2這個(gè)進(jìn)行熱點(diǎn)參數(shù)限流，其余的放過；
- 限流閾值：在統(tǒng)計(jì)時(shí)長(zhǎng)內(nèi)超過設(shè)定的閾值就會(huì)被限流
我們?cè)跒g覽器訪問http://localhost:8990/test/hello?id=1可以發(fā)現(xiàn)是沒有問題的，沒有被限流。
但是當(dāng)訪問http://localhost:8990/test/hello?id=2時(shí)就會(huì)被限流。
如圖所示
熱點(diǎn)限流的高級(jí)選項(xiàng)中可以添加多個(gè)參數(shù)例外項(xiàng)
以上就是Sentinel熱點(diǎn)規(guī)則示例詳解分析的詳細(xì)內(nèi)容，更多關(guān)于Sentinel熱點(diǎn)規(guī)則的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
大伙們有沒有遇到數(shù)據(jù)亂碼的問題，真的是讓人心情煩躁，今天就來教下大家數(shù)據(jù)怎么傳輸?shù)角岸艘约皝y碼問題怎么解決的，需要的朋友可以參考一下2021-12-12
Java?axios與spring前后端分離傳參規(guī)范總結(jié)
這篇文章主要介紹了Java?axios與spring前后端分離傳參規(guī)范總結(jié)，文章圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的朋友可以參考一下2022-08-08
springboot+jsonp解決前端跨域問題小結(jié)
這篇文章主要介紹了springboot+jsonp解決前端跨域問題小結(jié)，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-06-06
這篇文章主要介紹了IntelliJ IDEA 熱部署插件JRebel的使用，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-12-12
基于spring boot實(shí)現(xiàn)一個(gè)全局異常處理器
在項(xiàng)目開發(fā)中,我們可以基于spring boot提供的切面特性,來很輕松的實(shí)現(xiàn)全局異常的處理,所以本文主要為大家介紹了如何基于spring boot實(shí)現(xiàn)一個(gè)全局異常處理器,有需要的可以參考下2023-09-09
springboot中如何去整合shrio實(shí)例分享
這篇文章主要介紹了springboot中如何去整合shrio實(shí)例分享的相關(guān)資料,需要的朋友可以參考下2023-08-08
這篇文章主要介紹了Java中的常量避免反模式的方法，需要的朋友可以參考下2015-12-12
java 使用HttpURLConnection發(fā)送數(shù)據(jù)簡(jiǎn)單實(shí)例
這篇文章主要介紹了java 使用HttpURLConnection發(fā)送數(shù)據(jù)簡(jiǎn)單實(shí)例的相關(guān)資料,需要的朋友可以參考下2017-06-06
Mybatis之動(dòng)態(tài)sql標(biāo)簽的使用
這篇文章主要介紹了Mybatis之動(dòng)態(tài)sql標(biāo)簽的使用，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-06-06
實(shí)例講解Java設(shè)計(jì)模式編程中如何運(yùn)用代理模式
這篇文章主要介紹了Java設(shè)計(jì)模式編程中如何運(yùn)用代理模式,文中舉了普通代理和強(qiáng)制代理的例子作為代理模式的擴(kuò)展內(nèi)容,需要的朋友可以參考下2016-02-02