分布式流量防护_Sentinel组件二次开发-【官方】百战程序员_IT在线教育培训机构


xxxxxxxxxx
<dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
<!--            将scope注释掉 改为编译器打包-->
<!--            <scope>test</scope>-->
 </dependency>

后端程序对接Nacos

首先，你需要打开 sentinel-dashboard 项目下的 src/test/java目录。定位到 com.alibaba.csp.sentinel.dashboard.rule.nacos目录下。

解释：
NacosConfig：初始化 Nacos Config 的连接；
NacosConfigUtil：约定了 Nacos 配置⽂件所属的 Group 和⽂件命名后缀等常量字段；
FlowRuleNacosProvider：从 Nacos Config 上获取限流规则；
FlowRuleNacosPublisher：将限流规则发布到 Nacos Config。

为了让这些类在 Sentinel 运行期可以发挥作用，你需要在 src/main/java 下创建同样的包路径，然后将这四个文件从 test 路径拷贝到 main 路径下。

实现Nacos数据同步


xxxxxxxxxx
    @Bean
    public ConfigService nacosConfigService() throws Exception {
        Properties properties = new Properties();
        // Nacos服务地址
        properties.setProperty("serverAddr","192.168.66.101:8848");
        // NameSpace id
        properties.setProperty("namespace","a26e7bb2-04df-4574-8313-3d8728ae88ba");
        return ConfigFactory.createConfigService(properties);
    }

FlowControllerV2接入Nacos

解释：
在代码中，我通过Qualifer标签将FlowRuleNacosProvider注入到了ruleProvier变量中，又采用同样的方式将FlowRuleNacosPublisher注入到了rulePublisher变量中。FlowRuleNacosProvider和 FlowRuleNacosPublisher就是上一步我们刚从 test目录 Copy到main目录下的两个类。

查看FlowRuleNacosPublisher源码


xxxxxxxxxx
  @Override
    public List<FlowRuleEntity> getRules(String appName) throws Exception {
        // 发布到Nacos上的配置文件名
        // app + NacosConfigUtil.FLOW_DATA_ID_POSTFIX   +NacosConfigUtil.GROUP_ID
        String rules = configService.getConfig(appName + NacosConfigUtil.FLOW_DATA_ID_POSTFIX,
            NacosConfigUtil.GROUP_ID, 3000);
        if (StringUtil.isEmpty(rules)) {
            return new ArrayList<>();
        }
        return converter.convert(rules);
    }

解析：
我们就完成了对后端程序的改造，将 Sentinel 限流规则同步到了 Nacos。接下来我们需要对前端页面稍加修改，开放⼀个独立的页面，用来维护那些被同步到 Nacos 上的限流规则。

前端页面改造

首先，我们打开 sentinel-dashboard 模块下的 webapp 目录，该目录存放了 Sentinel 控制台的前端页面资源。我们需要改造的文件是 sidebar.html，这个 html文件定义了控制台的左侧导航栏。

新增内容


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

微服务改造

微服务端的改造非常常简单，我们不需要对代码做任何改动，只需要添加⼀个新的依赖项，并在配置文件中添加 sentinel datasource 连接信息就可以了。


xxxxxxxxxx
<dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
</dependency>

我们在 application.yml 配置文件中找到 spring.cloud.sentinel 节点，在这个节点下添加⼀段Nacos 数据源的配置。


xxxxxxxxxx
      datasource:
        # 数据源key 可以自由命名
        geekbang-flow:
          # 指定当前数据源是Nacos
          nacos:
            # 设置Nacos的连接地址，命名空间和GroupID
            server-addr: 192.168.66.101:8848
            # Nacos 命名空间
            namespace: a26e7bb2-04df-4574-8313-3d8728ae88ba
            groupId: SENTINEL_GROUP
            # 设置Nacos中配置⽂件的命名规则
            dataId: ${spring.application.name}-flow-rules
            # 必填的重要字段，指定当前规则类型是"限流"
            rule-type: flow

重点强调

我们在微服务端的 sentinal 数据源中配置的 namespace 和 groupID，⼀定要和 Sentinal Dashoboard 二次改造中的中的配置相同，否则将无法正常同步限流规则。
dataId 的文件命名规则，需要和 Sentinel 二次改造中的FlowRuleNacosPublisher 类保持⼀致。

验证限流规则同步效果

启动Sentinel-dashboard子项目，找主启动类启动Sentinel控制台。

请求http://localhost:8080，你可以登录 Sentinel Dashboard 服务。这时你会看到左侧的导航栏多了⼀个“流控规则百战”的选项。你可以点击这个选项，并手动在当前页面右上方点击“新增流控规则”，为 requestCoupon 添加⼀条“QPS=1 快速失败”的流控规则。

最后，打开 Nacos Config 的配置列表页，你就可以看到⼀个 cloud-sentinel-payment- flow-rules 的配置文件被创建了出来。

分布式流量防护_Sentinel为什么需要持久化分布式事物处理_认识本地事物

北京市昌平区回龙观镇南店村综合商业楼2楼226室