當(dāng)前位置：首頁 > 科技 > 軟件

面試官：Sentinel是如何實(shí)現(xiàn)限流的？

來源：責(zé)編：時(shí)間：2024-02-04 17:23:26 227觀看

導(dǎo)讀它的目的是確保系統(tǒng)能夠在承受范圍內(nèi)提供穩(wěn)定和可靠的服務(wù)，避免因過多的請求而導(dǎo)致系統(tǒng)崩潰、資源耗盡或響應(yīng)延遲過高的情況發(fā)生。在 Sentinel 中，實(shí)現(xiàn)限流的方法有以下兩種：通過代碼方法實(shí)現(xiàn)限流。通過 Sentinel 控制臺

它的目的是確保系統(tǒng)能夠在承受范圍內(nèi)提供穩(wěn)定和可靠的服務(wù)，避免因過多的請求而導(dǎo)致系統(tǒng)崩潰、資源耗盡或響應(yīng)延遲過高的情況發(fā)生。

在 Sentinel 中，實(shí)現(xiàn)限流的方法有以下兩種：

通過代碼方法實(shí)現(xiàn)限流。
通過 Sentinel 控制臺設(shè)置實(shí)現(xiàn)限流。

一、通過代碼實(shí)現(xiàn)限流

通過代碼實(shí)現(xiàn)限流需要以下兩步方可實(shí)現(xiàn)：

定義資源

通過代碼定義資源。
通過注解定義資源。

定義限流規(guī)則

具體實(shí)現(xiàn)如下。

1、定義資源

定義資源可以通過代碼方式或注解方式來實(shí)現(xiàn)，具體實(shí)現(xiàn)如下。

（1）通過代碼定義資源

可以通過代碼的的方式 SphU.entry("resourceName") 來定義資源，具體實(shí)現(xiàn)代碼如下：

@RequestMapping("/getuser")public String getUser() {    try (Entry entry = SphU.entry("getuser")) {        // 被保護(hù)邏輯        return "User";    } catch (Exception e) {        // 限流之后的業(yè)務(wù)邏輯        return "被限流了";    }}

PS：SphU 是 Sentinel Protection Hotspot Util 的縮寫，Sentinel 熱點(diǎn)保護(hù)工具類。

（2）通過注解方式定義資源

通過注解 @SentinelResource 也可以實(shí)現(xiàn)資源的定義，如下代碼所示：

// 定義資源和限流后觸發(fā)的方法@SentinelResource(value = "resourceName", blockHandler = "myBlockHandler")@RequestMapping("/getnamebyid")public String getNameById(Integer id) {return id + "-lei";}// 限流后觸發(fā)的方法public String myBlockHandler(Integer id, BlockException blockException) {    String msg = "Do myBlockHandler method.";    System.out.println(msg);    return msg;}

其中，value 屬性定義的資源名稱，blockHandler 定義的是原方法被限流/降級/系統(tǒng)保護(hù)之后執(zhí)行的方法。

注意事項(xiàng)

定義的限流方法 myBlockHandler 必須和原方法的返回值、參數(shù)保持一致；
限流方法必須添加 BlockException 參數(shù)，不然會(huì)因?yàn)檎也坏胶线m的限流后執(zhí)行方法，而提示以下錯(cuò)誤：

PS：其中“csp”表示 Concurrent Service Protection，即并發(fā)服務(wù)保護(hù)。

@SentinelResource 注解屬性說明：

value：資源名稱，必需項(xiàng)（不能為空）。
entryType：資源調(diào)用的流量類型：入口流量（EntryType.IN）和出口流量（EntryType.OUT），注意系統(tǒng)規(guī)則只對 IN 生效。
blockHandler/blockHandlerClass: 限流和熔斷時(shí)執(zhí)行 BlockException 所對應(yīng)的方法名。
fallback/fallbackClass：非 BlockException 時(shí)，其他非限流、非熔斷時(shí)異常對應(yīng)的方法。
exceptionsToIgnore：用于指定哪些異常被排除掉，不會(huì)計(jì)入異常統(tǒng)計(jì)中，也不會(huì)進(jìn)入 fallback 邏輯中，而是會(huì)原樣拋出。

注：1.6.0 之前的版本 fallback 函數(shù)只針對熔斷降級異常（DegradeException）進(jìn)行處理，不能針對業(yè)務(wù)異常進(jìn)行處理。

2、定義限流規(guī)則

在 Spring Boot 項(xiàng)目中，只需要將限流規(guī)則添加到項(xiàng)目啟動(dòng)時(shí)執(zhí)行即可，如下代碼所示：

public static void main(String[] args) {    SpringApplication.run(SentinelDemoApplication.class, args);    // 加載限流規(guī)則    initFlowRules();}

而限流規(guī)則定義如下：

private static void initFlowRules() {    List<FlowRule> rules = new ArrayList<>();    FlowRule rule = new FlowRule();    rule.setResource("resourceName"); // 資源名稱    rule.setGrade(RuleConstant.FLOW_GRADE_QPS); // 根據(jù) QPS 限流    rule.setCount(1); // QPS 閾值【每秒只允許通過一個(gè)請求】    rule.setStrategy(RuleConstant.STRATEGY_DIRECT); // 調(diào)用關(guān)系限流策略【非必須設(shè)置】    rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT); // 流控效果【非必須設(shè)置】    rule.setClusterMode(false); // 是否集群限流【非必須設(shè)置，默認(rèn)非集群】    rules.add(rule);    FlowRuleManager.loadRules(rules);}

其中：

setStrategy：設(shè)置調(diào)用關(guān)系限流策略，包含的值有：

直接（RuleConstant._STRATEGY_DIRECT_）【默認(rèn)值】
鏈路（RuleConstant._STRATEGY_RELATE_）
關(guān)聯(lián)（RuleConstant._STRATEGY_CHAIN_）

setControlBehavior：設(shè)置流控效果，包含的值有：
直接拒絕（RuleConstant._CONTROL_BEHAVIOR_DEFAULT_）【默認(rèn)值】
冷啟動(dòng)（RuleConstant._CONTROL_BEHAVIOR_WARM_UP_）
勻速啟動(dòng)（RuleConstant._CONTROL_BEHAVIOR_RATE_LIMITER_）
冷啟動(dòng)+勻速啟動(dòng)（RuleConstant._CONTROL_BEHAVIOR_WARM_UP_RATE_LIMITER_）

二、通過控制臺實(shí)現(xiàn)限流

Sentinel 還可以使用控制臺的方式進(jìn)行限流，不過默認(rèn)情況下限流規(guī)則是保存在內(nèi)存中，所以重啟之后規(guī)則會(huì)丟失，默認(rèn)情況下下的推送流程如下：

它的實(shí)現(xiàn)步驟如下：

下載并運(yùn)行 Sentinel Dashboard（控制臺）。
在程序中加入并配置 Sentinel Dashboard。
在 Sentinel Dashboard 配置限流/熔斷等規(guī)則。
驗(yàn)證效果。

1、下載并運(yùn)行Sentinel控制臺

我們可以從 Sentinel 官方倉庫下載最新版本的控制臺 jar 包，訪問地址：https://github.com/alibaba/Sentinel/releases

使用如下命令啟動(dòng)控制臺：

java -jar sentinel-dashboard.jar --server.port=18080

從 Sentinel 1.6.0 起，Sentinel 控制臺引入基本的登錄功能，默認(rèn)用戶名和密碼都是 sentinel。可以參考鑒權(quán)模塊文檔配置用戶名和密碼，命令如下：

java -Dserver.port=18080 -Dsentinel.dashboard.auth.username=sentinel -Dsentinel.dashboard.auth.password=123456 -jar sentinel-dashboard.jar

Sentinel 控制臺啟動(dòng)時(shí)的可選配置項(xiàng)：

配置項(xiàng)	默認(rèn)值	描述
server.port	8080	指定端口
csp.sentinel.dashboard.server	localhost:8080	指定地址
project.name	-	指定程序的名稱
sentinel.dashboard.auth.username	sentinel	Dashboard 登錄賬號（需要版本1.6+）
sentinel.dashboard.auth.password	sentinel	Dashboard 登錄密碼（需要版本1.6+）
server.servlet.session.timeout	30分鐘	登錄 Session 過期時(shí)間（需要版本1.6+）
配置為 7200 表示 7200 秒
配置為 60m 表示 60 分鐘

2、在程序中加入并配置 Sentinel

在需要進(jìn)行流控的項(xiàng)目中加入 Sentinel 依賴：

<dependency>  <groupId>com.alibaba.cloud</groupId>  <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>

在項(xiàng)目中配置 Sentinel Dashboard 地址：

spring:  application:    name: sentinel-dashboard-demo  cloud:    sentinel:      transport:        dashboard: localhost:18080        client-ip: 127.0.0.1         port: 8721        heartbeat-interval-ms: 10000

其中，只有 dashboard 是必輸項(xiàng)，其他的都可以省略，他們的含義如下：

dashboard：sentinel 控制臺地址。
client-ip：當(dāng)前客戶端 IP，不設(shè)置自動(dòng)選擇一個(gè) IP 注冊。
port：與 sentinel 通訊的端口，如不設(shè)置，會(huì)從 8719 開始掃描，依次 +1，直到找到未被占用的接口。
heartbeat-interval-ms：心跳發(fā)送周期，默認(rèn)值是 10s。

3、設(shè)置規(guī)則

4、新增限流規(guī)則

參數(shù)說明：

針對來源：Sentinel 可以針對調(diào)用者進(jìn)行限流，填寫具體微服務(wù)名時(shí)，指定對此微服務(wù)進(jìn)行限流，默認(rèn)值為 default（不區(qū)分來源，全部限制）。
閾值類型/單機(jī)閾值：用于限制和控制流量的一種度量標(biāo)準(zhǔn)的類型，可以為 QPS（Queries Per Second，每秒請求數(shù)）也可以為“并發(fā)線程數(shù)”。

QPS：每秒請求達(dá)到此值開始限流。
并發(fā)線程數(shù)：請求此資源的線程達(dá)到某個(gè)值時(shí)限流。每個(gè)請求分配一個(gè)線程，當(dāng)請求執(zhí)行時(shí)間長時(shí)，很快就會(huì)觸發(fā)限流，相反如果線程執(zhí)行速度快，那么限流觸發(fā)就會(huì)概率就會(huì)比較小。

流控模式：流量控制模式。
直接：接口達(dá)到限流條件時(shí)，直接限流。
關(guān)聯(lián)：當(dāng)關(guān)聯(lián)的資源達(dá)到閾值時(shí)，就限流自己。
鏈路：指定資源從入口資源進(jìn)來的流量，如果達(dá)到閾值，就進(jìn)行限流。
流控效果：流量控制效果。
快速失敗：該方式是默認(rèn)的流量控制方式，比如 QPS 超過任意規(guī)則的閾值后，新的請求就會(huì)被立即拒絕，拒絕方式為拋出 FlowException。這種方式適用于對系統(tǒng)處理能力確切已知的情況下，比如通過壓測確定了系統(tǒng)的準(zhǔn)確水位時(shí)。
排隊(duì)等待（也叫勻速通過）：排隊(duì)等待會(huì)嚴(yán)格控制請求通過的間隔時(shí)間，讓請求穩(wěn)定且勻速的通過，可以用來處理間隔性突發(fā)的高流量。例如搶票軟件，在某一秒或者一分鐘內(nèi)有大量的請求到來，而接下來的一段時(shí)間里處于空閑狀態(tài)，我們希望系統(tǒng)能夠在接下來的空余時(shí)間里也能出去這些請求，而不是直接拒絕。在設(shè)置排隊(duì)等待時(shí)，需要填寫超時(shí)時(shí)間。
Warm Up：此項(xiàng)叫做預(yù)熱或者冷啟動(dòng)方式，此模式主要是防止流量突然增加時(shí)，直接把系統(tǒng)拉升到高水位可能瞬間把系統(tǒng)壓垮，通過"冷啟動(dòng)"，讓通過的流量緩慢增加，在一定時(shí)間內(nèi)逐漸增加到閾值上限，給冷系統(tǒng)一個(gè)預(yù)熱的時(shí)間，避免冷系統(tǒng)被壓垮。當(dāng)使用 Warm Up 模式時(shí)，我們還需要指定啟動(dòng)時(shí)開放的 QPS 比例（DEFAULT_COLD_FACTOR，默認(rèn)值為 3，代表 30%），以及系統(tǒng)預(yù)熱所需時(shí)長（warmUpPeriodSec，默認(rèn)值是 10 秒）。

限流頁面當(dāng)“是否集群”選中之后，就會(huì)是這樣的界面：

其中最后一項(xiàng)“失敗退化”中的 Token Server 含義如下：Token Server 是 Sentinel 用于集群流量控制的關(guān)鍵組件，它負(fù)責(zé)分發(fā)令牌并進(jìn)行流量控制。當(dāng) Sentinel 的應(yīng)用程序配置為集群限流模式時(shí)，它會(huì)向 Token Server 請求令牌，然后根據(jù)令牌情況來進(jìn)行流量控制。如果 Token Server 不可用，可能是由于網(wǎng)絡(luò)故障、Token Server 實(shí)例崩潰等原因，這時(shí)候無法從 Token Server 獲取令牌。Token Server 配置的含義如下：

當(dāng)配置選項(xiàng)為"是"時(shí)：表示當(dāng) Token Server 不可用時(shí)，Sentinel 會(huì)自動(dòng)切換為單機(jī)限流模式。在單機(jī)限流模式中，Sentine 會(huì)從本地的限流規(guī)則進(jìn)行流量控制，不再依賴 Token Server。這樣可以保證即使 Token Server 不可用，也能夠繼續(xù)對流量進(jìn)行限制。
當(dāng)配置選項(xiàng)為"否"時(shí)：表示當(dāng) Token Server 不可用時(shí)，Sentinel 不會(huì)自動(dòng)切換為單機(jī)限流模式，流量控制會(huì)被暫停，即無法進(jìn)行限流，可能會(huì)導(dǎo)致服務(wù)負(fù)載過高。

本文鏈接：http://www.tebozhan.com/showinfo-26-73327-0.html面試官：Sentinel是如何實(shí)現(xiàn)限流的？

聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com

上一篇：面試官：線程通訊的方法有哪些？為什么有這么多？

下一篇： VR在工作場所的未來

標(biāo)簽：

熱門焦點(diǎn)

K60至尊版剛預(yù)熱一加Ace2 Pro正面硬剛

Redmi這邊剛?cè)缁鹑巛钡男麄髁薑60 Ultra的各種技術(shù)和硬件配置，作為競品的一加也坐不住了。一加中國區(qū)總裁李杰發(fā)布了兩條微博，表示在自家的一加Ace2上早就已經(jīng)采用了和PixelWo
6月安卓手機(jī)好評榜：魅族20 Pro蟬聯(lián)冠軍

性能榜和性價(jià)比榜之后，我們來看最后的安卓手機(jī)好評榜，數(shù)據(jù)來源安兔兔評測，收集時(shí)間2023年6月1日至6月30日，僅限國內(nèi)市場。第一名：魅族20 Pro好評率：95%5月份的時(shí)候魅族20 Pro就是
跑分安卓第一！Redmi K60至尊版8月發(fā)布！盧偉冰：目標(biāo)年度性能之王

8月5日消息，Redmi K60至尊版將于8月發(fā)布，在此前舉行的戰(zhàn)略發(fā)布會(huì)上，官方該機(jī)將搭載搭載天璣9200+處理器，安兔兔V10跑分超177萬分，是目前安卓陣營最高的分?jǐn)?shù)
三言兩語說透設(shè)計(jì)模式的藝術(shù)-簡單工廠模式

一、寫在前面工廠模式是最常見的一種創(chuàng)建型設(shè)計(jì)模式，通常說的工廠模式指的是工廠方法模式，是使用頻率最高的工廠模式。簡單工廠模式又稱為靜態(tài)工廠方法模式，不屬于GoF 23種設(shè)計(jì)
十個(gè)簡單但很有用的Python裝飾器

裝飾器（Decorators）是Python中一種強(qiáng)大而靈活的功能，用于修改或增強(qiáng)函數(shù)或類的行為。裝飾器本質(zhì)上是一個(gè)函數(shù)，它接受另一個(gè)函數(shù)或類作為參數(shù)，并返回一個(gè)新的函數(shù)或類。它們通常用
小米MIX Fold 3下月亮相：今年唯一無短板的全能折疊屏

這段時(shí)間以來，包括三星、一加、榮耀等等有不少品牌旗下的最新折疊屏旗艦都有新的進(jìn)展，其中榮耀、三星都已陸續(xù)發(fā)布了最新的折疊屏旗艦，尤其號榮耀Magi
三星電子Q2營收60萬億韓元存儲業(yè)務(wù)營收同比仍下滑超過50%

7月27日消息，據(jù)外媒報(bào)道，從三星電子所發(fā)布的財(cái)報(bào)來看，他們主要利潤來源的存儲芯片業(yè)務(wù)在今年二季度仍不樂觀，營收同比仍在大幅下滑，所在的設(shè)備解決方案
DRAM存儲器10月價(jià)格下跌，NAND閃存本月價(jià)格與上月持平

10月30日，據(jù)韓國媒體消息，自今年年初以來一直在上漲的 DRAM 存儲器的交易價(jià)格僅在本月就下跌了近 10％，此次是全年首次降價(jià)，而NAND 閃存本月價(jià)格與上月持平。市
電博會(huì)與軟博會(huì)實(shí)現(xiàn)"線下+云端"的雙線融合

在本次“電博會(huì)”與“軟博會(huì)”雙展會(huì)利好條件的加持下，既可以發(fā)揮展會(huì)拉動(dòng)人流、信息流、資金流實(shí)現(xiàn)快速交互流動(dòng)的作用，繼而推動(dòng)區(qū)域經(jīng)濟(jì)良性發(fā)展；又可以聚

AVt天堂网手机版,亚洲va久久久噜噜噜久久4399,天天综合亚洲色在线精品,亚洲一级Av无码毛片久久精品

面試官：Sentinel是如何實(shí)現(xiàn)限流的？

一、通過代碼實(shí)現(xiàn)限流

1、定義資源

（1）通過代碼定義資源

（2）通過注解方式定義資源

注意事項(xiàng)

2、定義限流規(guī)則

二、通過控制臺實(shí)現(xiàn)限流

1、下載并運(yùn)行Sentinel控制臺

2、在程序中加入并配置 Sentinel

3、設(shè)置規(guī)則

4、新增限流規(guī)則

K60至尊版剛預(yù)熱一加Ace2 Pro正面硬剛

6月安卓手機(jī)好評榜：魅族20 Pro蟬聯(lián)冠軍

跑分安卓第一！Redmi K60至尊版8月發(fā)布！盧偉冰：目標(biāo)年度性能之王

三言兩語說透設(shè)計(jì)模式的藝術(shù)-簡單工廠模式

十個(gè)簡單但很有用的Python裝飾器

小米MIX Fold 3下月亮相：今年唯一無短板的全能折疊屏

三星電子Q2營收60萬億韓元存儲業(yè)務(wù)營收同比仍下滑超過50%

DRAM存儲器10月價(jià)格下跌，NAND閃存本月價(jià)格與上月持平

電博會(huì)與軟博會(huì)實(shí)現(xiàn)"線下+云端"的雙線融合

最新推薦

猜你喜歡

熱門推薦

相關(guān)資訊