Java17 --- SpringCloud之Sentinel

目錄

一、Sentinel下載并運行

二、創建8401微服務整合Sentinel

三、流控規則?

3.1、直接模式?

3.2、關聯模式

3.3、鏈路模式?

3.3.1、修改8401代碼?

?3.3.2、創建流控模式

3.4、Warm UP（預熱）??編輯

3.5、排隊等待

四、熔斷規則

4.1、慢調用比例?

4.2、異常比例?

4.3、異常數

?五、@SentinelResource注解

5.1、按照rest地址限流+默認限流返回??編輯

5.2、按SentinelResource資源名稱限流+自定義限流返回

5.3、按SentinelResource資源名稱限流+自定義限流返回+服務降級處理

六、熱點規則?

6.1、參數例外項?

七、授權規則??編輯

八、規則持久化

九、整合Openfeign

十、整合Gateway?

一、Sentinel下載并運行

運行命令：java -jar sentinel-dashboard-1.8.7.jar

訪問界面：

二、創建8401微服務整合Sentinel

導入相關pom及yml文件配置

<dependencies><!--SpringCloud alibaba sentinel --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency><!--nacos-discovery--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!-- 引入自己定義的api通用包 --><dependency><groupId>com.cjc.cloud</groupId><artifactId>cloud-api-commons</artifactId><version>1.0-SNAPSHOT</version></dependency><!--SpringBoot通用依賴模塊--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><!--hutool--><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId></dependency><!--lombok--><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.28</version><scope>provided</scope></dependency><!--test--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>
server:port: 8401spring:application:name: cloudalibaba-sentinel-servicecloud:nacos:discovery:server-addr: localhost:8848         #Nacos服務注冊中心地址sentinel:transport:dashboard: localhost:8080 #配置Sentinel dashboard控制臺服務地址port: 8719 #默認8719端口，假如被占用會自動從8719開始依次+1掃描,直至找到未被占用的端口

測試代碼：

@SpringBootApplication
@EnableDiscoveryClient
public class Main8401 {public static void main(String[] args) {SpringApplication.run(Main8401.class,args);}
}
@RestController
public class FlowLimitController {@GetMapping("/testA")public String testA(){return "------testA";}@GetMapping("/testB")public String testB(){return "------testB";}
}

三、流控規則?

3.1、直接模式?

?默認使用

3.2、關聯模式

3.3、鏈路模式?

3.3.1、修改8401代碼?

sentinel:transport:dashboard: localhost:8080 #配置Sentinel dashboard控制臺服務地址port: 8719 #默認8719端口，假如被占用會自動從8719開始依次+1掃描,直至找到未被占用的端口web-context-unify: false # controller層的方法對service層調用不認為是同一個根鏈路
@Service
public class FlowLimitService {@SentinelResource(value = "common")public void common(){System.out.println("------FlowLimitService come in");}
}

@Autowiredprivate FlowLimitService flowLimitService;@GetMapping("/testC")public String testC(){flowLimitService.common();return "------testC";}@GetMapping("/testD")public String testD(){flowLimitService.common();return "------testD";}

?3.3.2、創建流控模式

3.4、Warm UP（預熱）?

3.5、排隊等待

?

四、熔斷規則

4.1、慢調用比例?

?

進行壓測：

?

4.2、異常比例?

??

4.3、異常數

?

?五、@SentinelResource注解

?SentinelResource是一個流量防衛防護組件注解， 哨兵資源是一個流量防衛防護組件注解，用于指定防護資源，對配置的資源進行流量控制、熔斷降級等功能。

5.1、按照rest地址限流+默認限流返回?

測試訪問：

?

5.2、按SentinelResource資源名稱限流+自定義限流返回

測試代碼：

@GetMapping("/rateLimit/byResource")@SentinelResource(value = "byResourceSentinelResource",blockHandler = "handleException")public String byResource(){return "按資源名稱SentinelResource限流測試OK";}public String handleException(BlockException exception){return "服務不可用@SentinelResource啟動"+"\t"+"o(╥﹏╥)o";}

?

測試訪問：

?

5.3、按SentinelResource資源名稱限流+自定義限流返回+服務降級處理

 @GetMapping("/rateLimit/doAction/{p1}")@SentinelResource(value = "doActionSentinelResource",blockHandler = "doActionBlockHandler", fallback = "doActionFallback")public String doAction(@PathVariable("p1") Integer p1) {if (p1 == 0){throw new RuntimeException("p1等于零直接異常");}return "doAction";}public String doActionBlockHandler(@PathVariable("p1") Integer p1,BlockException e){log.error("sentinel配置自定義限流了:{}", e);return "sentinel配置自定義限流了";}public String doActionFallback(@PathVariable("p1") Integer p1,Throwable e){log.error("程序邏輯異常了:{}", e);return "程序邏輯異常了"+"\t"+e.getMessage();}

?

測試結果：

?

六、熱點規則?

@GetMapping("/testHotKey")@SentinelResource(value = "testHotKey",blockHandler = "dealHandler_testHotKey")public String testHotKey(@RequestParam(value = "p1",required = false) String p1,@RequestParam(value = "p2",required = false) String p2){return "------testHotKey";}public String dealHandler_testHotKey(String p1,String p2,BlockException exception){return "-----dealHandler_testHotKey";}

?

測試結果：

?

6.1、參數例外項?

?

七、授權規則?

測試訪問：

?

八、規則持久化

添加pom依賴

<!--SpringCloud ailibaba sentinel-datasource-nacos --><dependency><groupId>com.alibaba.csp</groupId><artifactId>sentinel-datasource-nacos</artifactId></dependency>

?修改yml

spring:application:name: cloudalibaba-sentinel-servicecloud:nacos:discovery:server-addr: localhost:8848         #Nacos服務注冊中心地址sentinel:transport:dashboard: localhost:8080 #配置Sentinel dashboard控制臺服務地址port: 8719 #默認8719端口，假如被占用會自動從8719開始依次+1掃描,直至找到未被占用的端口web-context-unify: false # controller層的方法對service層調用不認為是同一個根鏈路datasource:ds1:nacos:server-addr: localhost:8848dataId: ${spring.application.name}groupId: DEFAULT_GROUPdata-type: jsonrule-type: flow # com.alibaba.cloud.sentinel.datasource.RuleType

在nacos服務配置中進行配置

?

測試：

?

九、整合Openfeign

修該9001服務提供者pom及yml

 <!--openfeign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!--alibaba-sentinel--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>
spring:application:name: nacos-payment-providercloud:nacos:discovery:server-addr: localhost:8848 #配置Nacos地址sentinel:transport:dashboard: localhost:8080 #配置Sentinel dashboard控制臺服務地址port: 8719 #默認8719端口，假如被占用會自動從8719開始依次+1掃描,直至找到未被占用的端口

測試代碼：

 @GetMapping("/pay/nacos/get/{orderNo}")@SentinelResource(value = "getPayByOrderNo",blockHandler = "handlerBlockHandler")public ResultData getPayByOrderNo(@PathVariable("orderNo") String orderNo){//模擬從數據庫查詢出數據并賦值給DTOPayDTO payDTO = new PayDTO();payDTO.setId(1024);payDTO.setOrderNo(orderNo);payDTO.setAmount(BigDecimal.valueOf(9.9));payDTO.setPayNo("pay:"+ IdUtil.fastUUID());payDTO.setUserId(1);return ResultData.success("查詢返回值："+payDTO);}public ResultData handlerBlockHandler(@PathVariable("orderNo") String orderNo, BlockException exception){return ResultData.fail(ReturnCodeEnum.RC500.getCode(),"getPayByOrderNo服務不可用，" +"觸發sentinel流控配置規則"+"\t"+"o(╥﹏╥)o");}

?遠程調用測試代碼：

@FeignClient(value = "nacos-payment-provider",fallback = PayFeignSentinelApiFallBack.class)
public interface PayFeignSentinelApi {@GetMapping("/pay/nacos/get/{orderNo}")public ResultData getPayByOrderNo(@PathVariable("orderNo") String orderNo);
}
@Component
public class PayFeignSentinelApiFallBack implements PayFeignSentinelApi{@Overridepublic ResultData getPayByOrderNo(String orderNo) {return ResultData.fail(ReturnCodeEnum.RC500.getCode(),"對方服務宕機或不可用，FallBack服務降級o(╥﹏╥)o");}
}

修改80消費者yml

# 激活Sentinel對Feign的支持
feign:sentinel:enabled: true
@Resourceprivate PayFeignSentinelApi payFeignSentinelApi;@GetMapping(value = "/consumer/pay/nacos/get/{orderNo}")public ResultData getPayByOrderNo(@PathVariable("orderNo") String orderNo){return payFeignSentinelApi.getPayByOrderNo(orderNo);}
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class NFMain80 {public static void main(String[] args) {SpringApplication.run(NFMain80.class,args);}
}

啟動80服務報錯

?

修改springcloud版本，也可以下調springboot版本

?

測試結果：

?

?

十、整合Gateway?

?新建9528微服務并導入相關pom與yml

<dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><dependency><groupId>com.alibaba.csp</groupId><artifactId>sentinel-transport-simple-http</artifactId><version>1.8.6</version></dependency><dependency><groupId>com.alibaba.csp</groupId><artifactId>sentinel-spring-cloud-gateway-adapter</artifactId><version>1.8.6</version></dependency><dependency><groupId>javax.annotation</groupId><artifactId>javax.annotation-api</artifactId><version>1.3.2</version><scope>compile</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>
server:port: 9528spring:application:name: cloudalibaba-sentinel-gateway     # sentinel+gataway整合Casecloud:nacos:discovery:server-addr: localhost:8848gateway:routes:- id: pay_routh1 #pay_routh1                #路由的ID(類似mysql主鍵ID)，沒有固定規則但要求唯一，建議配合服務名uri: http://localhost:9001                #匹配后提供服務的路由地址predicates:- Path=/pay/**                      # 斷言，路徑相匹配的進行路由

測試代碼：

@SpringBootApplication
@EnableDiscoveryClient
public class Main9528 {public static void main(String[] args) {SpringApplication.run(Main9528.class,args);}
}
@Configuration
public class GatewayConfiguration {private final List<ViewResolver> viewResolvers;private final ServerCodecConfigurer serverCodecConfigurer;public GatewayConfiguration(ObjectProvider<List<ViewResolver>> viewResolversProvider, ServerCodecConfigurer serverCodecConfigurer){this.viewResolvers = viewResolversProvider.getIfAvailable(Collections::emptyList);this.serverCodecConfigurer = serverCodecConfigurer;}@Bean@Order(Ordered.HIGHEST_PRECEDENCE)public SentinelGatewayBlockExceptionHandler sentinelGatewayBlockExceptionHandler() {// Register the block exception handler for Spring Cloud Gateway.return new SentinelGatewayBlockExceptionHandler(viewResolvers, serverCodecConfigurer);}@Bean@Order(-1)public GlobalFilter sentinelGatewayFilter() {return new SentinelGatewayFilter();}@PostConstruct //javax.annotation.PostConstructpublic void doInit() {initBlockHandler();}//處理/自定義返回的例外信息private void initBlockHandler() {Set<GatewayFlowRule> rules = new HashSet<>();rules.add(new GatewayFlowRule("pay_routh1").setCount(2).setIntervalSec(1));GatewayRuleManager.loadRules(rules);BlockRequestHandler handler = new BlockRequestHandler() {@Overridepublic Mono<ServerResponse> handleRequest(ServerWebExchange exchange, Throwable t) {Map<String,String> map = new HashMap<>();map.put("errorCode", HttpStatus.TOO_MANY_REQUESTS.getReasonPhrase());map.put("errorMessage", "請求太過頻繁，系統忙不過來，觸發限流(sentinel+gataway整合Case)");return ServerResponse.status(HttpStatus.TOO_MANY_REQUESTS).contentType(MediaType.APPLICATION_JSON).body(BodyInserters.fromValue(map));}};GatewayCallbackManager.setBlockHandler(handler);}
}

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/web/15020.shtml
繁體地址，請注明出處：http://hk.pswp.cn/web/15020.shtml
英文地址，請注明出處：http://en.pswp.cn/web/15020.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

【C++】09.vector

【C++】09.vector

一、vector介紹和使用 1.1 vector的介紹 vector是表示可變大小數組的序列容器。就像數組一樣&#xff0c;vector也采用的連續存儲空間來存儲元素。也就是意味著可以采用下標對vector的元素進行訪問&#xff0c;和數組一樣高效。但是又不像數組&#xff0c;它的大小是可以動態改…
閱讀更多...
操作系統實驗四 （綜合實驗）設計簡單的Shell程序

操作系統實驗四 （綜合實驗）設計簡單的Shell程序

前言 因為是一年前的實驗&#xff0c;很多細節還有知識點我都已經遺忘了&#xff0c;但我還是盡可能地把各個細節講清楚&#xff0c;請見諒。 1.實驗目的 綜合利用進程控制的相關知識&#xff0c;結合對shell功能的和進程間通信手段的認知&#xff0c;編寫簡易shell程序&…
閱讀更多...
Excel透視表：快速計算數據分析指標的利器

Excel透視表：快速計算數據分析指標的利器

文章目錄 概述1.數據透視表基本操作1.1準備數據&#xff1a;1.2創建透視表&#xff1a;1.3設置透視表字段&#xff1a;1.4多級分類匯總和交叉匯總的差別1.5計算匯總數據&#xff1a;1.6透視表美化&#xff1a;1.7篩選和排序&#xff1a;1.8更新透視表&#xff1a; 2.數據透視-數…
閱讀更多...
【B站 heima】小兔鮮Vue3 項目學習筆記Day02

【B站 heima】小兔鮮Vue3 項目學習筆記Day02

文章目錄 Pinia1.使用2. pinia-計數器案例3. getters實現4. 異步action5. storeToRefsx 數據解構保持響應式6. pinia 調試 項目起步1.項目初始化和git管理2. 使用ElementPlus3. ElementPlus 主題色定制4. axios 基礎配置5. 路由設計6. 靜態資源初始化和 Error lens安裝7.scss自…
閱讀更多...
Github 2024-05-24 開源項目日報 Top10

Github 2024-05-24 開源項目日報 Top10

根據Github Trendings的統計，今日(2024-05-24統計)共有10個項目上榜。根據開發語言中項目的數量，匯總情況如下： 開發語言項目數量Python項目3非開發語言項目2TypeScript項目2JavaScript項目1Kotlin項目1C#項目1C++項目1Shell項目1Microsoft PowerToys: 最大化Windows系統生產…
閱讀更多...
軟件設計師備考筆記（十）：網絡與信息安全基礎知識

軟件設計師備考筆記（十）：網絡與信息安全基礎知識

文章目錄 一、網絡概述二、網絡互連硬件&#xff08;一&#xff09;網絡的設備&#xff08;二&#xff09;網絡的傳輸介質&#xff08;三&#xff09;組建網絡 三、網絡協議與標準&#xff08;一&#xff09;網絡的標準與協議&#xff08;二&#xff09;TCP/IP協議簇 四、Inter…
閱讀更多...
某神，云手機啟動？

某神，云手機啟動？

某神自從上線之后&#xff0c;熱度不減&#xff0c;以其豐富的內容和獨特的魅力吸引著眾多玩家&#xff1b; 但是隨著劇情無法跳過&#xff0c;長草期過長等原因&#xff0c;近年脫坑的玩家多之又多&#xff0c;之前米家推出了一款云某神的app&#xff0c;目標是為了減少用戶手…
閱讀更多...
RedisTemplateAPI:String

RedisTemplateAPI:String

文章目錄 ?1 String 介紹?2 命令?3 對應 RedisTemplate API???? 3.1 添加緩存???? 3.2 設置過期時間(單獨設置)???? 3.3 獲取緩存值???? 3.4 刪除key???? 3.5 順序遞增???? 3.6 順序遞減 ?4 以下是一些常用的API?5 應用場景 ?1 String 介紹 Str…
閱讀更多...
ue引擎游戲開發筆記（47）——設置狀態機解決跳躍問題

ue引擎游戲開發筆記（47）——設置狀態機解決跳躍問題

1.問題分析&#xff1a; 目前當角色起跳時&#xff0c;只是簡單的上下移動&#xff0c;空中仍然保持行走動作&#xff0c;并沒有設置跳躍動作&#xff0c;因此&#xff0c;給角色設置新的跳躍動作&#xff0c;并優化新的動作動畫。 2.操作實現&#xff1a; 1.實現跳躍不復雜&…
閱讀更多...
LabVIEW常用的電機控制算法有哪些？

LabVIEW常用的電機控制算法有哪些？

LabVIEW常用的電機控制算法主要包括以下幾種&#xff1a; 1. PID控制&#xff08;比例-積分-微分控制&#xff09; 描述&#xff1a;PID控制是一種經典的控制算法&#xff0c;通過調節比例、積分和微分三個參數來控制電機速度和位置。應用&#xff1a;廣泛應用于直流電機、步…
閱讀更多...
Java中的繼承和多態

Java中的繼承和多態

繼承 在現實世界中&#xff0c;狗和貓都是動物&#xff0c;這是因為他們都有動物的一些共有的特征。 在Java中&#xff0c;可以通過繼承的方式來讓對象擁有相同的屬性&#xff0c;并且可以簡化很多代碼 例如&#xff1a;動物都有的特征&#xff0c;有名字&#xff0c;有年齡…
閱讀更多...
Mybatis源碼剖析---第一講

Mybatis源碼剖析---第一講

Mybatis源碼剖析 基礎環境搭建 JDK8 Maven3.6.3&#xff08;別的版本也可以…&#xff09; MySQL 8.0.28 --> MySQL 8 Mybatis 3.4.6 準備jar&#xff0c;準備數據庫數據 把依賴導入pom.xml中 <properties><project.build.sourceEncoding>UTF-8</p…
閱讀更多...
Linux學習筆記:線程

Linux學習筆記:線程

Linux中的線程 什么是線程線程的使用原生線程庫創建線程線程的id線程退出等待線程join分離線程取消一個線程線程的局部存儲在c程序中使用線程使用c自己封裝一個簡易的線程庫 線程互斥(多線程)導致共享數據出錯的原因互斥鎖關鍵函數pthread_mutex_t :創建一個鎖pthread_mutex_in…
閱讀更多...
雷電預警監控系統：守護安全的重要防線

雷電預警監控系統：守護安全的重要防線

TH-LD1在自然界中&#xff0c;雷電是一種常見而強大的自然現象。它既有震撼人心的壯觀景象&#xff0c;又潛藏著巨大的安全風險。為了有效應對雷電帶來的威脅&#xff0c;雷電預警監控系統應運而生&#xff0c;成為現代社會中不可或缺的安全防護工具。 雷電預警監控系統的基本…
閱讀更多...
makefile 編寫規則

makefile 編寫規則

1.概念 1.1 什么是makefile Makefile 是一種文本文件&#xff0c;用于描述軟件項目的構建規則和依賴關系&#xff0c;通常用于自動化軟件構建過程。它包含了一系列規則和指令&#xff0c;告訴構建系統如何編譯和鏈接源代碼文件以生成最終的可執行文件、庫文件或者其他目標文件…
閱讀更多...
Node.js知識點以及案例總結

Node.js知識點以及案例總結

思考&#xff1a;為什么JavaScript可以在瀏覽器中被執行 每個瀏覽器都有JS解析引擎&#xff0c;不同的瀏覽器使用不同的JavaScript解析引擎&#xff0c;待執行的js代碼會在js解析引擎下執行 為什么JavaScript可以操作DOM和BOM 每個瀏覽器都內置了DOM、BOM這樣的API函數&#xf…
閱讀更多...
開源模型應用落地-食用指南-以最小成本博最大收獲

開源模型應用落地-食用指南-以最小成本博最大收獲

一、背景 時間飛逝&#xff0c;我首次撰寫的“開源大語言模型-實際應用落地”專欄已經完成了一半以上的內容。由衷感謝各位朋友的支持,希望這些內容能給正在學習的朋友們帶來一些幫助。 在這里&#xff0c;我想分享一下創作這個專欄的初心以及如何有效的&#xff0c;循序漸進的…
閱讀更多...
STM32F103C8T6 HC-SR04超聲波模塊——超聲波障礙物測距（HAl庫）

STM32F103C8T6 HC-SR04超聲波模塊——超聲波障礙物測距（HAl庫）

超聲波障礙物測距 一、HC-SR04超聲波模塊&#xff08;一&#xff09;什么是HC-SR04&#xff1f;&#xff08;二&#xff09;HC-SR04工作原理&#xff08;三&#xff09;如何使用HC-SR04&#xff08;四&#xff09;注意事項 二、程序編寫&#xff08;一&#xff09;CubeMX配置1.…
閱讀更多...
2024全新Langchain大模型AI應用與多智能體實戰開發

2024全新Langchain大模型AI應用與多智能體實戰開發

2024全新Langchain大模型AI應用與多智能體實戰開發 LangChain 就是一個 LLM 編程框架&#xff0c;你想開發一個基于 LLM 應用&#xff0c;需要什么組件它都有&#xff0c;直接使用就行&#xff1b;甚至針對常規的應用流程&#xff0c;它利用鏈(LangChain中Chain的由來)這個概念…
閱讀更多...
Facebook之魅：數字社交的體驗

Facebook之魅：數字社交的體驗

在當今數字化時代&#xff0c;Facebook作為全球最大的社交平臺之一&#xff0c;承載著數十億用戶的社交需求和期待。它不僅僅是一個簡單的網站或應用程序&#xff0c;更是一個將世界各地的人們連接在一起的社交網絡&#xff0c;為用戶提供了豐富多彩、無與倫比的數字社交體驗。…
閱讀更多...
最新文章

Copyright @ 2022~2023