概念
- 商品 ID 為參數(shù),統(tǒng)計(jì)一段時(shí)間內(nèi)最常購(gòu)買(mǎi)的商品 ID 并進(jìn)行限制
- 用戶 ID 為參數(shù),針對(duì)一段時(shí)間內(nèi)頻繁訪問(wèn)的用戶 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ì)最近最常訪問(wèn)的熱點(diǎn)參數(shù),結(jié)合令牌桶算法來(lái)進(jìn)行參數(shù)級(jí)別的流控。
使用熱單參數(shù)限流式不能使用資源路徑,必須要使用資源名的方式。
Sentinel提供了@SentinelResource 注解用于定義資源
@SentinelResource
@SentinelResource
用于定義資源,并提供可選的異常處理和 fallback 配置項(xiàng)。
@SentinelResource
注解包含以下屬性:
-
value
:資源名稱(chēng),必需項(xiàng)(不能為空) -
entryType
:entry 類(lèi)型,可選項(xiàng)(默認(rèn)為EntryType.OUT
) -
blockHandler
/blockHandlerClass
:blockHandler
對(duì)應(yīng)處理BlockException
的函數(shù)名稱(chēng),可選項(xiàng)。blockHandler 函數(shù)訪問(wèn)范圍需要是public
,返回類(lèi)型需要與原方法相匹配,參數(shù)類(lèi)型需要和原方法相匹配并且最后加一個(gè)額外的參數(shù),類(lèi)型為BlockException
。blockHandler 函數(shù)默認(rèn)需要和原方法在同一個(gè)類(lèi)中。若希望使用其他類(lèi)的函數(shù),則可以指定blockHandlerClass
為對(duì)應(yīng)的類(lèi)的Class
對(duì)象,注意對(duì)應(yīng)的函數(shù)必需為 static 函數(shù),否則無(wú)法解析。 -
fallbac
/fallbackClass
:fallback 函數(shù)名稱(chēng),可選項(xiàng),用于在拋出異常的時(shí)候提供 fallback 處理邏輯。fallback 函數(shù)可以針對(duì)所有類(lèi)型的異常(除了exceptionsToIgnore
里面排除掉的異常類(lèi)型)進(jìn)行處理。fallback 函數(shù)簽名和位置要求:
1.返回值類(lèi)型必須與原函數(shù)返回值類(lèi)型一致;
2.方法參數(shù)列表需要和原函數(shù)一致,或者可以額外多一個(gè) Throwable
類(lèi)型的參數(shù)用于接收對(duì)應(yīng)的異常。
3.fallback 函數(shù)默認(rèn)需要和原方法在同一個(gè)類(lèi)中。若希望使用其他類(lèi)的函數(shù),則可以指定
fallbackClass
為對(duì)應(yīng)的類(lèi)的 Class
對(duì)象,注意對(duì)應(yīng)的函數(shù)必需為 static 函數(shù),否則無(wú)法解析。
-
defaultFallback
(since 1.6.0):默認(rèn)的 fallback 函數(shù)名稱(chēng),可選項(xiàng),通常用于通用的 fallback 邏輯(即可以用于很多服務(wù)或方法)。默認(rèn) fallback 函數(shù)可以針對(duì)所有類(lèi)型的異常(除了exceptionsToIgnore
里面排除掉的異常類(lèi)型)進(jìn)行處理。若同時(shí)配置了 fallback 和 defaultFallback,則只有 fallback 會(huì)生效。defaultFallback 函數(shù)簽名要求:
1.返回值類(lèi)型必須與原函數(shù)返回值類(lèi)型一致;
2.方法參數(shù)列表需要為空,或者可以額外多一個(gè) Throwable
類(lèi)型的參數(shù)用于接收對(duì)應(yīng)的異常。
3.defaultFallback 函數(shù)默認(rèn)需要和原方法在同一個(gè)類(lèi)中。若希望使用其他類(lèi)的函數(shù),
則可以指定 fallbackClass
為對(duì)應(yīng)的類(lèi)的 Class
對(duì)象,注意對(duì)應(yīng)的函數(shù)必需為 static 函數(shù),否則無(wú)法解析。
-
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: 資源名稱(chēng) * 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)前訪問(wèn)人數(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
首先我們來(lái)試下沒(méi)有自定義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)目,在瀏覽器中訪問(wèn)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)目,在瀏覽器中訪問(wèn)http://localhost:8990/test/hello?id=-1,
界面會(huì)返回默認(rèn)的fallback函數(shù)處理的異常!
如下圖所示:
流量控制
我們?cè)赟entinel中的流控規(guī)則中新增一個(gè)規(guī)則,
如下所示:
然后我們?cè)跒g覽器中訪問(wèn)http://localhost:8990/test/hello,
發(fā)現(xiàn)結(jié)果被流控
熔斷降級(jí)
我們刪除上面的流控規(guī)則,按照下圖所示新增一個(gè)熔斷規(guī)則,
如圖所示:
然后我們?cè)跒g覽器中訪問(wèn)http://localhost:8990/test/hello?id=-1,
發(fā)現(xiàn)結(jié)果被降級(jí)
熱點(diǎn)參數(shù)限流
同樣的我們刪除上面的熔斷規(guī)則,按照下圖所示新增一個(gè)熱點(diǎn)參數(shù)規(guī)則。
如圖所示:
然后我們?cè)跒g覽器中訪問(wèn)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)開(kāi)它如下圖所示:
- 參數(shù)類(lèi)型:是上述參數(shù)索引對(duì)應(yīng)參數(shù)的類(lèi)型。比如我們?cè)L問(wèn):http://localhost:8990/test/hello?id=?值得就是id的類(lèi)型
- 參數(shù)值:我們上面寫(xiě)的是2,意思是只對(duì)id=2這個(gè)進(jìn)行熱點(diǎn)參數(shù)限流,其余的放過(guò);
- 限流閾值:在統(tǒng)計(jì)時(shí)長(zhǎng)內(nèi)超過(guò)設(shè)定的閾值就會(huì)被限流
我們?cè)跒g覽器訪問(wèn)http://localhost:8990/test/hello?id=1可以發(fā)現(xiàn)是沒(méi)有問(wèn)題的,沒(méi)有被限流。
但是當(dāng)訪問(wèn)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)注服務(wù)器之家其它相關(guān)文章!
原文鏈接:https://blog.csdn.net/bbxylqf126com/article/details/119906245