qidao123.com ToB IT社区-企服评测·应用市场»论坛 › 软件与程序人生 › DevOps与敏捷开发 › Sentinel规则长期化Push模式两种实现方式

Sentinel规则长期化Push模式两种实现方式

[复制链接]
发表于 2026-2-22 11:03:41 | 显示全部楼层 |阅读模式

马上注册，结交更多好友，享用更多功能，让你轻松玩转社区。

您需要 登录 才可以下载或查看，没有账号？立即注册

×
前置知识 pull模式

sentinel长期化push推模式

pull拉模式的缺点，以生存当地文件举例：

      
  • 定时使命是每隔3s实验一次，去判断规则长期化文件的末了修改时间。这里有肯定时间的延长，但如果时间设置的太短，有影响服务器的性能  
  • 我们的微服务是集群摆设的，其他服务实例可读取不到我这台服务器的当地文件


以是另有一种push推送模式。我们一样平常会引入第三方中心件来实现，以Nacos为例。我们修改了nacos中的设置，它就会将更新后的数据推送给微服务。


push模式有两种实现方式：

      
  • 在微服务端添加读数据源，为dataId添加监听器，当规则设置文件更改之后我就获取到更改后的规则内存并更新内存中的数据；再添加一个写数据源，每当dashboard中更新了规则，我除了更新内存中的数据之外，我通过ConfigService.publishConfig()方法还往Nacos端举行写入
      
  • 在dashboard源码中举行更改，在获取规则内容、更新规则内容的接口中，不要和微服务端举行交互，直接去和Nacos通讯，通过ConfigService.publishConfig()和ConfigService.getConfig()来实现。这种方式告急注意dashboard端的规则实体对象和微服务端的规则实体对象不划一题目，须要颠末转换干系的操纵。sentinel默认情况下就直接把规则实体转换为json字符串推送给Nacos，Nacos设置文件更改了，又推送给微服务，微服务这边再把json字符串转换为规则实体对象这一步就会发现，转换失败了，某些属性对应不上。进而就导致了dashboard端设置的规则在微服务这边未收效。



微服务端的实现

具体实现

引入读数据源的依靠
  1. <dependency>
  2.     <groupId>com.alibaba.csp</groupId>
  3.     <artifactId>sentinel-datasource-nacos</artifactId>
  4. </dependency>
复制代码


设置文件中添加规则长期化的dataId
  1. server:
  2.   port: 8806
  4. spring:
  5.   application:
  6.     name: mall-user-sentinel-rule-push  #微服务名称
  7.    
  8.   #配置nacos注册中心地址
  9.   cloud:
  10.     nacos:
  11.       discovery:
  12.         server-addr: 127.0.0.1:8848
  14.     sentinel:
  15.       transport:
  16.         # 添加sentinel的控制台地址
  17.         dashboard: 127.0.0.1:8080
  18.       datasource:
  19.         # 名称自定义，可以随便定义字符串
  20.         flow-rules:
  21.           nacos:
  22.             server-addr: 127.0.0.1:8848
  23.             # dataId取了微服务名字，后面再拼接字符串
  24.             dataId: ${
  25.    
  26.    spring.application.name}-flow-rules
  27.             # 我这里在Nacos配置中心，单独使用了一个组
  28.             groupId: SENTINEL_GROUP
  29.             username: nacos
  30.             password: nacos
  31.             data-type: json
  32.             rule-type: flow
  33.         degrade-rules:
  34.           nacos:
  35.             server-addr: 127.0.0.1:8848
  36.             dataId: ${
  37.    
  38.    spring.application.name}-degrade-rules
  39.             groupId: SENTINEL_GROUP
  40.             username: nacos
  41.             password: nacos
  42.             data-type: json
  43.             rule-type: degrade
  44.         param-flow-rules:
  45.           nacos:
  46.             server-addr: 127.0.0.1:8848
  47.             dataId: ${
  48.    
  49.    spring.application.name}-param-flow-rules
  50.             groupId: SENTINEL_GROUP
  51.             username: nacos
  52.             password: nacos
  53.             data-type: json
  54.             rule-type: param-flow
  55.         authority-rules:
  56.           nacos:
  57.             server-addr: 127.0.0.1:8848
  58.             dataId: ${
  59.    
  60.    spring.application.name}-authority-rules
  61.             groupId: SENTINEL_GROUP
  62.             username: nacos
  63.             password: nacos
  64.             data-type: json
  65.             rule-type: authority
  66.         system-rules:
  67.           nacos:
  68.             server-addr: 127.0.0.1:8848
  69.             dataId: ${
  70.    
  71.    spring.application.name}-system-rules
  72.             groupId: SENTINEL_GROUP
  73.             username: nacos
  74.             password: nacos
  75.             data-type: json
  76.             rule-type: system
复制代码


在Nacos设置中心中创建对应的设置文件



编写java类，界说写数据源
  1. import com.alibaba.cloud.sentinel.SentinelProperties;
  2. import com.alibaba.cloud.sentinel.custom.SentinelAutoConfiguration;
  3. import org.springframework.boot.autoconfigure.AutoConfigureAfter;
  4. import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
  5. import org.springframework.context.annotation.Bean;
  6. import org.springframework.context.annotation.Configuration;
  8. /**
  9. * 添加往Nacos的写数据源，只不过未使用InitFunc
  10. * 如果要使用就需要放开注解
  11. */
  12. @Configuration(proxyBeanMethods = false)
  13. @AutoConfigureAfter(SentinelAutoConfiguration.class)
  14. public class SentinelNacosDataSourceConfiguration {
  15.    
  16.    
  17.     @Bean
  18.     @ConditionalOnMissingBean
  19.     public SentinelNacosDataSourceHandler sentinelNacosDataSourceHandler(SentinelProperties sentinelProperties) {
  20.    
  21.    
  22.         return new SentinelNacosDataSourceHandler(sentinelProperties);
  23.     }
  24. }
复制代码
  1. import com.alibaba.cloud.sentinel.SentinelProperties;
  2. import com.alibaba.cloud.sentinel.datasource.RuleType;
  3. import com.alibaba.cloud.sentinel.datasource.config.DataSourcePropertiesConfiguration;
  4. import com.alibaba.cloud.sentinel.datasource.config.NacosDataSourceProperties;
  5. import com.alibaba.csp.sentinel.command.handler.ModifyParamFlowRulesCommandHandler;
  6. import com.alibaba.csp.sentinel.datasource.WritableDataSource;
  7. import com.alibaba.csp.sentinel.slots.block.authority.AuthorityRule;
  8. import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
  9. import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
  10. import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRule;
  11. import com.alibaba.csp.sentinel.slots.system.SystemRule;
  12. import com.alibaba.csp.sentinel.transport.util.WritableDataSourceRegistry;
  13. import com.alibaba.fastjson.JSON;
  14. import org.springframework.beans.factory.SmartInitializingSingleton;
  16. import java.util.List;
  18. /**
  19. * sentinel 规则持久化到 nacos配置中心
  20. */
  21. public class SentinelNacosDataSourceHandler implements SmartInitializingSingleton {
  22.    
  23.    
  25.     private final SentinelProperties sentinelProperties;
  27.     public SentinelNacosDataSourceHandler(SentinelProperties sentinelProperties) {
  28.    
  29.    
  30.         this.sentinelProperties = sentinelProperties;
  31.     }
  33.     @Override
  34.     public void afterSingletonsInstantiated() {
  35.    
  36.    
  37.         // 遍历我们配置文件中指定的多个spring.cloud.sentinel.datasource的多个配置
  38.         sentinelProperties.getDatasource().values().forEach(this::registryWriter);
  39.     }
  41.     private void registryWriter(DataSourcePropertiesConfiguration dataSourceProperties) {
  42.    
  43.    
  44.         // 只获取application.yml文件中 nacos配置的数据源
  45.         final NacosDataSourceProperties nacosDataSourceProperties = dataSourceProperties.getNacos();
  46.         if (nacosDataSourceProperties == null) {
  47.    
  48.    
  49.             return;
  50.         }
  51.         // 获取规则类型，然后根据各个类型创建相应的写数据源
  52.         final RuleType ruleType = nacosDataSourceProperties.getRuleType();
  53.         switch (ruleType) {
  54.    
  55.    
  56.             case FLOW:
  57.                 WritableDataSource<List<FlowRule>> flowRuleWriter = new NacosWritableDataSource<>(nacosDataSourceProperties, JSON::toJSONString);
  58.                 WritableDataSourceRegistry.registerFlowDataSource(flowRuleWriter);
  59.                 break;
  60.             case DEGRADE:
  61.                 WritableDataSource<List<DegradeRule>> degradeRuleWriter = new NacosWritableDataSource<>(nacosDataSourceProperties, JSON::toJSONString);
  62.                 WritableDataSourceRegistry.registerDegradeDataSource(degradeRuleWriter);
  63.                 break;
  64.             case PARAM_FLOW:
  65.                 WritableDataSource<List<ParamFlowRule>> paramFlowRuleWriter = new NacosWritableDataSource<>(nacosDataSourceProperties, JSON::toJSONString);
  66.                 ModifyParamFlowRulesCommandHandler.setWritableDataSource(paramFlowRuleWriter);
  67.                 break;
  68.             case SYSTEM:
  69.                 WritableDataSource<List<SystemRule>> systemRuleWriter = new NacosWritableDataSource<>(nacosDataSourceProperties, JSON::toJSONString);
  70.                 WritableDataSourceRegistry.registerSystemDataSource(systemRuleWriter);
  71.                 break;
  72.             case AUTHORITY:
  73.                 WritableDataSource<List<AuthorityRule>> authRuleWriter = new NacosWritableDataSource<>(nacosDataSourceProperties, JSON::toJSONString);
  74.                 WritableDataSourceRegistry.registerAuthorityDataSource(authRuleWriter);
  75.                 break;
  76.             default:
  77.                 break;
  78.         }
  79.     }
  80. }
复制代码
  1. import com.alibaba.cloud.sentinel.datasource.config.NacosDataSourceProperties;
  2. import com.alibaba.csp.sentinel.datasource.Converter;
  3. import com.alibaba.csp.sentinel.datasource.WritableDataSource;
  4. import com.alibaba.nacos.api.NacosFactory;
  5. import com.alibaba.nacos.api.PropertyKeyConst;
  6. import com.alibaba.nacos.api.config.ConfigService;
  7. import com.alibaba.nacos.api.exception.NacosException;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.springframework.util.StringUtils;
  11. import java.util.Properties;
  12. import java.util.concurrent.locks.Lock;
  13. import java.util.concurrent.locks.ReentrantLock;
  15. /**
  16. * 将sentinel规则写入到nacos配置中心
  17. * @param <T>
  18. */
  19. @Slf4j
  20. public class NacosWritableDataSource<T> implements WritableDataSource<T> {
  21.    
  22.    
  24.     private final Converter<T, String> configEncoder;
  25.     private final NacosDataSourceProperties nacosDataSourceProperties;
  27.     private final Lock lock = new ReentrantLock(true);
  28.     private ConfigService configService = null;
  30.     public NacosWritableDataSource(NacosDataSourceProperties nacosDataSourceProperties, Converter<T, String> configEncoder) {
  31.    
  32.    
  33.         if (configEncoder == null) {
  34.    
  35.    
  36.             throw new IllegalArgumentException("Config encoder cannot be null");
  37.         }
  38.         if (nacosDataSourceProperties == null) {
  39.    
  40.    
  41.             throw new IllegalArgumentException("Config nacosDataSourceProperties cannot be null");
  42.         }
  43.         this.configEncoder = configEncoder;
  44.         this.nacosDataSourceProperties = nacosDataSourceProperties;
  45.         final Properties properties = buildProperties(nacosDataSourceProperties);
  46.         try {
  47.    
  48.    
  49.             // 也可以直接注入NacosDataSource，然后反射获取其configService属性
  50.             this.configService = NacosFactory.createConfigService(properties);
  51.         } catch (NacosException e) {
  52.    
  53.    
  54.             log.error("create configService failed.", e);
  55.         }
  56.     }
  58.     private Properties buildProperties(NacosDataSourceProperties nacosDataSourceProperties) {
  59.    
  60.    
  61.         Properties properties = new Properties();
  62.         if (!StringUtils.isEmpty(nacosDataSourceProperties.getServerAddr())) {
  63.    
  64.    
  65.             properties.setProperty(PropertyKeyConst.SERVER_ADDR, nacosDataSourceProperties.getServerAddr());
  66.         } else {
  67.    
  68.    
  69.             properties.setProperty(PropertyKeyConst.ACCESS_KEY, nacosDataSourceProperties.getAccessKey());
  70.             properties.setProperty(PropertyKeyConst.SECRET_KEY, nacosDataSourceProperties.getSecretKey());
  71.             properties.setProperty(PropertyKeyConst.ENDPOINT, nacosDataSourceProperties.getEndpoint());
  72.         }
  73.         if (!StringUtils.isEmpty(nacosDataSourceProperties.getNamespace())) {
  74.    
  75.    
  76.             properties.setProperty(PropertyKeyConst.NAMESPACE, nacosDataSourceProperties.getNamespace());
  77.         }
  78.         if (!StringUtils.isEmpty(nacosDataSourceProperties.getUsername())) {
  79.    
  80.    
  81.             properties.setProperty(PropertyKeyConst.USERNAME, nacosDataSourceProperties.getUsername());
  82.         }
  83.         if (!StringUtils.isEmpty(nacosDataSourceProperties.getPassword())) {
  84.    
  85.    
  86.             properties.setProperty(PropertyKeyConst.PASSWORD, nacosDataSourceProperties.getPassword());
  87.         }
  88.         return properties;
  89.     }
  91.     @Override
  92.     public void write(T value) throws Exception {
  93.    
  94.    
  95.         lock.lock();
  96.         // todo handle cluster concurrent problem
  97.         try {
  98.    
  99.    
  100.             String convertResult = configEncoder.convert(value);
  101.             if (configService == null) {
  102.    
  103.    
  104.                 log.error("configServer is null, can not continue.");
  105.                 return;
  106.             }
  107.             // 规则配置数据推送到nacos配置中心
  108.             final boolean published = configService.publishConfig(nacosDataSourceProperties.getDataId(), nacosDataSourceProperties.getGroupId(), convertResult);
  109.             if (!published) {
  110.    
  111.    
  112.                 log.error("sentinel {} publish to nacos failed.", nacosDataSourceProperties.getRuleType());
  113.             }
  114.         } finally {
  115.    
  116.    
  117.             lock.unlock();
  118.         }
  119.     }
  121.     @Override
  122.     public void close() throws Exception {
  123.    
  124.    
  126.     }
  127. }
复制代码


启动微服务举行测试。
dashboard中为某个接口界说一个流控规则



调用接口测试，发送三次哀求



检察Nacos中的设置文件，就会发现也乐成写入了



源码分析

读数据源

引入读数据源的依靠，我们来看看具体是怎么实现的
  1. <dependency>
  2.     <groupId>com.alibaba.csp</groupId>
  3.     <artifactId>sentinel-datasource-nacos</artifactId>
  4. </dependency>
复制代码


实现思绪：

      
  • 和文件的读数据源一样，继续了AbstractDataSource类，如许就不须要我们再去写一遍加载设置、更新内存中的设置
在源码中的这个扩展包下面，就有nacos读数据源的实现



我们先看看NacosDataSource类的父类的代码

      
  • 创建一个DynamicSentinelProperty对象，告急作用是更新内存中的规则设置  
  • 加载设置、分析设置
  1. public abstract class AbstractDataSource<S, T> implements ReadableDataSource<S, T> {
  2.    
  3.    
  5.     protected final Converter<S, T> parser;
  6.     protected final SentinelProperty<T> property;
  8.     public AbstractDataSource(Converter<S, T> parser)
复制代码
回复

使用道具 举报

返回列表

李优秀
+ 我要发帖

登录后关闭弹窗

登录参与点评抽奖  加入IT实名职场社区
去登录
快速回复 返回顶部 返回列表