Sentinel Dashboard 中修改规则同步到 Nacos

点击蓝色“程序猿DD”关注我哟

加个“星标”，不忘签到哦


Sentinel Dashboard 中修改规则同步到 Nacos



上一篇我们介绍了如何通过改造Sentinel Dashboard来实现修改规则之后自动同步到Apollo。下面通过这篇，详细介绍当使用Nacos作为配置中心之后，如何实现Sentinel Dashboard中修改规则同步到Nacos。关于下面改造的原理和分析可以见上一篇《Sentinel Dashboard中修改规则同步到Apollo》的头两节内容，本篇就不重复介绍了。

代码实现

下面直接来看看如何实现的具体改造步骤，这里参考了 SentinelDashboard源码中关于Nacos实现的测试用例。但是由于考虑到与Spring Cloud Alibaba的结合使用，略作修改。

第一步：修改 pom.xml中的sentinel-datasource-nacos的依赖，将 <scope>test</scope>注释掉，这样才能在主程序中使用。



    

  1. <dependency>
    2. 

  2.  <groupId>com.alibaba.csp</groupId>
    3. 

  3.  <artifactId>sentinel-datasource-nacos</artifactId>
    4. 

  4.  <!--<scope>test</scope>-->
    5. 

  5. </dependency>
    6. 



第二步：找到 resources/app/scripts/directives/sidebar/sidebar.html中的这段代码：




    

  1. <li ui-sref-active="active">
    2. 

  2.  <a ui-sref="dashboard.flowV1({app: entry.app})">
    3. 

  3.  <i class="glyphicon glyphicon-filter"></i>&nbsp;&nbsp;流控规则
    4. 

  4.  </a>
    5. 

  5. </li>
    6. 



修改为：




    

  1. <li ui-sref-active="active">
    2. 

  2.  <a ui-sref="dashboard.flow({app: entry.app})">
    3. 

  3.  <i class="glyphicon glyphicon-filter"></i>&nbsp;&nbsp;流控规则
    4. 

  4.  </a>
    5. 

  5. </li>
    6. 



第三步：在 com.alibaba.csp.sentinel.dashboard.rule包下新建一个nacos包，用来编写针对Nacos的扩展实现。


第四步：创建Nacos的配置类，具体代码如下：




    

  1. @Configuration
    2. 

  2. public class NacosConfig {
    3. 


    4. 

  4.  @Bean
    5. 

  5.  public Converter<List<FlowRuleEntity>, String> flowRuleEntityEncoder() {
    6. 

  6.  return JSON::toJSONString;
    7. 

  7.  }
    8. 


    9. 

  9.  @Bean
    10. 

  10.  public Converter<String, List<FlowRuleEntity>> flowRuleEntityDecoder() {
    11. 

  11.  return s -> JSON.parseArray(s, FlowRuleEntity.class);
    12. 

  12.  }
    13. 


    14. 

  14.  @Bean
    15. 

  15.  public ConfigService nacosConfigService() throws Exception {
    16. 

  16.  Properties properties = new Properties();
    17. 

  17.  properties.put(PropertyKeyConst.SERVER_ADDR, "localhost");
    18. 

  18.  return ConfigFactory.createConfigService(properties);
    19. 

  19.  }
    20. 

  20. }
    21. 



如果用到了namespace隔离环境，可以在 nacosConfigService方法中再加入配置，比如： properties.put(PropertyKeyConst.NAMESPACE,"130e71fa-97fe-467d-ad77-967456f2c16d");


第五步：实现Nacos的配置拉取。




    

  1. @Component("flowRuleNacosProvider")
    2. 

  2. public class FlowRuleNacosProvider implements DynamicRuleProvider<List<FlowRuleEntity>> {
    3. 


    4. 

  4.  @Autowired
    5. 

  5.  private ConfigService configService;
    6. 

  6.  @Autowired
    7. 

  7.  private Converter<String, List<FlowRuleEntity>> converter;
    8. 


    9. 

  9.  public static final String FLOW_DATA_ID_POSTFIX = "-sentinel";
    10. 

  10.  public static final String GROUP_ID = "DEFAULT_GROUP";
    11. 


    12. 

  12.  @Override
    13. 

  13.  public List<FlowRuleEntity> getRules(String appName) throws Exception {
    14. 

  14.  String rules = configService.getConfig(appName + FLOW_DATA_ID_POSTFIX, GROUP_ID, 3000);
    15. 

  15.  if (StringUtil.isEmpty(rules)) {
    16. 

  16.  return new ArrayList<>();
    17. 

  17.  }
    18. 

  18.  return converter.convert(rules);
    19. 

  19.  }
    20. 

  20. }
    21. 



    

  • getRules方法中的 appName参数是Sentinel中的服务名称。
    • 

  • configService.getConfig方法是从Nacos中获取配置信息的具体操作。其中，DataId和GroupId分别对应客户端使用时候的对应配置。比如这里的例子对应了之前我们在《Sentinel使用Nacos存储规则》一文中的配置，具体如下：
    • 





    

  1. spring.cloud.sentinel.datasource.ds.nacos.groupId=DEFAULT_GROUP
    2. 

  2. spring.cloud.sentinel.datasource.ds.nacos.dataId=${spring.application.name}-sentinel
    3. 



注意：两边的DataId和GroupId必须对应上。


第六步：实现Nacos的配置推送。




    

  1. @Component("flowRuleNacosPublisher")
    2. 

  2. public class FlowRuleNacosPublisher implements DynamicRulePublisher<List<FlowRuleEntity>> {
    3. 


    4. 

  4.  @Autowired
    5. 

  5.  private ConfigService configService;
    6. 

  6.  @Autowired
    7. 

  7.  private Converter<List<FlowRuleEntity>, String> converter;
    8. 


    9. 

  9.  public static final String FLOW_DATA_ID_POSTFIX = "-sentinel";
    10. 

  10.  public static final String GROUP_ID = "DEFAULT_GROUP";
    11. 


    12. 

  12.  @Override
    13. 

  13.  public void publish(String app, List<FlowRuleEntity> rules) throws Exception {
    14. 

  14.  AssertUtil.notEmpty(app, "app name cannot be empty");
    15. 

  15.  if (rules == null) {
    16. 

  16.  return;
    17. 

  17.  }
    18. 

  18.  configService.publishConfig(app + FLOW_DATA_ID_POSTFIX, GROUP_ID, converter.convert(rules));
    19. 

  19.  }
    20. 

  20. }
    21. 



  • 这里的大部分内容与上一步中的实现一致。主要就是Nacos中存储配置的DataId和GroupId不要弄错。


第七步：修改 com.alibaba.csp.sentinel.dashboard.controller.v2.FlowControllerV2中 DynamicRuleProvider和 DynamicRulePublisher注入的Bean，改为上面我们编写的针对Apollo的实现：




    

  1. @Autowired
    2. 

  2. @Qualifier("flowRuleNacosProvider")
    3. 

  3. private DynamicRuleProvider<List<FlowRuleEntity>> ruleProvider;
    4. 

  4. @Autowired
    5. 

  5. @Qualifier("flowRuleNacosPublisher")
    6. 

  6. private DynamicRulePublisher<List<FlowRuleEntity>> rulePublisher;
    7. 



最后，读者可以使用本文改造后的sentinel-dashboard联合之前《Sentinel使用Nacos存储规则》一文的例子来验证本文内容。


代码示例


本文介绍内容的客户端代码，示例读者可以通过查看下面仓库中的 alibaba-sentinel-dashboard-nacos项目：


    

  • Github：https://github.com/dyc87112/SpringCloud-Learning/
    • 

  • Gitee：https://gitee.com/didispace/SpringCloud-Learning/
    • 



如果您对这些感兴趣，欢迎star、follow、收藏、转发给予支持！


系列回顾





推荐阅读：








号外：最近整理了之前编写的一系列内容做成了PDF，关注我并回复相应口令获取：


- 001 ：领取《Spring Boot基础教程》


- 002 ：领取《Spring Cloud基础教程》











活动介绍：自律到极致-人生才精致：第6期


活动奖励：《Service Mesh实战》* 10


扫描下面二维码签到参与


Sentinel Dashboard 中修改规则同步到 Nacos


关注我，加个星标，不忘签到哦~





2019


与大家聊聊技术人的斜杠生活


Sentinel Dashboard 中修改规则同步到 Nacos


 
                    
            
                

                  
 
        

	 
        

            

                                            

        

        
相关文章：

        

      
            
 
                    
    
                                            

               
   
         

    


  






 
          

    
猜你喜欢 

        
    
                        

   
 



    
相关资源 

        
    
              
                            

   

   
    

     
相似解决方案 

         
    
                          

    

  
   

    

 
   

    
热门标签  

    

                    Java
                        Python
                        linux
                        javascript
                        Mysql
                        C#
                        Docker
                        算法
                        前端
                        SpringBoot
                        Redis
                        Vue
                        spring
                        设计模式
                        .net core
                        .net
                        kubernetes
                        c++
                        数据库
                        数据结构
                        大数据
                        js
                        机器学习
                        微服务
                        Android
                        Go
                        程序员
                        面试
                        JVM
                        ASP.net core
                        云原生
                        人工智能
                        后端
                        PHP
                        git
                        CSS
                        golang
                        k8s
                        Nginx
                        Django
                        mybatis
                        深度学习
                        多线程
                        React
                        架构
                        devops
                        爬虫
                        云计算
                        Spring Boot
                        LeetCode