当前位置：网站首页>将 Sentinel 熔断限流规则持久化到 Nacos 配置中心

将 Sentinel 熔断限流规则持久化到 Nacos 配置中心

2022-08-04 13:33:00 【InfoQ】

在实际操作的过程中你会发现，每次项目重启后，配置的限流规则都没有了！

这是因为，在 Sentinel DashBoard 上配置的规则只存在缓存中，当项目重启，这些规则自然就消失了。

实际生产环境中，我们是不允许这种情况存在的，那么如何进行 Sentinel 配置规则的持久化呢？Sentinel 提供多种不同的数据源来持久化规则配置，包括 File ，Redis 、Nacos 、ZooKeeper 等。

本文将演示如何持久化 Sentinel 规则到 Nacos 中。

Nacos 配置中心配置持久化规则

将 Sentinel 规则持久化到 Nacos 中保存，只要请求了某个微服务的资源，Sentinel 控制台的规则就能感应到，同时只要 Nacos 里面的配置不删除，针对该微服务上资源的 Sentinel 流控规则就持续有效。

只要实现了 Nacos 和 Sentinel 之间的通信，就能从持久化的 Nacos 中获取 Sentinel 流控规则。

Tips：

 在 Nacos 控制台上修改流控制，虽然可以同步到 Sentinel Dashboard，但是 Nacos 此时应该作为一个流控规则的持久化平台。正常操作过程应该是我们在 Sentinel Dashboard 上修改流控规则后同步到 Nacos ，但是目前并不能从 Sentinel Dashboard 配置完之后主动同步到 Nacos —— 需要我们在 Nacos 配置中心配置限流/熔断等 Sentinel 规则。

集成到 Spring Cloud Alibaba微服务项目

沿用前面文章的案例，在微服务项目 cloud-sentinel-service 中，增加内容：将 Sentinel 流控规则放到 Nacos 配置中心进行持久化。

在 Nacos 中配置流控规则

进入到 Nacos 控制台，进入到配置管理新建一个配置文件：

接下来输入 dataId , 文件类型选择 json ：

然后点击发布即可。

这里需要说明一下，具体的规则怎么配，配置项的含义说明：

流量控制规则（FlowRule）

resource ：资源名，资源名是限流规则的作用对象，比如请求资源 getUser 。

grade ：限流阈值类型，QPS 或线程数模式。0表示线程数，1表示QPS。默认为1，即 QPS 模式

count ：限流阈值。比如值为2表示1秒超过2个请求就限流。

strategy ：流控模式：直接、链路、关联，默认直接。0表示直接，1表示关联，2表示链路。

controlBehavior ：流控效果（直接拒绝 / 排队等待 / 慢启动模式），0表示快速失败，1表示Warm Up，2表示排队等待。

limitApp ：流控针对的调用来源。默认就是 default ，代表不区分调用来源.

熔断降级规则（DegradeRule）

resource ：资源名，资源名是限流规则的作用对象，比如请求资源 getUser 。

grade ：熔断策略，支持慢调用比例/异常比例/异常数策略。1：慢调用比例，2：异常比例，3：异常数。默认为1，慢调用比例。

count ：慢调用比例模式下为慢调用临界 RT（超出该值计为慢调用）；异常比例/异常数模式下为对应的阈值。

timeWindow ：熔断时长，单位为秒。

minRequestAmount ：熔断触发的最小请求数，请求数小于该值时即使异常比率超出阈值也不会熔断。默认为 5 。

statIntervalMs ：统计时长（单位为 ms），如 60*1000 代表分钟级。默认为 1000 ms。

slowRatioThreshold ：慢调用比例阈值，仅慢调用比例模式有效

Tip：同一个资源可以同时有多个降级规则。

Spring Cloud Alibaba 微服务项目中设置 Sentinel 数据源

首先，需要引入相关依赖包：

<!-- 引入 Sentinel 数据源 -->
<dependency>
 <groupId>com.alibaba.cloud</groupId>
 <artifactId>spring-cloud-alibaba-sentinel-datasource</artifactId>
</dependency>
<!-- Sentinel数据源之 Nacos -->
<dependency>
 <groupId>com.alibaba.csp</groupId>
 <artifactId>sentinel-datasource-nacos</artifactId>
</dependency>

然后，配置 application.yml ：

server:
 port: 7072

spring:
 application:
 name: cloud-sentinel-service

 cloud:
 nacos:
 discovery:
 server-addr: 192.168.242.112:81
 sentinel:
 transport:
 dashboard: localhost:8080
 port: 8719
 # https://github.com/alibaba/Sentinel/issues/1213
 web-context-unify: false
 datasource:
 nacos:
 nacos:
 serverAddr: 192.168.242.112:81
 groupId: DEFAULT_GROUP
 dataId: sentinelFlowRule.json
 ruleType: flow

management:
 endpoints:
 web:
 exposure:
 include: '*'

增加了配置项： spring.cloud.sentinel.datasource ，配置项指定了数据源为 Nacos，并且配置 Nacos 的 IP 地址以及 dataId 等。

根据前面在 Nacos 配置的流控规则：

[
 {
 &quot;resource&quot;: &quot;getUser&quot;,
 &quot;limitApp&quot;: &quot;default&quot;,
 &quot;grade&quot;: 1,
 &quot;count&quot;: 2,
 &quot;strategy&quot;: 0,
 &quot;controlBehavior&quot;: 0,
 &quot;clusterMode&quot;: false
 },
 {
 &quot;resource&quot;: &quot;getOrder&quot;,
 &quot;limitApp&quot;: &quot;default&quot;,
 &quot;grade&quot;: 1,
 &quot;count&quot;: 2,
 &quot;strategy&quot;: 0,
 &quot;controlBehavior&quot;: 0,
 &quot;clusterMode&quot;: false
 }
]

该规则说明：

资源 getUser 和 getOrder 的限流类型是 1：QPS，限流阈值时2，即当1秒大于2个请求就进行限流，限流策略时直接，流控效果是直接拒绝。

下面在 Controller 中写两个资源：

@GetMapping(&quot;/getUser&quot;)
@SentinelResource(&quot;getUser&quot;)
public String getUser() {
 return &quot;getUser success!&quot;;
}

@GetMapping(&quot;/getOrder&quot;)
@SentinelResource(&quot;getOrder&quot;)
public String getOrder() {
 return &quot;getOrder success!&quot;;
}

OK，至此就可以验证了。