03-13、SpringCloud Alibaba第十三章，升级篇，服务降级、熔断和限流Sentinel

SpringCloud Alibaba第十三章，升级篇，服务降级、熔断和限流Sentinel

一、Sentinel概述

1、Sentinel是什么

随着微服务的流行，服务和服务之间的稳定性变得越来越重要。Sentinel 以流量为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。一句话概括：sentinel即Hystrix的替代品官网： https://sentinelguard.io/zh-cn/下载：https://github.com/alibaba/Sentinel/releases

在这里插入图片描述

2、Sentinel基本概念

2.1、资源：

资源是 Sentinel 的关键概念。它可以是 Java 应用程序中的任何内容，例如，由应用程序提供的服务，或由应用程序调
用的其它应用提供的服务，甚至可以是一段代码。在接下来的文档中，我们都会用资源来描述代码块。只要通过 Sentinel API 定义的代码，就是资源，能够被 Sentinel 保护起来。大部分情况下，可以使用方法签名，
URL，甚至服务名称作为资源名来标示资源。

2.2、规则：

围绕资源的实时状态设定的规则，可以包括流量控制规则、熔断降级规则以及系统保护规则。所有规则可以动态实时调整。

2.3、流量控制：

流量控制在网络传输中是一个常用的概念，它用于调整网络包的发送数据。然而，从系统稳定性角度考虑，在处理请求的速度
上，也有非常多的讲究。任意时间到来的请求往往是随机不可控的，而系统的处理能力是有限的。我们需要根据系统的处理能
力对流量进行控制。Sentinel 作为一个调配器，可以根据需要把随机的请求调整成合适的形状.流量控制有一下几个角度：
1、资源的调用关系，例如资源的调用链路，资源和资源之间的关系；
2、运行指标，例如 QPS、线程池、系统负载等；
3、控制的效果，例如直接限流、冷启动、排队等。

2.4、熔断降级：

降低调用链路中的不稳定资源也是 Sentinel 的使命之一。由于调用关系的复杂性，如果调用链路中的某个资源出现了不稳
定，最终会导致请求发生堆积。这个问题和 Hystrix 里面描述的问题是一样的。Sentinel 和 Hystrix 的原则是一致的: 当调用链路中某个资源出现不稳定，例如，表现为 timeout，异常比例升高的
时候，则对这个资源的调用进行限制，并让请求快速失败，避免影响到其它的资源，最终产生雪崩的效果。Sentinel和Hystrix在限制手段上，采取了不一样的方法：1、Hystrix通过线程池的方式：
Hystrix 通过线程池的方式，来对依赖进行了隔离。2、Sentinel 对这个问题采取了两种手段:
a、通过并发线程数进行限制
b、通过响应时间对资源进行降级

2.5、系统负载保护：

Sentinel 同时对系统的维度提供保护。防止雪崩，是系统防护中重要的一环。当系统负载较高的时候，如果还持续让请求
进入，可能会导致系统崩溃，无法响应。在集群环境下，网络负载均衡会把本应这台机器承载的流量转发到其它的机器上去。
如果这个时候其它的机器也处在一个边缘状态的时候，这个增加的流量就会导致这台机器也崩溃，最后导致整个集群不可用。针对这个情况，Sentinel 提供了对应的保护机制，让系统的入口流量和系统的负载达到一个平衡，保证系统在能力范围之
内处理最多的请求。

二、Sentinel控制台安装

Sentinel分为两个部分：
1、核心库
2、控制台dashboard，基于Springboot开发，打包后可直接运行，不需要Tomcat等额外的容器

下载：

https://github.com/alibaba/Sentinel/releases

运行：

Sentinel Dashboard默认的端口是8080java -jar sentinel-dashboard-1.7.0.jar

访问：

http://localhost:8080/账号：sentinel  密码：sentinel

三、Sentinel案例

3.1、初始化演示工程

创建cloudalibaba-sentinel-service-8401

<parent><artifactId>cloud_2020</artifactId><groupId>com.lee.springcloud</groupId><version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion><artifactId>cloudalibaba-sentinel-service-8401</artifactId>

POM

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>cloud_2020</artifactId><groupId>com.lee.springcloud</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>cloudalibaba-sentinel-service-8401</artifactId><dependencies><!--SpringCloud ailibaba sentinel-datasource-nacos 后续做持久化用到--><dependency><groupId>com.alibaba.csp</groupId><artifactId>sentinel-datasource-nacos</artifactId></dependency><!--SpringCloud ailibaba sentinel --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency><!--SpringCloud ailibaba nacos --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><dependency><groupId>com.lee.springcloud</groupId><artifactId>cloud-api-commons</artifactId><version>${project.version}</version></dependency><!--openfeign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!-- SpringBoot整合Web组件+actuator --><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><!--日常通用jar包配置--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId><version>4.6.3</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies></project>

application.yml

server:port: 8401spring:application:name: cloudalibaba-sentinel-servicecloud:nacos:discovery:server-addr: localhost:8848sentinel:transport:dashboard: localhost:8080port: 8719  #默认8719，假如被占用了会自动从8719开始依次+1扫描。直至找到未被占用的端口management:endpoints:web:exposure:include: '*'

主启动类：

@SpringBootApplication
@EnableDiscoveryClient
public class SentinelMain8401 {public static void main(String[] args) {SpringApplication.run(SentinelMain8401.class,args);}
}

业务类：

@Slf4j
@RestController
public class FlowLimitController {@GetMapping("/testA")public String testA(){return "=======>testA";}@GetMapping("/testB")public String testB(){return "=======>testB";}
}

测试：

1、启动nacos server、Sentinel-Dashboard、CloudAlibaba-sentinel-service-8401
2、查看sentinel控制台 http://localhost:8080/结果：空空如也
（因为：Sentinel采用的是懒加载模式）
3、浏览：http://localhost:8401/testA和http://localhost:8401/testB
4、再查看sentinel控制台 http://localhost:8080/

在这里插入图片描述

3.2、流控规则

资源新增流控，可以通过两个地方来添加：
1、簇点链路-点击”+流控“
2、流控规则-点击"新增流控规则"阈值类型：
QPS：系统每秒钟处理完成的请求次数（QPS是在请求进入应用之前就处理，线程数是在请求进入应用之后处理）

3.2.1、流控模式

流控3种模式分为：直接、关联、链路
3.2.1.1、直接

在这里插入图片描述

测试：

1、直接的配置如上
2、每秒访问一次http://localhost:8401/testA正常
3、每秒多次快速的访问http://localhost:8401/testABlocked by Sentinel (flow limiting)
(当再次恢复每秒1次的访问频率时，又可正常访问)思考：
访问频次不符合配置规则后直接显示sentinel的默认处理Blocked by Sentinel,我们如何自定义规则不匹配的情况呢？
(后续会介绍：@SentinelResource去做方法的兜底处理，类似Hystrix的@HystrixCommand)
3.2.1.2、关联
什么是关联？即当与testA相关的资源testB达到阈值时，就挂testA

在这里插入图片描述

测试：

1、配置规则如上
2、postman模拟并发密集的访问http://localhost:8401/testB
3、浏览器访问http://localhost:8401/testA结果：Blocked by Sentinel (flow limiting)（当对testB密集访问停止后，testA访问恢复正常）

在这里插入图片描述

3.2.1.3、链路

新增代码：service

@Slf4j
@Service
public class FlowLimitService {@SentinelResource("findOrder")public String findOrder(){log.info("----order----");return "order";}
}

controller

@Slf4j
@RestController
public class FlowLimitController {@Resourceprivate FlowLimitService flowLimitService;@GetMapping("/testA")public String testA(){flowLimitService.findOrder();return "=======>testA";}@GetMapping("/testB")public String testB(){flowLimitService.findOrder();return "=======>testB";}
}

配置规则：

在这里插入图片描述

1、配置规则如上
2、快速访问http://localhost:8401/testA
结果：
###############################有待确认#############
快速访问http://localhost:8401/testB
结果：
###############################有待确认#############

3.2.2、流控效果

3.2.2.1、快速失败
源码：
com.alibaba.csp.sentinel.slots.block.flow.controller.DefaultController上面写流控模式的时候已经展示了效果，不符合配置的时候，快速做出对应的反映，如
3.2.2.2、Warn Up预热
源码:
com.alibaba.csp.sentinel.slots.block.flow.controller.WarmUpController公式：
阈值除以coldFactor（默认为3），经过预热时长后才会达到阈值限流-冷启动：
当流量突然增大的时候，我们常常会希望系统从空闲状态到繁忙状态的切换的时间长一些。即如果系统在此之前长期处于空闲
的状态，我们希望处理请求的数量是缓步的增多，经过预期的时间以后，到达系统处理请求个数的最大值。Warm Up（冷启
动，预热）模式就是为了实现这个目的的。应用场景：
秒杀系统在开启的瞬间，会有很多流量上来，会把系统打死，预热方式就是为了保护系统，可以慢慢的把流量放进来。
慢慢的把阈值增长到设定的阈值、

在这里插入图片描述

配置解读：
系统初始化的阈值为10/3约等于3，即阈值刚开始为3.然后过了5秒后阈值才逐渐升到10
3.2.2.3、排队等待
源码：
com.alibaba.csp.sentinel.slots.block.flow.controller.RateLimiterController匀速排队，阈值必须设置为QPS。匀速排队会严格控制请求通过的时间间隔。也即是让请求以均匀的速度通过，对应的是漏桶算法。（类似消息队列）

在这里插入图片描述

配置解读：
/testB每秒1次请求，超过的话就排队等待。等待的超时时间是20000ms

3.3、降级规则

降级规则包括：RT、异常比例、异常数
3.3.1、RT平均响应时间
RT平均响应时间:
当1s内持续进入5个请求，对应时刻的平均响应时间均超过阈值，那么在接下的时间窗口之内，对这个方法的调用都会自动地
熔断（抛出DegradeException）.Sentinel的默认RT上限是4900ms,超出此阈值的都会算作4900ms。若需要变更此上线可以通过：
-Dcsp.sentinel.statistic.max.rt=xxx来配置

在这里插入图片描述

新增代码：

@GetMapping("/testD")
public String testD()
{try {TimeUnit.SECONDS.sleep(1);} catch (InterruptedException e) {e.printStackTrace();}log.info("testD 测试RT");return "=======>testD";
}

配置

在这里插入图片描述

测试：

在这里插入图片描述

如上JMeter创建1s中10个线程的访问去请求testD.然后再浏览器上访问http://localhost:8401/testD
结果：
Blocked by Sentinel (flow limiting)（配置中，我们希望200毫秒处理完这次任务，如果200毫秒还没处理完，在未来1s的时间窗口内，断路器打开，微服务不可用）（当我们停止JMeter测试后，没这么大访问量了，断路器关闭，微服务恢复。）
3.3.2、异常比例
异常比例：
当资源的每秒请求量>=5，并且每秒异常总数占通过量的比值超过阈值之后，资源进入降级状态，即在接下来的时间窗口之
内，对这个方法的调用都会自动返回。

在这里插入图片描述

新增代码：

@GetMapping("/testE")
public String testE()
{log.info("testE 测试RT");int age = 10/0;return "------testE";
}

配置规则：

在这里插入图片描述

测试：

JMeter压测testE,每秒10个线程浏览器访问：http://localhost:8401/testE结果：不是报错，而是Blocked by Sentinel (flow limiting)结论：
开启JMeter后，直接高并发发送请求，多次调用达到了我们的配置条件。断路器开启，微服务不可用，不再报错error而是
进入服务降级
3.3.3、异常数
异常数：
当资源近1分钟的异常数目超过阈值之后进入熔断，这个统计时间窗口是分钟级别的，若timewindow小于60s,则结束熔断状
态后仍可能再次进入熔断状态

在这里插入图片描述

新增代码：

@GetMapping("/testF")
public String testF()
{log.info("testF 测试异常数");int age = 10/0;return "------testF 测试异常数";
}

配置规则如下：

在这里插入图片描述

浏览器访问：http://localhost:8401/testF
前5次报错，走Error
之后报：Blocked by Sentinel (flow limiting)
61s后,服务熔断解除，走Error

3.4、热点KEY限流

3.4.1、普通配置
何为热点？热点即经常访问的数据。很多时候我们希望统计某个热点数据中访问频次最高的 Top K 数据，并对其访问进行限
制。

之前的case，限流出现问题后，都是Sentinel的默认提示:Blocked by Sentinel (flow limiting)

我们将使用@SentinelResource，类似Hystrix的@HystrixCommand。当方法出现问题后就找对应的兜底方法返回。

新增方法如下：

@GetMapping("/testHotKey")
@SentinelResource(value = "testHotKey",blockHandler = "deal_testHotKey")
public String testHotKey(@RequestParam(value = "p1",required = false) String p1,@RequestParam(value = "p2",required = false) String p2) {//int age = 10/0;return "------testHotKey";
}//兜底方法
public String deal_testHotKey (String p1, String p2, BlockException exception){return "------deal_testHotKey,o(╥﹏╥)o";
}

配置规则如下：

在这里插入图片描述

测试：

快速访问：http://localhost:8401/testHotKey   结果：------testHotKey快速访问：http://localhost:8401/testHotKey?p1=abc    结果：------deal_testHotKey,o(╥﹏╥)o快速访问：http://localhost:8401/testHotKey?p2=123  结果：------testHotKey快速访问：http://localhost:8401/testHotKey?p1=abc&p2=123 结果：------deal_testHotKey,o(╥﹏╥)o如果不快速访问，达不到阈值时，也只会返回------testHotKey
3.4.2、参数例外：

我们有时候期望当P1参数为某个特殊值时，它的限流值和平时不一样，假如当P1==5时，期望它的阈值为200。

在这里插入图片描述

测试：

1、浏览器快速访问：http://localhost:8401/testHotKey?p1=5 返回：------testHotKey2、浏览器快速访问：http://localhost:8401/testHotKey?p1=3 返回：------deal_testHotKey,o(╥﹏╥)o注意：参数必须是基础数据类型

3.5、系统规则

系统保护规则是从应用级别的入口流量进行控制，从单台机器的 load、CPU 使用率、平均 RT、入口 QPS 和并发线程数等
几个维度监控应用指标，让系统尽可能跑在最大吞吐量的同时保证系统整体的稳定性。系统保护规则是应用整体维度的，而不是资源维度的，并且仅对入口流量生效。入口流量指的是进入应用的流量
（EntryType.IN），比如 Web 服务或 Dubbo 服务端接收的请求，都属于入口流量。系统规则支持以下的模式:
1、load自适应：仅对 Linux/Unix-like 机器生效
系统的 load1 作为启发指标，进行自适应系统保护。当系统 load1 超过设定的启发值，且系统当前的并发线程数超过估
算的系统容量时才会触发系统保护（BBR 阶段）。系统容量由系统的 maxQps * minRt 估算得出。设定参考值一般是 
CPU cores * 2.5。2、CPU usage：
当系统 CPU 使用率超过阈值即触发系统保护（取值范围 0.0-1.0），比较灵敏。3、平均 RT：
当单台机器上所有入口流量的平均 RT 达到阈值即触发系统保护，单位是毫秒。4、并发线程数：
当单台机器上所有入口流量的并发线程数达到阈值即触发系统保护。5、入口 QPS：
当单台机器上所有入口流量的 QPS 达到阈值即触发系统保护。

3.6、@SentinelResource

@SentinelResource:类似Hystrix的@HystrixCommand,做兜底服务自定义其中blockXXXX是处理：配置违规的@blockHandlerClass 处理类@blockHandler 处理类下的处理方法fallback:处理异常，做服务降级的
exceptionToIgnore：忽略异常【程序异常和违规同时发生优先执行blockHandler】
3.6.1、按资源名称限流

新增业务类RateLimitController：

@Slf4j
@RestController
public class RateLimitController {@GetMapping("/byResource")@SentinelResource(value = "byResource",blockHandler = "handleException")public CommonResult byResource(){return new CommonResult(200,"按资源名称限流测试OK",new Payment(2020L,"serial001"));}public CommonResult handleException(BlockException exception){return new CommonResult(444,exception.getClass().getCanonicalName()+"\t 服务不可用");}}

新增配置：

在这里插入图片描述

测试：

上述配置解析：
表示1秒钟内查询次数大于1，就限流跑到我们自定义的方法1、1s访问一次：http://localhost:8401/byResource
结果：{"code":200,"message":"按资源名称限流测试OK","data":{"id":2020,"serial":"serial001"}}2、1s内快速多次访问：http://localhost:8401/byResource
结果：{"code":444,"message":"com.alibaba.csp.sentinel.slots.block.flow.FlowException\t 服务不可用","data":null}根据资源名称限流，会优先返回我们自定义的处理信息，没有自定义的返回Sentinel默认限流处理信息
3.6.2、按URL地址限流

新增方法：

@GetMapping("/rateLimit/byUrl")
@SentinelResource(value = "byUrl",blockHandler = "byUrlHandler")
public CommonResult byUrl()
{return new CommonResult(200,"按url限流测试OK",new Payment(2020L,"serial002"));
}public CommonResult byUrlHandler(BlockException exception){return new CommonResult(444,exception.getClass().getCanonicalName()+"\t 服务不可用");
}

新增配置：

在这里插入图片描述

测试：

1、1s访问一次：http://localhost:8401/rateLimit/byUrl
结果：
{"code":200,"message":"按url限流测试OK","data":{"id":2020,"serial":"serial002"}}2、1s内快速访问：http://localhost:8401/rateLimit/byUrl
结果：
Blocked by Sentinel (flow limiting)根据url地址限流返回的是Sentinel自带的默认限流处理信息
3.6.3、优化

以上一个方法新增一个对应的处理限流方法，代码冗余且和业务混杂，我们可以将处理方法提出来做单独处理

新增一个handler：

public class CustomerBlockHandler {//注意---这里必须是static且不能为privatepublic static CommonResult handlerException(BlockException exception){return new CommonResult(4444,"按客戶自定义,global handlerException----1");}public static CommonResult handlerException2(BlockException exception){return new CommonResult(4444,"按客戶自定义,global handlerException----2");}}

业务类新增方法：

@GetMapping("/rateLimit/customerBlockHandler")
@SentinelResource(value = "customerBlockHandler",blockHandlerClass = CustomerBlockHandler.class,blockHandler = "handlerException")
public CommonResult customerBlockHandler()
{return new CommonResult(200,"按客戶自定义",new Payment(2020L,"serial003"));
}

新增对应的配置，然后测试：

1s内多次快速的访问：http://localhost:8401/rateLimit/customerBlockHandler结果：
{"code":4444,"message":"按客戶自定义,global handlerException----1","data":null}

3.7、Sentinel与Ribbon和Feign的整合

3.7.1、Sentinel与Ribbon

3.7.1.1、创建cloudalibaba-provider-payment-9004和9005
<parent><artifactId>cloud_2020</artifactId><groupId>com.lee.springcloud</groupId><version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>cloudalibaba-provider-payment-9004</artifactId>

pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>cloud_2020</artifactId><groupId>com.lee.springcloud</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>cloudalibaba-provider-payment-9004</artifactId><dependencies><!--SpringCloud ailibaba nacos --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity --><groupId>com.lee.springcloud</groupId><artifactId>cloud-api-commons</artifactId><version>${project.version}</version></dependency><!-- SpringBoot整合Web组件 --><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><!--日常通用jar包配置--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>
</project>

application.yml

server:port: 9004spring:application:name: nacos-payment-providercloud:nacos:discovery:server-addr: localhost:8848 #配置Nacos地址management:endpoints:web:exposure:include: '*'

主启动类

@SpringBootApplication
@EnableDiscoveryClient//服务发现
public class PaymentMain9004 {public static void main(String[] args) {SpringApplication.run(PaymentMain9004.class,args);}
}

业务类

@Slf4j
@RestController
public class PaymentController {@Value("${server.port}")private String serverPort;public static HashMap<Long, Payment> hashMap = new HashMap<>();static{hashMap.put(1L,new Payment(1L,"aaa"));hashMap.put(2L,new Payment(2L,"bbb"));hashMap.put(3L,new Payment(3L,"ccc"));}@GetMapping(value = "/paymentSQL/{id}")public CommonResult<Payment> paymentSQL(@PathVariable("id") Long id){Payment payment = hashMap.get(id);CommonResult<Payment> result = new CommonResult(200,"from mysql,serverPort:  "+serverPort,payment);return result;}}
3.7.1.2、创建cloudalibaba-consumer-order-84
<parent><artifactId>cloud_2020</artifactId><groupId>com.lee.springcloud</groupId><version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>cloudalibaba-consumer-order-84</artifactId>

POM

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>cloud_2020</artifactId><groupId>com.lee.springcloud</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>cloudalibaba-consumer-order-84</artifactId><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency><dependency><groupId>com.lee.springcloud</groupId><artifactId>cloud-api-commons</artifactId><version>${project.version}</version></dependency><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><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies></project>

application.yml

server:port: 84spring:application:name: nacos-order-consumercloud:nacos:discovery:server-addr: localhost:8848sentinel:transport:dashboard: localhost:8080port: 8719service-url:nacos-user-service: http://nacos-payment-provider

主启动类

@EnableDiscoveryClient
@SpringBootApplication
@EnableFeignClients
public class ConsumerOrderNacos84 {public static void main(String[] args) {SpringApplication.run(ConsumerOrderNacos84.class,args);}
}

配置类

@Configuration
public class ApplicationContextConfig {@Bean@LoadBalancedpublic RestTemplate  getRestTemplate(){return new RestTemplate();}}

业务类

@Slf4j
@RestController
public class CircleBreakerController {public static final String SERVICE_URL = "http://nacos-payment-provider";@Resourceprivate RestTemplate restTemplate;@RequestMapping("/consumer/fallback/{id}")@SentinelResource(value = "fallback") //没有配置//@SentinelResource(value = "fallback",fallback = "handlerFallback") //fallback只负责业务异常//@SentinelResource(value = "fallback",blockHandler = "blockHandler") //blockHandler只负责sentinel控制台配置违规//@SentinelResource(value = "fallback", fallback = "handlerFallback", blockHandler="blockHandler",exceptionsToIgnore = {IllegalArgumentException.class})public CommonResult<Payment> fallback(@PathVariable Long id) {CommonResult<Payment> result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id, CommonResult.class,id);if (id == 4) {throw new IllegalArgumentException ("IllegalArgumentException,非法参数异常....");}else if (result.getData() == null) {throw new NullPointerException ("NullPointerException,该ID没有对应记录,空指针异常");}return result;}//fallbackpublic CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {Payment payment = new Payment(id,"null");return new CommonResult<>(444,"兜底异常handlerFallback,exception内容  "+e.getMessage(),payment);}//blockHandlerpublic CommonResult blockHandler(@PathVariable  Long id, BlockException blockException) {Payment payment = new Payment(id,"null");return new CommonResult<>(445,"blockHandler-sentinel限流,无此流水: blockException  "+blockException.getMessage(),payment);}}
3.7.1.3、测试：
1、启动nacos-server、sentinel-server、cloudalibaba-provider-payment-9004、9005、
cloudalibaba-consumer-order-84#############测试一############
2、浏览器访问：http://localhost:84/consumer/fallback/1结果：
{"code":200,"message":"from mysql,serverPort:  9004","data":{"id":1,"serial":"aaa"}}
{"code":200,"message":"from mysql,serverPort:  9005","data":{"id":1,"serial":"aaa"}}
两个结果来回切换3、浏览器访问：http://localhost:84/consumer/fallback/4结果：
Whitelabel Error Page#############测试二##############
4、consumer-84业务类放开注解@SentinelResource(value = "fallback",fallback = "handlerFallback")//fallback只负责业务异常5、浏览器访问：http://localhost:84/consumer/fallback/4结果：
{"code":444,"message":"兜底异常handlerFallback,exception内容  IllegalArgumentException,非法参数异常....","data":{"id":4,"serial":"null"}}##############测试三############
6、consumer-84业务类放开注解@SentinelResource(value = "fallback",blockHandler = "blockHandler") //blockHandler只负责sentinel控制台配置违规7、且sentinel控制台新增fallback的降级策略新增降级：资源名：fallback 策略：异常数	异常数：2 时间窗口：28、浏览器访问：http://localhost:84/consumer/fallback/2结果：正常浏览器访问：http://localhost:84/consumer/fallback/4结果：Whitelabel Error Page快速多次访问：http://localhost:84/consumer/fallback/4结果：{"code":445,"message":"blockHandler-sentinel限流,无此流水: blockException  null","data":{"id":4,"serial":"null"}}##################测试四############
9、consumer-84业务类放开注解@SentinelResource(value = "fallback", fallback = "handlerFallback", blockHandler = "blockHandler",exceptionsToIgnore = {IllegalArgumentException.class})10、浏览器访问：http://localhost:84/consumer/fallback/4结果：Whitelabel Error Page浏览器访问：http://localhost:84/consumer/fallback/5结果：{"code":444,"message":"兜底异常handlerFallback,exception内容  NullPointerException,该ID没有对应记录,空指针异常","data":{"id":5,"serial":"null"}}结论：@blockHandlerClass 处理类
@blockHandler 处理类下的处理方法
fallback:处理异常，做服务降级的
exceptionToIgnore：忽略异常

3.7.2、Sentinel与OpenFeign

修改module：cloudalibaba-consumer-order-84

POM新增（上面创建的时候就已增加过了）

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

yml新增：

#对Feign的支持
feign:sentinel:enabled: true

新增feign对应的接口：paymentService

@FeignClient(value = "nacos-payment-provider",fallback = PaymentFallbackService.class)
public interface PaymentService {@GetMapping(value = "/paymentSQL/{id}")public CommonResult<Payment> paymentSQL(@PathVariable("id") Long id);}

新增feign接口的对应的服务降级类：PaymentFallbackService

@Component
public class PaymentFallbackService implements PaymentService
{@Overridepublic CommonResult<Payment> paymentSQL(Long id){return new CommonResult<>(44444,"服务降级返回,---PaymentFallbackService",new Payment(id,"errorSerial"));}
}

新增controller：OrderController

@Slf4j
@RestController
public class OrderController {// OpenFeign@Resourceprivate PaymentService paymentService;@GetMapping(value = "/consumer/feign/paymentSQL/{id}")public CommonResult<Payment> paymentSQL(@PathVariable("id") Long id) {return paymentService.paymentSQL(id);}}

主启动类新增注解：

@EnableFeignClients

测试：

1、启动nacos-server、sentinel-server、cloudalibaba-provider-payment-9004、9005、
cloudalibaba-consumer-order-842、浏览器访问：http://localhost:84/consumer/feign/paymentSQL/5结果:
{"code":200,"message":"from mysql,serverPort:  9005","data":null}4、此时关闭cloudalibaba-provider-payment-9004、9005两个微服务，重新访问结果：
{"code":44444,"message":"服务降级返回,---PaymentFallbackService","data":{"id":5,"serial":"errorSerial"}}

3.8、Sentinel规则持久化

blic CommonResult paymentSQL(@PathVariable(“id”) Long id);

}


新增feign接口的对应的服务降级类：PaymentFallbackService ```java
@Component
public class PaymentFallbackService implements PaymentService
{@Overridepublic CommonResult<Payment> paymentSQL(Long id){return new CommonResult<>(44444,"服务降级返回,---PaymentFallbackService",new Payment(id,"errorSerial"));}
}

新增controller：OrderController

@Slf4j
@RestController
public class OrderController {// OpenFeign@Resourceprivate PaymentService paymentService;@GetMapping(value = "/consumer/feign/paymentSQL/{id}")public CommonResult<Payment> paymentSQL(@PathVariable("id") Long id) {return paymentService.paymentSQL(id);}}

主启动类新增注解：

@EnableFeignClients

测试：

1、启动nacos-server、sentinel-server、cloudalibaba-provider-payment-9004、9005、
cloudalibaba-consumer-order-842、浏览器访问：http://localhost:84/consumer/feign/paymentSQL/5结果:
{"code":200,"message":"from mysql,serverPort:  9005","data":null}4、此时关闭cloudalibaba-provider-payment-9004、9005两个微服务，重新访问结果：
{"code":44444,"message":"服务降级返回,---PaymentFallbackService","data":{"id":5,"serial":"errorSerial"}}

3.8、Sentinel规则持久化

//TODO 以后再单独列出文章来写

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/483574.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

基于vite6+ vue3 + electron@33 实现的 局域网内互传文件的桌面软件

基于vite6+ vue3 + electron@33 实现的 局域网内互传文件的桌面软件

目录 项目介绍项目部分截图介绍下基础项目搭建先搭建一个vite 前端项目 再安装 electron 相关依赖依赖安装失败解决方案修改 vite配置文件和 ts 配置文件修改packjsonts相关配置项目结构介绍 项目介绍 前端 基于 vue3 ts windicss 后端 就是node 层 项目地址&#xff1a; h…
阅读更多...
安装MySQL 5.7 亲测有效

安装MySQL 5.7 亲测有效

前言&#xff1a;本文是笔者在安装MySQL5.7时根据另一位博主大大的安装教程基础上做了一些修改而成 首先在这里表示对博主大大的感谢 下面附博主大大地址 下面的步骤言简意赅 跟着做就不会出错 希望各位读者耐下心来 慢慢解决安装中出现的问题~MySQL 5.7 安装教程&#xff08;全…
阅读更多...
CSS函数

CSS函数

目录 一、背景 二、函数的概念 1. var()函数 2、calc()函数 三、总结 一、背景 今天我们就来说一说&#xff0c;常用的两个css自定义属性&#xff0c;也称为css函数。本文中就成为css函数。先来看一下官方对其的定义。 自定义属性&#xff08;有时候也被称作CSS 变量或者级…
阅读更多...
6.824/6.5840 Lab 1: MapReduce

6.824/6.5840 Lab 1: MapReduce

宁静的夏天 天空中繁星点点 心里头有些思念 思念着你的脸 ——宁夏 完整代码见&#xff1a; https://github.com/SnowLegend-star/6.824 由于这个lab整体难度实在不小&#xff0c;故考虑再三还是决定留下代码仅供参考 6.824的强度早有耳闻&#xff0c;我终于也是到了挑战这座高…
阅读更多...
MongoDB集群分片安装部署手册

MongoDB集群分片安装部署手册

文章目录 一、集群规划1.1 集群安装规划1.2 端口规划1.3 目录创建 二、mongodb安装&#xff08;三台均需要操作&#xff09;2.1 下载、解压2.2 配置环境变量 三、mongodb组件配置3.1 配置config server的副本集3.1.1 config配置文件3.1.2 config server启动3.1.3 初始化config …
阅读更多...
一种多功能调试工具设计方案开源

一种多功能调试工具设计方案开源

一种多功能调试工具设计方案开源 设计初衷设计方案具体实现HUB芯片采用沁恒微CH339W。TF卡功能网口功能SPI功能IIC功能JTAG功能下行USB接口 安路FPGA烧录器功能Xilinx FPGA烧录器功能Jlink OB功能串口功能RS232串口RS485和RS422串口自适应接口 CAN功能烧录器功能 目前进度后续计…
阅读更多...
三维测量与建模笔记 - 5.3 光束法平差（Bundle Adjustment）

三维测量与建模笔记 - 5.3 光束法平差（Bundle Adjustment）

此篇笔记尚未理解&#xff0c;先做笔记。 如上图&#xff0c;在不同位姿下对同一个物体采集到了一系列图像&#xff0c; 例子中有四张图片。物体上某点M&#xff0c;在四幅图像上都能找到其观测点。 上式中的f函数是对使用做投影得到的估计点位置。求解这个方程有几种方法&…
阅读更多...
力扣hot100道【贪心算法后续解题方法心得】（三）

力扣hot100道【贪心算法后续解题方法心得】（三）

力扣hot100道【贪心算法后续解题方法心得】 十四、贪心算法关键解题思路1、买卖股票的最佳时机2、跳跃游戏3、跳跃游戏 | |4、划分字母区间 十五、动态规划什么是动态规划&#xff1f;关键解题思路和步骤1、打家劫舍2、01背包问题3、完全平方式4、零钱兑换5、单词拆分6、最长递…
阅读更多...
ElasticSearch学习篇19_《检索技术核心20讲》搜推广系统设计思想

ElasticSearch学习篇19_《检索技术核心20讲》搜推广系统设计思想

目录 主要是包含搜推广系统的基本模块简单介绍&#xff0c;另有一些流程、设计思想的分析。 搜索引擎 基本模块检索流程 查询分析查询纠错 广告引擎 基于标签倒排索引召回基于向量ANN检索召回打分机制&#xff1a;非精确打分精准深度学习模型打分索引精简&#xff1a;必要的…
阅读更多...
Ambrus 游戏工作室将应对气候变暖与游戏变现完美结合

Ambrus 游戏工作室将应对气候变暖与游戏变现完美结合

当 Ambrus Studio 创始人兼 CEO Johnson Yeh 计划打造他称之为“第一款伟大的 Web3 游戏”时&#xff0c;他设立了两个关键目标&#xff1a;游戏需要在传统大型工作室忽视的市场中盈利&#xff0c;以及它需要具备超越娱乐的意义。 在 Sui 的帮助下&#xff0c;Johnson 和他的团…
阅读更多...
KAN-Transfomer——基于新型神经网络KAN的时间序列预测

KAN-Transfomer——基于新型神经网络KAN的时间序列预测

1.数据集介绍 ETT(电变压器温度)&#xff1a;由两个小时级数据集&#xff08;ETTh&#xff09;和两个 15 分钟级数据集&#xff08;ETTm&#xff09;组成。它们中的每一个都包含 2016 年 7 月至 2018 年 7 月的七种石油和电力变压器的负载特征。 traffic(交通) &#xff1a;描…
阅读更多...
UEFI Spec 学习笔记---3 - Boot Manager(3)

UEFI Spec 学习笔记---3 - Boot Manager(3)

3.2 Boot Manager Policy Protocol EFI_BOOT_MANAGER_POLICY_PROTOCOL----EFI应用程序使用该协议请求UEFI引导管理器使用平台策略连接设备。 typedef struct _EFI_BOOT_MANAGER_POLICY_PROTOCOL EFI_BOOT_MANAGER_POLICY_PROTOCOL; struct _EFI_BOOT_MANAGER_POLICY_PROTOCOL…
阅读更多...
wordpress网站首页底部栏显示网站备案信息

wordpress网站首页底部栏显示网站备案信息

一、页脚文件footer.php 例如&#xff0c;wordpress主题使用的是simple-life主题&#xff0c;服务器IP为192.168.68.89,在wordpress主题文件中有个页脚文件footer.php&#xff0c;这是一个包含网站页脚代码的文件。 footer.php 路径如下&#xff1a; /www/wwwroot/192.168.68…
阅读更多...
QT实战-qt各种菜单样式实现

QT实战-qt各种菜单样式实现

本文主要介绍了qt普通菜单样式、带选中样式、带子菜单样式、超过一屏幕菜单样式、自定义带有滚动条的菜单样式&#xff0c; 先上图如下&#xff1a; 1.普通菜单样式 代码&#xff1a; m_pmenu new QMenu(this);m_pmenu->setObjectName("quoteListMenu"); qss文…
阅读更多...
数据结构实训——查找

数据结构实训——查找

声明&#xff1a; 以下是我们学校在学习数据结构时进行的实训&#xff0c;如涉及侵权马上删除文章 声明&#xff1a;本文主要用作技术分享&#xff0c;所有内容仅供参考。任何使用或依赖于本文信息所造成的法律后果均与本人无关。请读者自行判断风险&#xff0c;并遵循相关法…
阅读更多...
指针（上）

指针（上）

目录 内存和地址 指针变量和地址 取地址&#xff08;&&#xff09; 解引用&#xff08;*&#xff09; 大小 类型 意义 const修饰 修饰变量 修饰指针 指针运算 指针- 整数 指针-指针 指针的关系运算 野指针 概念 成因 避免 assert断言 指针的使用 strl…
阅读更多...
13TB的StarRocks大数据库迁移过程

13TB的StarRocks大数据库迁移过程

公司有一套StarRocks的大数据库在大股东的腾讯云环境中&#xff0c;通过腾讯云的对等连接打通&#xff0c;通过dolphinscheduler调度datax离线抽取数据和SQL计算汇总&#xff0c;还有在大股东的特有的Flink集群环境&#xff0c;该环境开发了flink开发程序包部署&#xff0c;实时…
阅读更多...
ARP表、MAC表、路由表的区别和各自作用

ARP表、MAC表、路由表的区别和各自作用

文章目录 ARP表、MAC表、路由表的区别和各自作用同一网络内:ARP表request - 请求reply - 响应 MAC地址在同一网络内,交换机如何工作? 不同网络路由表不同网络通信流程PC1到路由器路由器到PC2流程图 简短总结 ARP表、MAC表、路由表的区别和各自作用 拓扑图如下: 同一网络内:…
阅读更多...
第七课 Unity编辑器创建的资源优化_UI篇（UGUI）

第七课 Unity编辑器创建的资源优化_UI篇（UGUI）

上期我们学习了简单的Scene优化&#xff0c;接下来我们继续编辑器创建资源的UGUI优化 UI篇&#xff08;UGUI&#xff09; 优化UGUI应从哪些方面入手&#xff1f; 可以从CPU和GPU两方面考虑&#xff0c;CPU方面&#xff0c;避免触发或减少Canvas的Rebuild和Rebatch&#xff0c…
阅读更多...
微服务搭建----springboot接入Nacos2.x

微服务搭建----springboot接入Nacos2.x

springboot接入Nacos2.x nacos之前用的版本是1.0的&#xff0c;现在重新搭建一个2.0版本的&#xff0c;学如逆水行舟&#xff0c;不进则退&#xff0c;废话不多说&#xff0c;开搞 1、 nacos2.x搭建 1&#xff0c;首先第一步查询下项目之间的版本对照&#xff0c;不然后期会…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023