Sentinel 集成 Nacos 实现规则动态推送与持久化的过程

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.example</groupId>
    <artifactId>sentinel-nacos-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>sentinel-nacos-demo</name>
    <description>Demo project for Sentinel with Nacos</description>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.0</version> <!-- 请根据实际情况选择合适的版本 -->
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>2021.0.3</spring-cloud.version> <!-- 请根据实际情况选择合适的版本 -->
        <sentinel.version>1.8.6</sentinel.version> <!-- 请根据实际情况选择合适的版本 -->
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Sentinel 核心依赖 -->
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-core</artifactId>
            <version>${sentinel.version}</version>
        </dependency>
        <!-- Sentinel Spring Cloud Gateway 集成 (如果需要) -->
        <!--
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-spring-cloud-gateway-adapter</artifactId>
            <version>${sentinel.version}</version>
        </dependency>
        -->
        <!-- Sentinel Spring WebFlux 集成 (如果需要) -->
        <!--
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-spring-webflux-adapter</artifactId>
            <version>${sentinel.version}</version>
        </dependency>
        -->
        <!-- Sentinel 注解支持 (用于 @SentinelResource 等注解) -->
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-annotation-aspectj</artifactId>
            <version>${sentinel.version}</version>
        </dependency>
        <!-- Sentinel Nacos 扩展 -->
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
            <version>${sentinel.version}</version>
        </dependency>
        <!-- Spring Cloud Alibaba Nacos Discovery (如果需要服务发现) -->
        <!--
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <version>2021.0.4.0</version>
        </dependency>
        -->
        <!-- Spring Cloud Alibaba Nacos Config (如果需要配置中心) -->
        <!--
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
            <version>2021.0.4.0</version>
        </dependency>
        -->
        <!-- 如果你的项目是 Spring Cloud 项目，且使用了 Spring Cloud LoadBalancer，可能需要这个依赖 -->
        <!--
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-loadbalancer</artifactId>
        </dependency>
        -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

package com.example.sentinel.nacos.demo.controller;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class DemoController {
    // 定义资源名称为 "demoResource"
    @SentinelResource(value = "demoResource", blockHandler = "handleBlockException")
    @GetMapping("/demo")
    public String demo(@RequestParam(required = false) String name) {
        if (name == null || name.isEmpty()) {
            name = "World";
        }
        return "Hello, " + name + "!";
    }
    // 当触发限流或降级时，会调用此方法
    public String handleBlockException(String name, BlockException ex) {
        System.err.println("Block exception occurred: " + ex.getClass().getSimpleName());
        return "Blocked by Sentinel! Reason: " + ex.getClass().getSimpleName();
    }
}

server:
  port: 8080
spring:
  application:
    name: sentinel-nacos-demo # 应用名称，用于 Nacos 中区分不同的配置
# Sentinel 配置
spring:
  cloud:
    sentinel:
      transport:
        dashboard: localhost:8080 # Sentinel 控制台地址 (可选)
        port: 8080 # Sentinel 客户端向 Dashboard 发送心跳的端口 (可选)
      # 指定规则数据源为 Nacos
      datasource:
        # 定义第一个数据源 (流控规则)
        flow:
          nacos:
            server-addr: localhost:8848 # Nacos 地址
            group-id: SENTINEL_GROUP # Nacos 中的 Group ID
            data-id: ${spring.application.name}-flow.json # Nacos 中的 Data ID
            rule-type: flow # 规则类型 (flow: 流控, degrade: 熔断, system: 系统保护, authority: 授权)
        # 定义第二个数据源 (熔断规则)
        degrade:
          nacos:
            server-addr: localhost:8848
            group-id: SENTINEL_GROUP
            data-id: ${spring.application.name}-degrade.json
            rule-type: degrade
        # 定义第三个数据源 (热点参数规则)
        param-flow:
          nacos:
            server-addr: localhost:8848
            group-id: SENTINEL_GROUP
            data-id: ${spring.application.name}-param-flow.json
            rule-type: param-flow
        # 定义第四个数据源 (系统规则)
        system:
          nacos:
            server-addr: localhost:8848
            group-id: SENTINEL_GROUP
            data-id: ${spring.application.name}-system.json
            rule-type: system
        # 定义第五个数据源 (授权规则)
        authority:
          nacos:
            server-addr: localhost:8848
            group-id: SENTINEL_GROUP
            data-id: ${spring.application.name}-authority.json
            rule-type: authority
management:
  endpoints:
    web:
      exposure:
        include: '*'

package com.example.sentinel.nacos.demo.config;
import com.alibaba.csp.sentinel.datasource.Converter;
import com.alibaba.csp.sentinel.datasource.ReadableDataSource;
import com.alibaba.csp.sentinel.datasource.nacos.NacosDataSource;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;
import java.util.List;
@Configuration
public class SentinelConfig {
    private static final Logger logger = LoggerFactory.getLogger(SentinelConfig.class);
    @Value("${spring.cloud.sentinel.datasource.flow.nacos.server-addr}")
    private String serverAddr;
    @Value("${spring.cloud.sentinel.datasource.flow.nacos.group-id}")
    private String groupId;
    @Value("${spring.cloud.sentinel.datasource.flow.nacos.data-id}")
    private String dataId;
    @PostConstruct
    public void initFlowRules() {
        ReadableDataSource<String, List<FlowRule>> flowRuleDataSource = new NacosDataSource<>(serverAddr, groupId, dataId,
                new Converter<String, List<FlowRule>>() {
                    @Override
                    public List<FlowRule> convert(String source) {
                        logger.info("Received flow rules from Nacos: {}", source);
                        return JSON.parseObject(source, new TypeReference<List<FlowRule>>() {});
                    }
                });
        FlowRuleManager.register2Property(flowRuleDataSource.getProperty());
        logger.info("Flow rules loaded from Nacos successfully.");
    }
    // 可以类似地为其他规则类型（如 DegradeRule, SystemRule, AuthorityRule, ParamFlowRule）添加初始化逻辑
    // 示例：添加熔断规则初始化
    /*
    @Bean
    public ReadableDataSource<String, List<DegradeRule>> degradeRuleDataSource() {
        return new NacosDataSource<>(serverAddr, groupId, "sentinel-nacos-demo-degrade.json",
                source -> JSON.parseObject(source, new TypeReference<List<DegradeRule>>() {}));
    }
    */
}

http://localhost:8080/demo?name=Test

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

[
  {
    "resource": "demoResource",
    "grade": 1,
    "count": 0.1,
    "timeWindow": 10,
    "minRequestAmount": 10,
    "statIntervalMs": 1000
  }
]

[
  {
    "mode": 1,
    "threshold": 0.7
  }
]

[
  {
    "resource": "demoResource",
    "limitApp": "default",
    "count": 1,
    "grade": 1,
    "paramIdx": 0,
    "controlBehavior": 0,
    "clusterMode": false
  }
]

[
  {
    "resource": "demoResource",
    "limitApp": "default",
    "strategy": 0
  }
]