Sentinel控制台改造：规则同步到Nacos

时间：2025-04-14 07:08:41

Sentinel生产环境改造控制台使规则同步到Nacos

  • 首先下载Sentinel控制台的源码
  • 修改文件
  • 修改
  • 创建Nacos配置类
  • 拉取Nacos配置
  • 推送配置给Nacos
  • 修改注入的Bean
  • 结束语

官方给出的文档：在生产环境中使用-Sentinel
我们要实现push 模式，推送规则为Sentinel 控制台 → Nacos配置中心 → Sentinel 数据源 → Sentinel
下面以限流规则为例改造控制台

首先下载Sentinel控制台的源码

Sentinel源码
然后打开源码中的sentinel-dashboard项目

修改文件

 <!-- for Nacos rule publisher sample -->
        <dependency>
            <groupId></groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
        </dependency>

修改

找到sentinel-dashboard\src\main\webapp\resources\app\scripts\directives\sidebar中的
把

<li ui-sref-active="active">
    <a ui-sref="dashboard.flowV1({app: })">
        <i class="glyphicon glyphicon-filter"></i>&nbsp;&nbsp;流控规则
    </a>
</li>

修改为：

<li ui-sref-active="active">
    <a ui-sref="({app: })">
        <i class="glyphicon glyphicon-filter"></i>&nbsp;&nbsp;流控规则
    </a>
</li>

创建Nacos配置类

在包下新建一个nacos包
在nacos包下创建下面的类：

import ;
import ;
import ;
import ;
import ;
import ;
import ;
import ;

import ;
import ;

/**
 * @author dingshh
 * @since 1.7.1
 */
@Configuration
public class NacosConfig {

    @Bean
    public Converter<List<FlowRuleEntity>, String> flowRuleEntityEncoder() {
        return JSON::toJSONString;
    }

    @Bean
    public Converter<String, List<FlowRuleEntity>> flowRuleEntityDecoder() {
        return s -> (s, );
    }

    @Bean
    public ConfigService nacosConfigService() throws Exception {
        Properties properties = new Properties();
        (PropertyKeyConst.SERVER_ADDR, "NacosIp:端口号");
//        (, "xxx");
        return (properties);
    }
}

其中NacosIp:端口号对应Nacos配置中心的Ip地址和端口号
如果用到了namespace隔离环境，可以在nacosConfigService方法中再加入配置(, “xxx”);

拉取Nacos配置

在nacos包下创建下面的类：

import ;
import ;
import ;
import ;
import ;
import ;
import ;

import ;
import ;

/**
 * @author dingshh
 * @since 1.7.1
 */
@Component("flowRuleNacosProvider")
public class FlowRuleNacosProvider implements DynamicRuleProvider<List<FlowRuleEntity>> {

    @Autowired
    private ConfigService configService;
    @Autowired
    private Converter<String, List<FlowRuleEntity>> converter;

    public static final String FLOW_DATA_ID_POSTFIX = "sentinel";
    public static final String GROUP_ID = "DEFAULT_GROUP";

    @Override
    public List<FlowRuleEntity> getRules(String appName) throws Exception {
        String rules = (FLOW_DATA_ID_POSTFIX, GROUP_ID, 3000);
        if ((rules)) {
            return new ArrayList<>();
        }
        return (rules);
    }
}

推送配置给Nacos

在nacos包下创建下面的类：

import ;
import ;
import ;
import ;
import ;
import ;
import ;

import ;

/**
 * @author dingshh
 * @since 1.7.1
 */
@Component("flowRuleNacosPublisher")
public class FlowRuleNacosPublisher implements DynamicRulePublisher<List<FlowRuleEntity>> {

    @Autowired
    private ConfigService configService;
    @Autowired
    private Converter<List<FlowRuleEntity>, String> converter;

    public static final String FLOW_DATA_ID_POSTFIX = "sentinel";
    public static final String GROUP_ID = "DEFAULT_GROUP";

    @Override
    public void publish(String app, List<FlowRuleEntity> rules) throws Exception {
        (app, "app name cannot be empty");
        if (rules == null) {
            return;
        }
        (FLOW_DATA_ID_POSTFIX, GROUP_ID, (rules));
    }
}

修改注入的Bean

修改`.v2.FlowControllerV2

	@Autowired
    @Qualifier("flowRuleNacosProvider")
    private DynamicRuleProvider<List<FlowRuleEntity>> ruleProvider;
    @Autowired
    @Qualifier("flowRuleNacosPublisher")
    private DynamicRulePublisher<List<FlowRuleEntity>> rulePublisher;

结束语

以上仅仅是修改了限流规则与Nacos配置中心的同步。
以下是我的代码地址，完整代码中实现了正常模式和网关模式的所有规则同步。
github地址

相关文章