这篇文章，主要介绍微服务组件之Sentinel服务熔断、服务降级、流量控制。
目录
一、Sentinel组件
1.1、Sentinel介绍
1.2、Sentinel环境搭建
（1）引入依赖
（2）资源和规则
1.3、使用SphU定义资源
（1）定义资源
（2）定义规则
1.4、使用SphO定义资源
（1）定义资源
（2）定义规则
1.5、使用@SentinelResource注解定义资源
（1）定义资源
（2）定义规则
1.6、熔断降级规则
（1）案例代码
（2）五种降级规则
一、Sentinel组件
1.1、Sentinel介绍
Sentinel是Spring Cloud Alibaba提供的一个专门用于服务容错、服务熔断、服务限流的微服务组件，它和hystrix组件的作用是类似的，但是Sentinel提供的功能比hystrix更加强大，Sentinel分为两部分，一部分是Sentinel核心库，另外一部分是Dashboard控制台，Dashboard控制台可以查看监控的信息，接口的调用情况等。
有两种使用Sentinel组件的方式，分别是：
- 第一种：引入Sentinel核心库依赖，然后通过Java代码的方式编写流控规则。
- 第二种：通过Dashboard控制台直接添加流控规则。
1.2、Sentinel环境搭建
Sentinel可以和很多的框架进行整合，并且也可以单独的使用，例如：和SpringCloud整合、和SpringBoot整合、Dubbo整合等，这里我就和SpringCloud进行整合。
（1）引入依赖
<!-- 引入 web 依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 引入 sentinel 依赖 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>引入sentinel依赖之后，基本的环境就搭建好了，接下来就是使用Sentinel进行流量控制等代码的编写。
（2）资源和规则
在Sentinel中有两种概念需要了解下，分别是：资源和规则。
资源就是指项目中的一个请求资源，可以将一段代码、一个方法看作是资源，Sentinel就是以【资源】的形式进行流控设置，定义资源之后，还需要给这个资源设置相对应的流控规则，规则也就是说，这个资源什么情况下，需要发生熔断、降级、限流等等操作呢，这些操作就是规则。
- 一般情况下，我们都使用方法名、URL、微服务名称作为资源名称来描述某个资源。
- 流量控制、熔断降级、系统保护、来源访问控制、热点参数等等规则。
Sentinel提供了多种资源的定义方式，可以通过【@SentinelResource】注解定义资源，也可以通过Java代码的方式手动的定义资源。下面分别介绍一下，几种定义资源和规则的方式。
1.3、使用SphU定义资源
SphU是Sentinel提供的一个类，SphU是采用【try...catch】异常的方式来实现流控配置，当发生流控的时候，就会抛出一个BlockException异常。
（1）定义资源
@GetMapping("/sphU")
public String demo01() {
Entry entry = null;
try {
// 1、开启流控
entry = SphU.entry("sphU_demo01");
System.out.println("这里就是执行具体业务逻辑");
} catch (BlockException e) {
e.printStackTrace();
// 记录流控异常日志
Tracer.traceEntry(e, entry);
// 2、当发生流控的时候，就会进入这个异常块里面
return "Sentinel发生流控，请稍后重试！";
} finally {
if (entry != null) {
// 3、退出流控
entry.exit();
}
}
return "接口调用成功";
}（2）定义规则
/**
* 注入流控规则
*/
@PostConstruct
private void initFlowRule() {
List<FlowRule> ruleList = new ArrayList<>();
// 创建资源对应的流控规则
FlowRule flowRule = new FlowRule();
// 设置当前这个规则属于哪个资源的
// 注意：不要用错方法，是调用【serResource()】方法，而不是【serRefResource()】,方法用错后，sentinel流控不生效
flowRule.setResource("sphU_demo01");
// 设置流控规则类型，这采用 QPS 方式
flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);
// 设置 QPS 的限制数量
flowRule.setCount(1);
ruleList.add(flowRule);
// 将流控规则添加到Sentinel里面
FlowRuleManager.loadRules(ruleList);
}启动工程，然后浏览器访问【/api/sentinel/sphU】接口，连续多次刷新页面，此时就会出现流控情况，从而抛出异常。
1.4、使用SphO定义资源
SphO也是Sentinel提供的一个类，它是采用【if...else】的方式来实现流控，当触发流控的时候，对应方法会返一个boolean类型，false表示发生了流控，我们就可以根据方法的返回值，进行代码的处理。
（1）定义资源
@GetMapping("/sphO")
public String demo02() {
boolean entry = SphO.entry("sphO_demo02");
if (entry) {
try {
System.out.println("执行具体业务逻辑...");
// 没有发生流控，正常执行业务逻辑代码
return "接口调用成功";
} finally {
// 关闭流控
SphO.exit();
}
} else {
// 发生流控
return "Sentinel发生流控，请稍后重试！";
}
}（2）定义规则
/**
* 注入流控规则
*/
@PostConstruct
public void initFlowRule() {
List<FlowRule> ruleList = new ArrayList<>();
// 创建资源对应的流控规则
FlowRule flowRule = new FlowRule();
flowRule.setResource("sphO_demo02");
// 设置当前这个规则属于哪个资源的
// 设置流控规则类型，这采用 QPS 方式
flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);
// 设置 QPS 的限制数量
flowRule.setCount(1);
ruleList.add(flowRule);
// 将流控规则添加到Sentinel里面
FlowRuleManager.loadRules(ruleList);
}1.5、使用@SentinelResource注解定义资源
@SentinelResource注解，用于定义资源，这个注解中有下面这些属性：
- value：定义资源名称。
- blockHandler：定义流控降级之后调用的方法。
- 方法必须定义在同一个类中。
- 方法必须是public的。
- 方法返回值必须和原方法的返回值一致。
- 方法参数必须相同，但是最后一个参数可以添加一个异常类参数。
- blockHandlerClass：作用和blockHandler一致，只是单独写到一个类里面了。
- fallback：当对应方法抛出异常时候，会调用这个降级方法。
（1）定义资源
package com.gitcode.demo.controller;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @version 1.0.0
* @Date: 2023/4/25 17:07
* @Copyright (C) ZhuYouBin
* @Description:
*/
@RestController
@RequestMapping("/api/sentinel/demo")
public class SentinelDemo {
@SentinelResource(value = "sentinel_demo", blockHandler = "blockHandlerMethod", fallback = "fallbackMethod")
@GetMapping("/resource")
public String demo02() {
System.out.println("执行具体业务逻辑...");
return "接口调用成功";
}
public String blockHandlerMethod() {
System.out.println("Sentinel发生流控，请稍后重试！");
return "Sentinel发生流控，请稍后重试！";
}
public String fallbackMethod(Throwable ex) {
System.out.println("Sentinel发生异常，请稍后重试！" + ex.getMessage());
return "Sentinel发生异常，请稍后重试！" + ex.getMessage();
}
}
（2）定义规则
/**
* 注入流控规则
*/
@PostConstruct
public void initFlowRule() {
List<FlowRule> ruleList = new ArrayList<>();
// 创建资源对应的流控规则
FlowRule flowRule3 = new FlowRule();
// 设置当前这个规则属于哪个资源的
flowRule3.setResource("sentinel_demo");
// 设置流控规则类型，这采用 QPS 方式
flowRule3.setGrade(RuleConstant.FLOW_GRADE_QPS);
// 设置 QPS 的限制数量
flowRule3.setCount(1);
ruleList.add(flowRule);
// 将流控规则添加到Sentinel里面
FlowRuleManager.loadRules(ruleList);
}1.6、熔断降级规则
通过Java代码的方式设置降级规则，降级规则采用【DegradeRule】类表示，通过这个类设置一些规则，然后将其保存到【DegradeRuleManager】类中的缓存里面即可。
（1）案例代码
/**
* 服务降级规则配置
*/
public void initDegradeRule() {
List<DegradeRule> degradeRuleList = new ArrayList<>();
// 设置降级规则
DegradeRule rule = new DegradeRule();
rule.setResource("资源名称");
// 指定触发降级的规则类型，有五种
rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);
// 设置发生异常时候数量
rule.setCount(2);
// 设置窗口时间
rule.setTimeWindow(10);
// 设置最小请求数量
rule.setMinRequestAmount(2);
degradeRuleList.add(rule);
// 加载到Sentinel里面
DegradeRuleManager.loadRules(degradeRuleList);
}（2）五种降级规则
- DEGRADE_GRADE_EXCEPTION_COUNT：在指定时间内发生的异常次数降级。
- DEGRADE_GRADE_EXCEPTION_RATIO：在指定时间内发生的异常比率降级。
- DEGRADE_DEFAULT_MIN_REQUEST_AMOUNT：根据最小请求数量来实现降级。
- DEGRADE_GRADE_RT：根据响应比进行降级。
- DEGRADE_DEFAULT_SLOW_REQUEST_AMOUNT：最慢请求数量降级。
常用的就只有三个，分别是：异常数量、异常比率、响应比。文章来源：https://www.toymoban.com/news/detail-854884.html
综上，这篇文章结束了，主要介绍微服务组件之Sentinel服务熔断、服务降级、流量控制。文章来源地址https://www.toymoban.com/news/detail-854884.html
到了这里，关于【微服务笔记21】微服务组件之Sentinel服务熔断、服务降级、流量控制介绍的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
