Sentinel熱點規(guī)則示例詳解分析
概念
- 商品 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 類型,可選項(默認為EntryType.OUT)blockHandler/blockHandlerClass:blockHandler對應處理BlockException的函數(shù)名稱,可選項。blockHandler 函數(shù)訪問范圍需要是public,返回類型需要與原方法相匹配,參數(shù)類型需要和原方法相匹配并且最后加一個額外的參數(shù),類型為BlockException。blockHandler 函數(shù)默認需要和原方法在同一個類中。若希望使用其他類的函數(shù),則可以指定blockHandlerClass為對應的類的Class對象,注意對應的函數(shù)必需為 static 函數(shù),否則無法解析。fallbac/fallbackClass:fallback 函數(shù)名稱,可選項,用于在拋出異常的時候提供 fallback 處理邏輯。fallback 函數(shù)可以針對所有類型的異常(除了exceptionsToIgnore里面排除掉的異常類型)進行處理。fallback 函數(shù)簽名和位置要求:
1.返回值類型必須與原函數(shù)返回值類型一致;
2.方法參數(shù)列表需要和原函數(shù)一致,或者可以額外多一個 Throwable 類型的參數(shù)用于接收對應的異常。
3.fallback 函數(shù)默認需要和原方法在同一個類中。若希望使用其他類的函數(shù),則可以指定
fallbackClass 為對應的類的 Class 對象,注意對應的函數(shù)必需為 static 函數(shù),否則無法解析。
defaultFallback(since 1.6.0):默認的 fallback 函數(shù)名稱,可選項,通常用于通用的 fallback 邏輯(即可以用于很多服務或方法)。默認 fallback 函數(shù)可以針對所有類型的異常(除了exceptionsToIgnore里面排除掉的異常類型)進行處理。若同時配置了 fallback 和 defaultFallback,則只有 fallback 會生效。defaultFallback 函數(shù)簽名要求:
1.返回值類型必須與原函數(shù)返回值類型一致;
2.方法參數(shù)列表需要為空,或者可以額外多一個 Throwable 類型的參數(shù)用于接收對應的異常。
3.defaultFallback 函數(shù)默認需要和原方法在同一個類中。若希望使用其他類的函數(shù),
則可以指定 fallbackClass 為對應的類的 Class 對象,注意對應的函數(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ī)則控制時的默認處理方案
* fallback: 自定義業(yè)務出錯時默認處理方案
* defaultFallback: 業(yè)務錯誤時的默認處理方案
*/
@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 "當前請求被流控!";
}
if(e instanceof DegradeException){
return "當前請求被降級!";
}
if(e instanceof ParamFlowException){
return "當前請求被熱點參數(shù)限流!";
}
return "當前訪問人數(shù)太多,請稍后再試!";
}
public String fallback(Integer id){
return "fallback函數(shù)處理的異常!";
}
public String defaultFallback(){
return "默認的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,
界面會返回默認的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,
界面會返回默認的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ù)索引對應參數(shù)的類型。比如我們訪問:http://localhost:8990/test/hello?id=?值得就是id的類型
- 參數(shù)值:我們上面寫的是2,意思是只對id=2這個進行熱點參數(shù)限流,其余的放過;
- 限流閾值:在統(tǒng)計時長內(nèi)超過設定的閾值就會被限流
我們在瀏覽器訪問http://localhost:8990/test/hello?id=1可以發(fā)現(xiàn)是沒有問題的,沒有被限流。
但是當訪問http://localhost:8990/test/hello?id=2時就會被限流。
如圖所示

熱點限流的高級選項中可以添加多個參數(shù)例外項
以上就是Sentinel熱點規(guī)則示例詳解分析的詳細內(nèi)容,更多關(guān)于Sentinel熱點規(guī)則的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Java?axios與spring前后端分離傳參規(guī)范總結(jié)
這篇文章主要介紹了Java?axios與spring前后端分離傳參規(guī)范總結(jié),文章圍繞主題展開詳細的內(nèi)容介紹,具有一定的參考價值,需要的朋友可以參考一下2022-08-08
springboot+jsonp解決前端跨域問題小結(jié)
這篇文章主要介紹了springboot+jsonp解決前端跨域問題小結(jié),小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2018-06-06
基于spring boot實現(xiàn)一個全局異常處理器
在項目開發(fā)中,我們可以基于spring boot提供的切面特性,來很輕松的實現(xiàn)全局異常的處理,所以本文主要為大家介紹了如何基于spring boot實現(xiàn)一個全局異常處理器,有需要的可以參考下2023-09-09
java 使用HttpURLConnection發(fā)送數(shù)據(jù)簡單實例
這篇文章主要介紹了java 使用HttpURLConnection發(fā)送數(shù)據(jù)簡單實例的相關(guān)資料,需要的朋友可以參考下2017-06-06

