• Sentinel1.8.6集成nacos

    代码：https://gitee.com/gsls200808/sentinel-dashboard-nacos

    jar包：sentinel-dashboard-nacos 发行版 - Gitee.com

    代码如果看不到可能需要登录。

    官方参考文档：

    动态规则扩展 · alibaba/Sentinel Wiki · GitHub

    需要修改的代码如下：

    为了便于后续版本集成nacos，简单讲一下集成思路

    1.更改pom

    修改sentinel-datasource-nacos的范围

    将

    1.  <dependency>
    2.             <groupId>com.alibaba.csp</groupId>
    3.             <artifactId>sentinel-datasource-nacos</artifactId>
    4.             <scope>test</scope>
    5.         </dependency>

    改为

    1.  <dependency>
    2.             <groupId>com.alibaba.csp</groupId>
    3.             <artifactId>sentinel-datasource-nacos</artifactId>
    4.             <!--<scope>test</scope>-->
    5.         </dependency>

    2.拷贝示例

    将test目录下的com.alibaba.csp.sentinel.dashboard.rule.nacos包下的内容拷贝到src的 com.alibaba.csp.sentinel.dashboard.rule的目录

    test目录只包含限流，其他规则参照创建即可。

    创建时注意修改常量，并且在NacosConfig实现各种converter

    注意：授权规则和热点规则需要特殊处理，否则nacos配置不生效。

    因为授权规则Entity比流控规则Entity多包了一层。

    1. public class FlowRuleEntity implements RuleEntity 
    2. public class AuthorityRuleEntity extends AbstractRuleEntity

    以授权规则为例

    AuthorityRuleNacosProvider.java

    1. /*
    2.  * Copyright 1999-2018 Alibaba Group Holding Ltd.
    3.  *
    4.  * Licensed under the Apache License, Version 2.0 (the "License");
    5.  * you may not use this file except in compliance with the License.
    6.  * You may obtain a copy of the License at
    7.  *
    8.  *      http://www.apache.org/licenses/LICENSE-2.0
    9.  *
    10.  * Unless required by applicable law or agreed to in writing, software
    11.  * distributed under the License is distributed on an "AS IS" BASIS,
    12.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    13.  * See the License for the specific language governing permissions and
    14.  * limitations under the License.
    15.  */
    16. package com.alibaba.csp.sentinel.dashboard.rule.nacos.authority;
    17.  
    18. import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.AuthorityRuleEntity;
    19. import com.alibaba.csp.sentinel.dashboard.rule.DynamicRuleProvider;
    20. import com.alibaba.csp.sentinel.dashboard.rule.nacos.NacosConfigUtil;
    21. import com.alibaba.csp.sentinel.datasource.Converter;
    22. import com.alibaba.csp.sentinel.slots.block.authority.AuthorityRule;
    23. import com.alibaba.csp.sentinel.util.StringUtil;
    24. import com.alibaba.fastjson.JSON;
    25. import com.alibaba.fastjson.JSONArray;
    26. import com.alibaba.fastjson.JSONObject;
    27. import com.alibaba.nacos.api.config.ConfigService;
    28. import org.springframework.beans.factory.annotation.Autowired;
    29. import org.springframework.stereotype.Component;
    30.  
    31. import java.util.ArrayList;
    32. import java.util.List;
    33.  
    34. /**
    35.  * @author Eric Zhao
    36.  * @since 1.4.0
    37.  */
    38. @Component("authorityRuleNacosProvider")
    39. public class AuthorityRuleNacosProvider implements DynamicRuleProvider<List<AuthorityRuleEntity>> {
    41.     @Autowired
    42.     private ConfigService configService;
    43.     @Autowired
    44.     private Converter<String, List<AuthorityRuleEntity>> converter;
    46.     @Override
    47.     public List<AuthorityRuleEntity> getRules(String appName) throws Exception {
    48.         String rules = configService.getConfig(appName + NacosConfigUtil.AUTHORITY_DATA_ID_POSTFIX,
    49.                 NacosConfigUtil.GROUP_ID, 3000);
    50.         if (StringUtil.isEmpty(rules)) {
    51.             return new ArrayList<>();
    52.         }
    53.         return converter.convert(this.parseRules(rules));
    54.     }
    55.  
    56.     private String parseRules(String rules) {
    57.         JSONArray newRuleJsons = new JSONArray();
    58.         JSONArray ruleJsons = JSONArray.parseArray(rules);
    59.         for (int i = 0; i < ruleJsons.size(); i++) {
    60.             JSONObject ruleJson = ruleJsons.getJSONObject(i);
    61.             AuthorityRuleEntity ruleEntity = JSON.parseObject(ruleJson.toJSONString(), AuthorityRuleEntity.class);
    62.             JSONObject newRuleJson = JSON.parseObject(JSON.toJSONString(ruleEntity));
    63.             AuthorityRule rule = JSON.parseObject(ruleJson.toJSONString(), AuthorityRule.class);
    64.             newRuleJson.put("rule", rule);
    65.             newRuleJsons.add(newRuleJson);
    66.         }
    67.         return newRuleJsons.toJSONString();
    68.     }
    69. }

    AuthorityRuleNacosPublisher.java

    1. /*
    2.  * Copyright 1999-2018 Alibaba Group Holding Ltd.
    3.  *
    4.  * Licensed under the Apache License, Version 2.0 (the "License");
    5.  * you may not use this file except in compliance with the License.
    6.  * You may obtain a copy of the License at
    7.  *
    8.  *      http://www.apache.org/licenses/LICENSE-2.0
    9.  *
    10.  * Unless required by applicable law or agreed to in writing, software
    11.  * distributed under the License is distributed on an "AS IS" BASIS,
    12.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    13.  * See the License for the specific language governing permissions and
    14.  * limitations under the License.
    15.  */
    16. package com.alibaba.csp.sentinel.dashboard.rule.nacos.authority;
    17.  
    18. import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.AuthorityRuleEntity;
    19. import com.alibaba.csp.sentinel.dashboard.rule.DynamicRulePublisher;
    20. import com.alibaba.csp.sentinel.dashboard.rule.nacos.NacosConfigUtil;
    21. import com.alibaba.csp.sentinel.datasource.Converter;
    22. import com.alibaba.csp.sentinel.util.AssertUtil;
    23. import com.alibaba.fastjson.JSONArray;
    24. import com.alibaba.fastjson.JSONObject;
    25. import com.alibaba.nacos.api.config.ConfigService;
    26. import org.springframework.beans.factory.annotation.Autowired;
    27. import org.springframework.stereotype.Component;
    28.  
    29. import java.util.List;
    30.  
    31. /**
    32.  * @author Eric Zhao
    33.  * @since 1.4.0
    34.  */
    35. @Component("authorityRuleNacosPublisher")
    36. public class AuthorityRuleNacosPublisher implements DynamicRulePublisher<List<AuthorityRuleEntity>> {
    38.     @Autowired
    39.     private ConfigService configService;
    40.     @Autowired
    41.     private Converter<List<AuthorityRuleEntity>, String> converter;
    42.  
    43.     @Override
    44.     public void publish(String app, List<AuthorityRuleEntity> rules) throws Exception {
    45.         AssertUtil.notEmpty(app, "app name cannot be empty");
    46.         if (rules == null) {
    47.             return;
    48.         }
    49.         configService.publishConfig(app + NacosConfigUtil.AUTHORITY_DATA_ID_POSTFIX,
    50.             NacosConfigUtil.GROUP_ID,  this.parseRules(converter.convert(rules)));
    51.     }
    52.  
    53.     private String parseRules(String rules) {
    54.         JSONArray oldRuleJsons = JSONArray.parseArray(rules);
    55.         for (int i = 0; i < oldRuleJsons.size(); i++) {
    56.             JSONObject oldRuleJson = oldRuleJsons.getJSONObject(i);
    57.             JSONObject ruleJson = oldRuleJson.getJSONObject("rule");
    58.             oldRuleJson.putAll(ruleJson);
    59.             oldRuleJson.remove("rule");
    60.         }
    61.         return oldRuleJsons.toJSONString();
    62.     }
    63. }

    热点规则同理

    3.修改controller

    v2目录的FlowControllerV2

    将

    1.     @Autowired
    2.     @Qualifier("flowRuleDefaultProvider")
    3.     private DynamicRuleProvider> ruleProvider;
    4.     @Autowired
    5.     @Qualifier("flowRuleDefaultPublisher")
    6.     private DynamicRulePublisher> rulePublisher;

    改为

    1.     @Autowired
    2.     @Qualifier("flowRuleNacosProvider")
    3.     private DynamicRuleProvider> ruleProvider;
    4.     @Autowired
    5.     @Qualifier("flowRuleNacosPublisher")
    6.     private DynamicRulePublisher> rulePublisher;

    controller目录的其他controller包括AuthorityRuleController DegradeController FlowControllerV1 ParamFlowRuleController SystemController

    做如下更改(以DegradeController为例)

    将

    1. @Autowired
    2.     private SentinelApiClient sentinelApiClient;

    改成

    1.  @Autowired
    2.     @Qualifier("degradeRuleNacosProvider")
    3.     private DynamicRuleProvider> ruleProvider;
    4.     @Autowired
    5.     @Qualifier("degradeRuleNacosPublisher")
    6.     private DynamicRulePublisher> rulePublisher;

    将原有publishRules方法删除，统一改成

    1.     private void publishRules(/*@NonNull*/ String app) throws Exception {
    2.         List<DegradeRuleEntity> rules = repository.findAllByApp(app);
    3.         rulePublisher.publish(app, rules);
    4.     }

    之后解决报错的地方即可。

    获取所有rules的地方

    将

     List<DegradeRuleEntity> rules = sentinelApiClient.fetchDegradeRuleOfMachine(app, ip, port);

    改成

    List<DegradeRuleEntity> rules = ruleProvider.getRules(app);

    原有调用publishRules方法的地方，删除掉

    在上一个try catch方法里加上

    publishRules(entity.getApp());

    这里的entity.getApp()也有可能是oldEntity.getApp()/app等变量。根据删除的publishRules代码片段推测即可。

    4.修改前端文件

    文件路径:src/main/webapp/resources/app/scripts/directives/sidebar/sidebar.html

    将

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

    改成

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

    5.最后打包即可

    执行命令打包成jar

    mvn clean package

    运行方法与官方jar一致，不做赘述

    6.微服务程序集成

    pom.xml添加

    1.         <dependency>
    2.             <groupId>com.alibaba.csp</groupId>
    3.             <artifactId>sentinel-datasource-nacos</artifactId>
    4.         </dependency>

    配置文件application.yml添加

    1. spring:
    2.   cloud:
    3.     sentinel:
    4.       datasource:
    5.         # 名称随意
    6.         flow:
    7.           nacos:
    8.             server-addr: 192.168.11.5:8848
    9.             dataId: ${spring.application.name}-flow-rules
    10.             groupId: SENTINEL_GROUP
    11.             # 规则类型，取值见：
    12.             # org.springframework.cloud.alibaba.sentinel.datasource.RuleType
    13.             rule-type: flow
    14.         degrade:
    15.           nacos:
    16.             server-addr: 192.168.11.5:8848
    17.             dataId: ${spring.application.name}-degrade-rules
    18.             groupId: SENTINEL_GROUP
    19.             rule-type: degrade
    20.         system:
    21.           nacos:
    22.             server-addr: 192.168.11.5:8848
    23.             dataId: ${spring.application.name}-system-rules
    24.             groupId: SENTINEL_GROUP
    25.             rule-type: system
    26.         authority:
    27.           nacos:
    28.             server-addr: 192.168.11.5:8848
    29.             dataId: ${spring.application.name}-authority-rules
    30.             groupId: SENTINEL_GROUP
    31.             rule-type: authority
    32.         param-flow:
    33.           nacos:
    34.             server-addr: 192.168.11.5:8848
    35.             dataId: ${spring.application.name}-param-flow-rules
    36.             groupId: SENTINEL_GROUP
    37.             rule-type: param-flow

    7.测试验证

    在sentinel控制台界面添加几个流控规则后尝试关闭微服务和sentinel，然后重新打开sentinel和微服务，看流控规则是否还在。

  • 相关阅读:
    springboot实现ACL+RBAC权限体系
    sprinboot 引入 Elasticsearch 依赖包
    牛客刷题——前端面试【六】谈一谈 v-if、v-show、v-for（区别、注意事项）
    centos7搭建EFK日志收集系统
    mybatis学习(19):模糊查询#
    4.力扣c++刷题--＞删除有序数组中的重复项 II
    【数据结构】带头双向循环链表
    【web-攻击会话管理】（4.1）会话状态：状态要求、会话替代方案
    跟着CTF-wiki学pwn——ret2libc1
    asp核酸检测预登记系统源码
  • 原文地址：https://blog.csdn.net/gsls200808/article/details/132721043