Sentinel如何持久化數(shù)據(jù)到Nacos？

作者：磊哥 2024-04-25 16:17:53

Sentinel Dashboard 默認(rèn)情況下，只能將配置規(guī)則保存到內(nèi)存中，這樣就會(huì)程序重啟后配置規(guī)則丟失的情況，因此我們需要給 Sentinel 設(shè)置一個(gè)數(shù)據(jù)源，并且要和數(shù)據(jù)源之間實(shí)現(xiàn)雙向通訊，所以我們需要修改 Sentinel 的源碼。

默認(rèn)情況下 Sentinel 只能接收到 Nacos 推送的消息，但不能將自己控制臺(tái)修改的信息同步給 Nacos，如下圖所示：

但是在生成環(huán)境下，我們?yōu)榱烁奖愕牟僮?，是需要?Sentinel 控制臺(tái)修改的規(guī)則也同步到 Nacos 的，所以在這種情況下我們就需要修改 Sentinel 的源碼，讓其可以實(shí)現(xiàn)和 Nacos 的雙向通訊，如下圖所示：

改造之后的交互流程如下圖所示：

圖片

Sentinel 同步規(guī)則至數(shù)據(jù)源，例如將 Sentinel 的規(guī)則，同步規(guī)則至 Nacos 數(shù)據(jù)源的改造步驟很多，但整體實(shí)現(xiàn)難度不大，下面我們一起來(lái)看吧。

1.下載Sentinel源碼

下載地址：https://github.com/alibaba/Sentinel

PS：本文 Sentinel 使用的版本是 1.8.6。

下載源碼之后，使用 idea 打開(kāi)里面的 sentinel-dashboard 項(xiàng)目，如下圖所示：

2.修改pom.xml

將 sentinel-datasource-nacos 底下的 scope 注釋掉，如下圖所示：

PS：因?yàn)楣俜教峁┑?Nacos 持久化實(shí)例，是在 test 目錄下進(jìn)行單元測(cè)試的，而我們是用于生產(chǎn)環(huán)境，所以需要將 scope 中的 test 去掉。

3.移動(dòng)單元測(cè)試代碼

將 test/com.alibaba.csp.sentinel.dashboard.rule.nacos 下所有文件復(fù)制到 src/main/java/com.alibaba.csp.sentinel.dashboard.rule 目錄下，如下圖所示：

4.新建NacosPropertiesConfiguration文件

在 com.alibaba.csp.sentinel.dashboard.rule 下創(chuàng)建 Nacos 配置文件的讀取類，實(shí)現(xiàn)代碼如下：

package com.alibaba.csp.sentinel.dashboard.rule;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

@ConfigurationProperties(prefix = "sentinel.nacos")
@Configuration
public class NacosPropertiesConfiguration {
    private String serverAddr;
    private String dataId;
    private String groupId;
    private String namespace;
    private String username;
    private String password;
    // 省略 Getter/Setter 代碼
}

5.修改NacosConfig文件

只修改 NacosConfig 中的 nacosConfigService 方法，修改后的代碼如下：

@Bean
public ConfigService nacosConfigService(NacosPropertiesConfiguration nacosPropertiesConfiguration) throws Exception {
    Properties properties = new Properties();
    properties.put(PropertyKeyConst.SERVER_ADDR, nacosPropertiesConfiguration.getServerAddr());
    properties.put(PropertyKeyConst.NAMESPACE, nacosPropertiesConfiguration.getNamespace());
    properties.put(PropertyKeyConst.USERNAME,nacosPropertiesConfiguration.getUsername());
    properties.put(PropertyKeyConst.PASSWORD,nacosPropertiesConfiguration.getPassword());
    return ConfigFactory.createConfigService(properties);
//        return ConfigFactory.createConfigService("localhost"); // 原代碼
}

6.修改FlowControllerV2文件

修改 com.alibaba.csp.sentinel.dashboard.controller.v2 目錄下的 FlowControllerV2 文件：

修改后代碼：

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

PS：此操作的目的是開(kāi)啟 Controller 層操作 Nacos 的開(kāi)關(guān)。

如下圖所示：

7.修改配置信息

在 application.properties 中設(shè)置 Nacos 連接信息，配置如下：

sentinel.nacos.serverAddr=localhost:8848
sentinel.nacos.username=nacos
sentinel.nacos.password=nacos
sentinel.nacos.namespace=
sentinel.nacos.groupId=DEFAULT_GROUP
sentinel.nacos.dataId=sentinel-dashboard-demo-sentinel