如何使用Sentinel实现流控和降级

Sentinel 是一款面向分布式系统的流量控制、熔断和自适应限流工具，由Alibaba开源。Sentinel 以Java客户端的形式提供，可以嵌入到Java应用中以保护系统稳定运行。

以下是使用Sentinel实现流量控制和降级操作的详细步骤：

1. 添加Sentinel依赖

首先，需要在项目中添加Sentinel的依赖。

Maven依赖:

<dependency><groupId>com.alibaba.csp</groupId><artifactId>sentinel-core</artifactId><version>1.8.0</version>
</dependency>

Gradle依赖:

implementation 'com.alibaba.csp:sentinel-core:1.8.0'

2. 引入Sentinel核心库

在应用启动类或者配置文件中引入Sentinel核心库。

import com.alibaba.csp.sentinel.init.InitFunc;public class SentinelApplication {public static void main(String[] args) {// 初始化SentinelInitFunc.doInit();// 其他应用启动代码...}
}

3. 定义资源

Sentinel 中的资源是受保护的实体，如一个接口调用、一个数据库连接等。

import com.alibaba.csp.sentinel.Entry;
import com.alibaba.csp.sentinel.SphU;
import com.alibaba.csp.sentinel.context.ContextUtil;
import com.alibaba.csp.sentinel.slots.block.BlockException;public class YourService {private static final String RESOURCE_NAME = "yourMethodResource";public void yourMethod() {Entry entry = null;try {entry = SphU.entry(RESOURCE_NAME);// 业务逻辑...} catch (BlockException e) {// 流量控制或熔断时的处理逻辑...} finally {if (entry != null) {entry.exit();}}}
}

4. 配置流控规则

Sentinel 允许你通过代码或配置文件定义流控规则。

代码配置:

import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;FlowRule rule = new FlowRule();
rule.setResource(RESOURCE_NAME);
rule.setCount(10); // 每秒通过的请求数量
rule.setGrade(RuleConstant.FLOW_GRADE_QPS); // 限流阈值类型
rule.setLimitApp("default"); // 来源应用名称List<FlowRule> rules = new ArrayList<>();
rules.add(rule);FlowRuleManager.loadRules(rules);

配置文件:

在sentinel目录下的flow-rules.json文件中定义规则。

[{"resource": "yourMethodResource","limitApp": "default","grade": 1,"count": 10,"strategy": 0,"controlBehavior": 0,"exceResources": "","clusterMode": false}
]

5. 配置降级规则

降级规则允许你在系统负载较高时，对某些服务调用进行降级。

import com.alibaba.csp.sentinel.slots.system.SystemRule;
import com.alibaba.csp.sentinel.slots.system.SystemRuleManager;SystemRule rule = new SystemRule();
rule.setHighestSystemLoad(75); // 系统负载达到75%时触发降级
SystemRuleManager.loadRules(Collections.singletonList(rule));

6. 定义降级逻辑

在业务逻辑中，捕获BlockException来定义降级逻辑。

try {entry = SphU.entry(RESOURCE_NAME);// 正常业务逻辑...
} catch (BlockException e) {// 执行降级逻辑，例如返回默认值、执行备选逻辑等System.out.println("Blocked by Sentinel: " + e.getMessage());// 返回降级后的结果
}