SpringCloudAlibabaSentinel＞流控规则初体验

源码地址&＃xff1a;https://github.com/alibaba/Sentinel
新手指南&＃xff1a;https://github.com/alibaba/Sentinel/wiki/新手指南#公网-demo
官方文档&＃xff1a;https://sentinelguard.io/zh-cn/docs/introduction.html
注解支持文档&＃xff1a;https://github.com/alibaba/Sentinel/wiki/注解支持

源代码地址&＃xff1a;Spring Cloud Alibaba Sentinel - - &＃xff1e;流控规则 (快速使用案例)&＃xff0c;主要看Sentinel8040这个moudle

Sentinel 介绍

  Sentinel 是阿里巴巴开源的&＃xff0c;面向分布式服务架构的高可用组件 / 流量控制组件 (分布式系统的流量防卫兵)。随着微服务的流行&＃xff0c;服务与服务之间的稳定性变得越来越重要。Sentinel 以流量为切入点&＃xff0c;从流量控制 (限流)、流量整形、熔断降级、系统负载保护、热点防护等多个维度来帮助开发者保障微服务的稳定性。

Sentinel 具有以下特征&＃xff1a;

• 丰富的应用场景

Sentinel 承接了 Alibaba 近十年的双十一大促流量的核心场景&＃xff0c;例如秒杀 (即突增流量控制在系统容器可以承受的范围)、消息削峰填谷、实时熔断下游不可用应用服务等。

• 完备的实时监控

Sentinel 提供实时的监控功能。你可以在控制台中看到接入应用的单台机器秒级数据&＃xff0c;甚至500台以下规模的集群的汇总运行情况。

• 广泛的开源生态

Sentinel 提供开箱即用&＃xff0c;与其它开源框架/库的整合模块&＃xff0c;例如Spring Cloud、Dubble、gRPC的整合。你只需引入相关的依赖并进行简单的配置即可快速地接入 Sentinel。

• 完善的 SPI 扩展点

Sentinel 提供简单易用、完善的 SPI 扩展点。你可以通过实现扩展点&＃xff0c;快速的定制逻辑。例如定制规则管理&＃xff0c;适配数据源等。

阿里巴巴开源的 Sentinel 是基础版&＃xff0c;而双十一使用的是它们的内部版本。但阿里云提供了企业级的 Sentinel 服务 - - > 应用高可用服务 AHAS&＃xff0c;也就是付费版本。其实开源的基础版本对于中小型互联网公司而言已经足够用了&＃xff0c;而对于大型互联网公司则需要在 Sentinel 的基础上进行扩展)

&＃x1f517; Sentinel 与 Hystrix 的对比

&＃x1f517; 使用简介

Sentinel 可以简单的分为 Sentinel 核心库 (sentinel-core依赖) 和 Dashboard (Sentinel控制台)。核心库不依赖 Dashboard&＃xff0c;但是结合 Dashboard 可以取得最好的效果 (因为通过Sentinel控制台&＃xff0c;我们可以更方便的设置规则&＃xff0c;不仅效率提高了&＃xff0c;还能进行实时监控&＃xff0c;而无需编写java代码来设置规则)。 - - > 当然学习中还是以代码方式为准。

这篇文章主要介绍 Sentinel 核心库的使用。如果希望有一个最快最直接的了解&＃xff0c;可以参考 新手指南 来获取一个最直观的感受。

我们说的资源&＃xff0c;可以是任何东西&＃xff0c;服务&＃xff0c;服务里的方法&＃xff0c;甚至是一段代码。使用 Sentinel 来进行资源保护&＃xff0c;主要分为几个步骤:

1. 定义资源
2. 定义规则
3. 检验规则是否生效

先把可能需要保护的资源定义好&＃xff08;埋点&＃xff09;&＃xff0c;之后再配置规则。也可以理解为&＃xff0c;只要有了资源&＃xff0c;我们就可以在任何时候灵活地定义各种流量控制规则。在编码的时候&＃xff0c;只需要考虑这个代码是否需要保护&＃xff0c;如果需要保护&＃xff0c;就将之定义为一个资源。

对于主流的框架&＃xff0c;我们提供适配&＃xff0c;只需要按照适配中的说明配置&＃xff0c;Sentinel 就会默认定义提供的服务&＃xff0c;方法等为资源。

注意&＃xff1a;Sentinel 需要 JDK 1.8 或更高版本。

需要注意的是&＃xff0c;Sentinel 并不是一定要在 Spring Cloud Alibaba 上使用的&＃xff0c;我们可以单纯的去使用 Sentinel 核心库。它可以在分布式架构中使用&＃xff0c;而不是一定要在微服务架构中使用。

Sentinel 快速使用

&＃x1f517; 1. 添加依赖关系

如果您使用的是 Maven&＃xff0c;只需在pom.xml中添加以下依赖项。

<dependency>
<groupId>com.alibaba.cspgroupId>
<artifactId>sentinel-coreartifactId>
dependency>


Sentinel 的流控规则、降级规则等都是针对项目中的接口来进行设置的&＃xff0c;需要依赖 web 接口&＃xff0c;需要引入 web场景启动器 spring-boot-starter-web 依赖。

<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-webartifactId>
dependency>


&＃x1f517; 2. 定义资源

创建一个接口&＃xff0c;在接口中定义资源&＃xff0c;资源名称一般和接口地址一致。

&＃64;GetMapping("/hello")
public String hello(){
Entry entry &＃61; null;
try {
// sentinel 针对资源进行限制的&＃xff0c;通常这个资源名称会跟接口的地址名称保持一致
entry &＃61; SphU.entry(RESOURCE_NAME);
// 被保护的业务逻辑
String str &＃61; "hello word";
log.info("- - -> " &＃43; str &＃43; " <- - -");
return str;
} catch (BlockException e) {
// 资源访问阻止&＃xff0c;被限流 或 被降级
// 进行相应的处理操作
log.info("block");
return "被流控了";
} catch (Exception e) {
// 若需要配置降级规则&＃xff0c;需要通过这种方式记录业务异常
Tracer.traceEntry(e, entry);
}finally {
if(entry !&＃61; null){
entry.exit();
}
}
return null;
}


&＃x1f517; 3. 定义规则

接下来&＃xff0c;通过流控规则来指定允许该资源通过的请求次数&＃xff0c;例如下面的代码定义了资源 HelloWorld 每秒最多只能通过 1 个请求。

&＃64;PostConstruct // Spring的初始化方法
private static void initFlowRules(){
// 流控规则
List<FlowRule> rules &＃61; new ArrayList<>();
// 流控
FlowRule rule &＃61; new FlowRule();
// 设置受保护的资源&＃xff08;即为哪个资源进行流量控制&＃xff09;
rule.setResource(RESOURCE_NAME);
// 设置流控规则 QPS
rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
// 设置受保护的资源阈值
// Set limit QPS to 20&＃xff0c;设置每秒的访问数为20&＃xff0c;超过20的部分就会进行限流
//rule.setCount(20);
// Set limit QPS to 1&＃xff0c;设置每秒的访问数为1&＃xff0c;超过1的部分就会到catch(BlockException e)里去
rule.setCount(1);
rules.add(rule);
// 加载配置好的规则
FlowRuleManager.loadRules(rules);
}


完成上面 3 步&＃xff0c;Sentinel 就能够正常工作了。更多的信息可以参考 使用文档。

完整代码

&＃64;RestController
&＃64;Slf4j
public class HelloController {
private static final String RESOURCE_NAME &＃61; "hello";
private static final String USER_RESOURCE_NAME &＃61; "user";
private static final String DEGRADE_RESOURCE_NAME &＃61; "degrade";
/**
* 进行Sentinel流控规则
*
* Sentinel 所有的规则都是针对于接口来的&＃xff0c;准确点说是针对资源来设置的
*/
&＃64;GetMapping("/hello")
public String hello(){
Entry entry &＃61; null;
try {
// sentinel 针对资源进行限制的&＃xff0c;通常这个资源名称会跟接口的地址名称保持一致
entry &＃61; SphU.entry(RESOURCE_NAME);
// 被保护的业务逻辑&＃xff0c;如果是RPC调用远程服务的接口&＃xff0c;那么这里被保护的就是RPC远程服务接口
String str &＃61; "hello word";
log.info("- - -> " &＃43; str &＃43; " <- - -");
// 如果没有被流控&＃xff0c;则正常返回
return str;
} catch (BlockException e) {
// 资源访问阻止&＃xff0c;被限流 或 被降级
// 进行相应的处理操作
log.info("block");
// 如果被流控了&＃xff0c;则返回被流控了
return "被流控了";
} catch (Exception e) {
// 若需要配置降级规则&＃xff0c;需要通过这种方式记录业务异常
Tracer.traceEntry(e, entry);
}finally {
if(entry !&＃61; null){
entry.exit();
}
}
return null;
}
&＃64;PostConstruct // Spring的初始化方法
private static void initFlowRules(){
// 流控规则
List<FlowRule> rules &＃61; new ArrayList<>();
// 流控
FlowRule rule &＃61; new FlowRule();
// 设置受保护的资源&＃xff08;即为哪个资源进行流量控制&＃xff09;
rule.setResource(RESOURCE_NAME);
// 设置流控规则 QPS
rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
// 设置受保护的资源阈值
// Set limit QPS to 20&＃xff0c;设置每秒的访问数为20&＃xff0c;超过20的部分就会进行限流
//rule.setCount(20);
// Set limit QPS to 1&＃xff0c;设置每秒的访问数为1&＃xff0c;超过1的部分就会到catch(BlockException e)里去
rule.setCount(1);
rules.add(rule);
// 加载配置好的规则
FlowRuleManager.loadRules(rules);
}
}


&＃x1f517; 4. 检查效果