Spring Cloud Alibaba Sentinel（简称Sentinel）是一款开源的流量控制和熔断降级框架，专注于提供微服务架构中的流量控制、熔断降级、系统自适应保护等功能。它是阿里巴巴集团开发的一款分布式系统的容错框架，旨在解决微服务架构中的服务雪崩问题，提高系统的稳定性和可靠性。
使用Sentinel的主要原因是为了增加分布式系统的稳定性、可靠性和弹性，以及保护系统免受异常情况和过载的影响。以下是一些需要使用Sentinel的理由：
在你的 Spring Cloud 项目的 Maven 或 Gradle 配置文件中，添加以下依赖：
Maven：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
Gradle：
implementation 'com.alibaba.cloud:spring-cloud-starter-alibaba-sentinel'
在你的 Spring Boot 应用的配置文件（比如 application.properties 或 application.yml）中，添加 Sentinel 的配置：
spring:
cloud:
sentinel:
transport:
dashboard: localhost:8080 # Sentinel Dashboard 地址
eager: true # 开启 Sentinel 的 Eager 模式，即提前初始化 Sentinel 监听器
在你的 Spring Boot 主类上添加 @EnableCircuitBreaker 注解，启用熔断器功能。示例：
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
@SpringBootApplication
@EnableCircuitBreaker
public class YourApplication {
public static void main(String[] args) {
SpringApplication.run(YourApplication.class, args);
}
}
在你的业务方法上添加 @SentinelResource 注解，进行流控和降级配置。示例：
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to flow control or circuit breaker!";
}
}
Dashboard的启动和使用
下载 Sentinel Dashboard 的 jar 包并运行，可以通过以下命令启动：
java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
在浏览器中访问 http://localhost:8080，你将看到 Sentinel Dashboard 的界面。在 Dashboard 中，你可以配置流控规则、熔断规则，查看实时监控数据等。
| Field | 说明 | 默认值 |
|---|---|---|
| resource | 资源名，资源名是限流规则的作用对象 | |
| count | 限流阈值 | |
| grade | 限流阈值类型，QPS 模式（1）或并发线程数模式（0） | QPS 模式 |
| limitApp | 流控针对的调用来源 | default，代表不区分调用来源 |
| strategy | 调用关系限流策略：直接、链路、关联 | 根据资源本身（直接） |
| controlBehavior | 流控效果（直接拒绝/WarmUp/匀速+排队等待），不支持按调用关系限流 | 直接拒绝 |
| clusterMode | 是否集群限流 | 否 |
单机流控是对单个服务实例的流量进行控制，防止某个实例被过多的请求压垮。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to flow control!";
}
}
集群流控是对多个服务实例的流量进行控制，防止整个服务集群被过多的请求压垮。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to cluster flow control!";
}
}
热点参数限流允许你根据某个参数的值来限制流量，防止热点参数的请求压垮系统。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock")
public String demoMethod(String parameter) {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(String parameter, Throwable e) {
return "Blocked due to parameter hot spot flow control!";
}
}
你可以使用 Sentinel 控制台来配置流控规则，以下是一个简单的代码示例，展示如何通过控制台配置流控规则：
在启动类中添加以下配置类：
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.alibaba.csp.sentinel.annotation.aspectj.SentinelResourceAspect;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import java.util.ArrayList;
import java.util.List;
@Configuration
public class SentinelConfig {
@Bean
public SentinelResourceAspect sentinelResourceAspect() {
return new SentinelResourceAspect();
}
@PostConstruct
public void initFlowRules() {
List<FlowRule> rules = new ArrayList<>();
FlowRule rule = new FlowRule();
rule.setResource("demoResource"); // 资源名称，对应 @SentinelResource 注解的 value 值
rule.setCount(10); // QPS 阈值
rule.setGrade(RuleConstant.FLOW_GRADE_QPS); // 限流规则类型
rules.add(rule);
FlowRuleManager.loadRules(rules);
}
}
RT 降级是根据服务的平均响应时间来触发降级，当服务的平均响应时间超过设定的阈值时，将触发降级。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to RT (response time) degradation!";
}
// 定义降级回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to RT (response time) degradation!";
}
}
异常比例降级是根据异常比例来触发降级，当服务的异常比例超过设定的阈值时，将触发降级。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
if (Math.random() > 0.5) {
throw new RuntimeException("Exception for testing");
}
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to exception ratio degradation!";
}
// 定义降级回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to exception ratio degradation!";
}
}
异常数降级是根据异常数量来触发降级，当服务的异常数量超过设定的阈值时，将触发降级。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
private static int exceptionCount = 0;
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
if (Math.random() > 0.5) {
exceptionCount++;
throw new RuntimeException("Exception for testing");
}
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to exception count degradation!";
}
// 定义降级回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to exception count degradation!";
}
}
启动 Sentinel 控制台，可以使用以下命令：
java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
在浏览器中访问 http://localhost:8080，登录 Sentinel 控制台。
在控制台中选择 “流控规则” 选项，点击 “新增规则”。
根据需要选择降级规则类型，比如 “平均响应时间”、“异常比例” 或 “异常数”，然后配置阈值、触发策略等。
配置完成后，点击 “添加” 按钮，即可在控制台中看到已配置的降级规则。
慢调用比例触发熔断是根据请求的平均响应时间来触发熔断，当服务的慢调用比例超过设定的阈值时，将触发熔断。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑，模拟慢调用
try {
Thread.sleep(1000); // 模拟耗时操作
} catch (InterruptedException e) {
e.printStackTrace();
}
return "Hello, Sentinel!";
}
// 定义熔断降级处理方法
public String handleBlock(Throwable e) {
return "Circuit breaker triggered due to slow call ratio!";
}
// 定义熔断回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to slow call ratio!";
}
}
快速失败触发熔断是当请求被流控后立即失败，无需等待超时。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义熔断降级处理方法
public String handleBlock(Throwable e) {
return "Circuit breaker triggered due to quick failure!";
}
// 定义熔断回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to quick failure!";
}
}
异常比例触发熔断是根据请求的异常比例来触发熔断，当服务的异常比例超过设定的阈值时，将触发熔断。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑，模拟异常
if (Math.random() > 0.5) {
throw new RuntimeException("Exception for testing");
}
return "Hello, Sentinel!";
}
// 定义熔断降级处理方法
public String handleBlock(Throwable e) {
return "Circuit breaker triggered due to exception ratio!";
}
// 定义熔断回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to exception ratio!";
}
}
当使用 Spring Cloud Alibaba Sentinel 进行熔断规则的讲解时，需要了解慢调用比例触发熔断、快速失败触发熔断、异常比例触发熔断以及如何在 Sentinel 控制台中配置熔断规则。以下是详细的讲解、操作步骤和代码案例。
1. 慢调用比例触发熔断：
慢调用比例触发熔断是根据请求的平均响应时间来触发熔断，当服务的慢调用比例超过设定的阈值时，将触发熔断。
javaCopy code
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑，模拟慢调用
try {
Thread.sleep(1000); // 模拟耗时操作
} catch (InterruptedException e) {
e.printStackTrace();
}
return "Hello, Sentinel!";
}
// 定义熔断降级处理方法
public String handleBlock(Throwable e) {
return "Circuit breaker triggered due to slow call ratio!";
}
// 定义熔断回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to slow call ratio!";
}
}
2. 快速失败触发熔断：
快速失败触发熔断是当请求被流控后立即失败，无需等待超时。
javaCopy code
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义熔断降级处理方法
public String handleBlock(Throwable e) {
return "Circuit breaker triggered due to quick failure!";
}
// 定义熔断回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to quick failure!";
}
}
3. 异常比例触发熔断：
异常比例触发熔断是根据请求的异常比例来触发熔断，当服务的异常比例超过设定的阈值时，将触发熔断。
javaCopy code
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑，模拟异常
if (Math.random() > 0.5) {
throw new RuntimeException("Exception for testing");
}
return "Hello, Sentinel!";
}
// 定义熔断降级处理方法
public String handleBlock(Throwable e) {
return "Circuit breaker triggered due to exception ratio!";
}
// 定义熔断回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to exception ratio!";
}
}
4. 控制台配置熔断规则：
要在 Sentinel 控制台中配置熔断规则，需要执行以下步骤：
启动 Sentinel 控制台，可以使用以下命令：
java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
在浏览器中访问 http://localhost:8080，登录 Sentinel 控制台。
在控制台中选择 “熔断降级” 选项，点击 “新增规则”。
根据需要选择熔断规则类型，比如 “慢调用比例”、“快速失败” 或 “异常比例”，然后配置阈值、触发策略等。
配置完成后，点击 “添加” 按钮，即可在控制台中看到已配置的熔断规则。
QPS 自适应规则根据系统的 QPS（每秒请求数）来自动调整流量控制规则，以保护系统免受过载的影响。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to QPS adaptation!";
}
// 定义降级回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to QPS adaptation!";
}
}
平均响应时间自适应规则根据系统的平均响应时间来自动调整流量控制规则，以保证系统的稳定性。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to average RT (response time) adaptation!";
}
// 定义降级回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to average RT (response time) adaptation!";
}
}
线程数自适应规则根据系统的线程数来自动调整流量控制规则，以保证系统的稳定性和性能。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(Throwable e) {
return "Blocked due to thread count adaptation!";
}
// 定义降级回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to thread count adaptation!";
}
}
启动 Sentinel 控制台，可以使用以下命令：
java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
在浏览器中访问 http://localhost:8080，登录 Sentinel 控制台。
在控制台中选择 “系统自适应保护” 选项，点击 “新增规则”。
根据需要选择自适应规则类型，比如 “QPS 自适应”、“平均响应时间自适应” 或 “线程数自适应”，然后配置阈值、触发策略等。
配置完成后，点击 “添加” 按钮，即可在控制台中看到已配置的自适应规则。
热点参数限流可以根据方法的参数值来进行流量控制。你可以配置一些参数例外项，让这些参数的值不受限制。下面是一个例子，演示如何配置参数例外项。
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod(String parameter) {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义流控降级处理方法
public String handleBlock(String parameter, BlockException ex) {
return "Blocked due to parameter hot spot flow control!";
}
// 定义降级回退方法
public String fallbackMethod(String parameter) {
return "Fallback due to parameter hot spot flow control!";
}
}
启动 Sentinel 控制台，可以使用以下命令：
java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
在浏览器中访问 http://localhost:8080，登录 Sentinel 控制台。
在控制台中选择 “热点参数限流” 选项，点击 “新增规则”。
配置资源名称，可以使用 @SentinelResource 注解中的 value 值，例如 “demoResource”。
在 “参数例外项” 中，添加不需要限制的参数值。例如，配置参数名为 parameter，例外项值为 exceptionValue。
配置其他限流规则，如阈值、统计窗口等。
配置完成后，点击 “添加” 按钮，即可在控制台中看到已配置的热点参数规则。
在 Spring Cloud Alibaba 中，可以使用 Nacos 作为服务注册和配置中心，结合 Gateway 实现网关限流。
Maven：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
在 Nacos 配置中心中配置 Sentinel 的流控规则，例如，配置一个限制访问 /api/hello 的规则。
spring:
cloud:
sentinel:
transport:
dashboard: localhost:8080
创建一个简单的 Gateway 配置类：
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import reactor.core.publisher.Mono;
import com.alibaba.csp.sentinel.adapter.gateway.sc.SentinelGatewayFilter;
import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.BlockRequestHandler;
import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.GatewayCallbackManager;
@Configuration
public class GatewayConfig {
@Value("${spring.cloud.sentinel.transport.dashboard}")
private String dashboard;
@Bean
public GlobalFilter sentinelGatewayFilter() {
return new SentinelGatewayFilter();
}
@PostConstruct
public void initBlockHandler() {
BlockRequestHandler blockRequestHandler = (serverWebExchange, throwable) ->
Mono.fromCallable(() -> "Blocked by Sentinel: " + throwable.getClass().getSimpleName());
GatewayCallbackManager.setBlockHandler(blockRequestHandler);
}
}
以上配置启动成功后即整合完成，注意一定要启动sentinel服务！
Maven：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
配置 Sentinel 的流控规则，可以在 Nacos 配置中心中配置。
创建一个带有 Sentinel 流控保护的 RestTemplate 配置类：
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
import com.alibaba.cloud.sentinel.annotation.SentinelRestTemplate;
@Configuration
public class RestTemplateConfig {
@Bean
@SentinelRestTemplate
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
在需要调用其他微服务的地方使用 RestTemplate：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
@Service
public class MyService {
@Autowired
private RestTemplate restTemplate;
public String callOtherService() {
// 使用 RestTemplate 进行调用，会受到 Sentinel 流控保护
return restTemplate.getForObject("http://other-service/api/hello", String.class);
}
}
以上仅仅提供了基本代码案例和操作步骤，用于演示 Spring Cloud Alibaba 中集成 Sentinel，实际项目中还需要配置 Sentinel 控制台、Nacos 注册中心等。
Nacos 可以作为配置中心来管理 Sentinel 的规则配置
Maven：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
在 Nacos 配置中心中创建配置项，例如 sentinel-demo-rules.json，用于存储 Sentinel 的规则配置：
[
{
"resource": "demoResource",
"limitApp": "default",
"grade": 1,
"count": 10
}
]
在应用的 bootstrap.yml 或 bootstrap.properties 中配置 Nacos 作为配置中心：
spring:
cloud:
nacos:
config:
server-addr: localhost:8848
file-extension: json
group: DEFAULT_GROUP
namespace: your-namespace # 替换为你的命名空间
@EnableNacosConfig 注解：import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.alibaba.nacos.config.EnableNacosConfig;
@SpringBootApplication
@EnableNacosConfig
public class SentinelNacosDemoApplication {
public static void main(String[] args) {
SpringApplication.run(SentinelNacosDemoApplication.class, args);
}
}
@SentinelResource 注解，配置资源名与 Nacos 中的配置对应：import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
}
Nacos 可以作为数据持久化存储 Sentinel 的统计数据。
Maven：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
sentinel-metrics.yml，用于存储 Sentinel 的统计数据持久化配置：sentinel:
transport:
dashboard: localhost:8080
nacos:
server-addr: localhost:8848
group-id: DEFAULT_GROUP
namespace: your-namespace # 替换为你的命名空间
@EnableNacosConfig 注解：import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.alibaba.nacos.config.EnableNacosConfig;
@SpringBootApplication
@EnableNacosConfig
public class SentinelNacosMetricsDemoApplication {
public static void main(String[] args) {
SpringApplication.run(SentinelNacosMetricsDemoApplication.class, args);
}
}
以上只是简单的 Spring Cloud Alibaba 中集成 Sentinel 和 Nacos 的规则配置和统计数据持久化，生产环境请根据实际业务配置。
Sentinel 控制台 Dashboard 提供了图表展示、规则配置、应用信息查看等功能，帮助你监控和管理微服务的流量控制和熔断降级等策略。
Sentinel 控制台 Dashboard 提供了以下主要功能：
在处理降级和熔断时，需要根据业务需求选择合适的策略和处理方法。以下是一些示例代码和操作步骤，用于演示如何处理降级和熔断。
处理降级：
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义降级回退方法
public String fallbackMethod() {
return "Fallback due to degradation!";
}
}
处理熔断：
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(value = "demoResource", blockHandler = "handleBlock", fallback = "fallbackMethod")
public String demoMethod() {
// 业务逻辑
return "Hello, Sentinel!";
}
// 定义熔断降级处理方法
public String handleBlock(Throwable e) {
return "Circuit breaker triggered!";
}
// 定义降级回退方法
public String fallbackMethod(Throwable e) {
return "Fallback due to circuit breaker!";
}
}
在 Sentinel 中，规则的优先级从高到低依次是：系统保护规则 > 流控规则 > 热点参数限流规则 > 授权规则 > 降级规则 > 熔断规则。
系统保护规则是最高优先级，其次是流控规则，然后是热点参数限流规则，依此类推。如果存在多个规则，Sentinel 会根据优先级的顺序依次检查，一旦命中生效的规则，则不再继续匹配其他规则。
以下是一个示例代码和操作步骤，演示如何设置不同类型规则的优先级。
创建一个 Spring Cloud Alibaba Sentinel 项目。
引入相关依赖，如 spring-cloud-starter-alibaba-sentinel。
配置 Sentinel 控制台地址，在 application.properties 或 application.yml 中添加：
spring:
cloud:
sentinel:
transport:
dashboard: localhost:8080
创建一个 Service 类，配置不同类型的规则，设置优先级：
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
@Service
public class MyService {
@SentinelResource(
value = "systemRule",
blockHandler = "systemRuleBlockHandler"
)
public String systemRuleDemo() {
// 业务逻辑
return "System Rule Demo";
}
@SentinelResource(
value = "flowRule",
blockHandler = "flowRuleBlockHandler"
)
public String flowRuleDemo() {
// 业务逻辑
return "Flow Rule Demo";
}
@SentinelResource(
value = "hotParamRule",
blockHandler = "hotParamRuleBlockHandler"
)
public String hotParamRuleDemo(String param) {
// 业务逻辑
return "Hot Param Rule Demo";
}
@SentinelResource(
value = "degradeRule",
blockHandler = "degradeRuleBlockHandler"
)
public String degradeRuleDemo() {
// 业务逻辑
return "Degrade Rule Demo";
}
@SentinelResource(
value = "circuitBreakerRule",
blockHandler = "circuitBreakerRuleBlockHandler"
)
public String circuitBreakerRuleDemo() {
// 业务逻辑
return "Circuit Breaker Rule Demo";
}
// 省略其他业务方法和降级处理方法
}
import org.springframework.stereotype.Component;
import com.alibaba.csp.sentinel.slots.block.BlockException;
@Component
public class BlockHandler {
public String systemRuleBlockHandler(BlockException ex) {
return "Blocked by System Rule";
}
public String flowRuleBlockHandler(BlockException ex) {
return "Blocked by Flow Rule";
}
public String hotParamRuleBlockHandler(String param, BlockException ex) {
return "Blocked by Hot Param Rule";
}
public String degradeRuleBlockHandler(BlockException ex) {
return "Blocked by Degrade Rule";
}
public String circuitBreakerRuleBlockHandler(BlockException ex) {
return "Blocked by Circuit Breaker Rule";
}
}
通过以上步骤，你可以理解和体验不同类型规则的优先级以及如何设置和配置它们。根据实际业务需求，你可以根据优先级的关系，适当调整规则的配置，确保 Sentinel 规则的正确生效，以达到稳定的微服务运行状态。
⏳ 名言警句：说会的，说对的
✨ 原创不易，还希望各位大佬支持一下