十三、微服务整合Sentinel持久化到nacos

前面讲过了Sentinel的简单应用,但是有一个问题:如果直接使用阿里提供的Jar包,当Sentinel重启后,之前制定的规则就会丢失。那么我们就需要将数据持久化。
Sentinel是支持持久化的,不然阿里的商业版怎么用的。我们可以下载Sentinel源码,自己稍作改动,使规则能持久化到数据库或硬盘。因为微服务使用的是Spring-cloud-alibaba,Sentinel支持和nacos整合,就持久化到nacos数据库中,同时sentinel还能读取nacos中做的流控规则。
先列出Spring-cloud-alibaba的版本:

spring-cloud-alibaba版本

sentinel、nacos版本

这是阿里给出的,可以自己查:spring-cloud-alibaba版本对应关系
Sentinel文档,里面有下载的链接。

1. 后台源码修改

源码下载完,我是用eclipse打开的,有一个依赖版本需要2处需要改一下:

报错的地方

添加属性

sentinel中有和nacos中对接的源码,只不过没有使用。我们修改:1是改成 默认后台使用sentinel对接nacos,而不是存到内存,1是前台页面接口调用nacos对应的接口

1.1 sentinel-dashboard中添加nacos

nacos部分代码已经有了,在test中,需要将代码移到src/main/java中,就可以使用。

    1. pom.xml中将sentinel-datasource-nacos包的scope注释掉
      scope注释
    1. 代码移动


      代码移动

nacos包中的4个类:

  • FlowRuleNacosProvider: 动态获取Nacos配置中心流控规则,读取流控规则
  • FlowRuleNacosPublisher: publish上传流控规则到Nacos配置中心,写入流控规则
  • NacosConfig: Nacos配置
  • NacosConfigUtils: 流控规则在nacos中配置文件的一些细节:后缀、组别等

这里需要注意一点:在获取nacos中的流控规则的时候,nacos中流控配置文件,加了后缀,组也给了特定的,我们不用改源码,后面我们在nacos中添加配置文件的时候按他给的名字来就行,如下图:

nacos中配置文件后缀

流控规则后缀和组名

1.2 配置连接自己的nacos

自带的nacos配置只写了个localhost,我们按着他给的,连接我们自己的。修改NacosConfig.java

自带的

自己的替代

参数也可以写到配置文件中,在这里接收。

@Value("${sentinel.nacos.address}")
private String nacosAddr;
@Value("${sentinel.nacos.username}")
private String userName;
@Value("${sentinel.nacos.password}")
private String password;
@Value("${sentinel.nacos.namespace}")
private String namespace; 
  
@Bean
public ConfigService nacosConfigService() throws Exception {
    Properties properties = new Properties();
    properties.put(PropertyKeyConst.SERVER_ADDR, nacosAddr);
    // properties.put(PropertyKeyConst.USERNAME, userName);
    // properties.put(PropertyKeyConst.PASSWORD, password);
    properties.put(PropertyKeyConst.NAMESPACE, namespace);
    return ConfigFactory.createConfigService(properties);
}

若写到配置文件中,这样写:


配置文件添加

1.3 修改代码Controller层,调用nacos提供的服务层

修改文件:com.alibaba.csp.sentinel.dashboard.controller.v2.FlowControllerV2.java

修改服务层

这个时候应该可以启动sentinel-dashboard了,启动后,登陆页面左侧是空白的。


启动后

2. 前端页面源码修改

2.1 配置中添加nacos接口并修改地址

修改src/main/webapp/resources/app/scripts/controllers/identity.js

    1. 第4行将V1改为V2


      nacos地址
    1. 直接搜/dashboard/flow/定位第101行
// let url = '/dashboard/flow/' + $scope.app;
 let url = '/dashboard/v2/flow/' + $scope.app;
替换地址

2.2 修改页面中的路由地址

修改src/main/webapp/resources/app/scripts/directives/sidebar/sidebar.html
直接搜dashboard.flowV1定位57行去掉V1

<!-- <li ui-sref-active="active" ng-if="!entry.isGateway">
          <a ui-sref="dashboard.flowV1({app: entry.app})">
          <i class="glyphicon glyphicon-filter"></i>&nbsp;&nbsp;流控规则</a>
      </li> -->
          
<li ui-sref-active="active" ng-if="!entry.isGateway">
      <a ui-sref="dashboard.flow({app: entry.app})">
      <i class="glyphicon glyphicon-filter"></i>&nbsp;&nbsp;流控规则</a>
</li>
去掉V1

2.3 注释掉一个按钮

修改src/main/webapp/resources/app/views/flow_v2.html
注释掉回到单机页面按钮。

回到单机页面

3. 微服务(非网关)

3.1 微服务引入jar包

pom

pom.xml如下:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.zrb.test</groupId>
        <artifactId>sentinel-test</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>
    <artifactId>user-demo</artifactId>
    <name>user-demo</name>
    <description>sentinel测试</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>com.mysql</groupId>
            <artifactId>mysql-connector-j</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.github.xiaoymin</groupId>
            <artifactId>knife4j-openapi2-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
        </dependency>
        
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
        </dependency>
        
        <!--nacos客户端 -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        
        <!-- sentinel -->
        <dependency>
           <groupId>com.alibaba.cloud</groupId>
           <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <!-- 使用nacos作为sentinel持久化数据源 -->
        <dependency>
           <groupId>com.alibaba.csp</groupId>
           <artifactId>sentinel-datasource-nacos</artifactId>
        </dependency>
    </dependencies>

    <build>
        <finalName>user-demo</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

3.2 微服务配置文件

配置文件中

sentinel有哪些规则,在org.springframework.cloud.alibaba.sentinel.datasource.RuleType中,名字和他一致比较好。
application.yml文件:

# 1. server
server:
  port: 8001
logging:
  level:
    '[com.zrb.test.user.dao]': debug
# 3.spring
spring: 
  # 服务名称必须带上,不然nacos服务列表中没有,也不会有注册成功的信息
  application: 
    name: user-demo
  mvc: 
    pathmatch: 
      matching-strategy: ant-path-matcher
  config: 
    import:
    - nacos:${spring.application.name}.yaml
  cloud:
     nacos: 
       config: 
         server-addr: 192.168.50.89:8848
         file-extension: yaml
       discovery: 
         register-enabled: true
         server-addr: 192.168.50.89:8848
     sentinel:
       transport:
         dashboard: 192.168.50.89:8080
         port: 8721
       datasource:
         flow:
           nacos:
             server-addr: 192.168.50.89:8848
             namespace: 
             dataId: ${spring.application.name}-flow-rules
             groupId: SENTINEL_GROUP
             dataType: json
             rule-type: flow
# 暂时只弄一个流控规则的吧,其他的自己添加
#         degrade:
#           nacos:
#             server-addr: 192.168.50.89:8848
#             namespace:
#             dataId: ${spring.application.name}-degrade-rules
#             groupId: SENTINEL_GROUP
#             data-type: json
#             rule-type: degrade
#         system:
#           nacos:
#             server-addr: 192.168.50.89:8848
#             namespace:
#             dataId: ${spring.application.name}-system-rules
#             groupId: SENTINEL_GROUP
#             data-type: json
#             rule-type: system
#         authority:
#           nacos:
#             server-addr: 192.168.50.89:8848
#             namespace:
#             dataId: ${spring.application.name}-authority-rules
#             groupId: SENTINEL_GROUP
#             data-type: json
#             rule-type: authority
#         param-flow:
#           nacos:
#             server-addr: 192.168.50.89:8848
#             namespace:
#             dataId: ${spring.application.name}-param-flow-rules
#             groupId: SENTINEL_GROUP
#             data-type: json
#             rule-type: param-flow

3.3 nacos中添加配置文件

nacos中配置

添加的时候,格式选json,内容就先填个{}就行。

3.4 测试

这个坑我遇到了,不知道什么原因。注意:打包放到linux系统中去测试,要不簇点链路中无数据。

    1. 在linux中分别启动服务,调几个微服务的接口测试一下:


      接口测试
    1. 等几秒钟,在sentinel中查看,微服务已经注册上来了


      微服务
    1. 簇点链路中能看到接口信息


      簇点链路
    1. 选2个接口,添加流控规则


      规则1步

      规则2步

      添加完成
    1. 查看nacos


      有内容了

      格式化,可以大致看到规则

以上就是 微服务整合Sentinel持久化到nacos,需要说明一点,这只是微服务,如果使用网关整合 sentinel和这个还是不一样的,下次再写网关gateway整合sentinel的。


参考文章:https://blog.csdn.net/qq_44870331/article/details/129886930

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 226,097评论 6 523
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 97,198评论 3 410
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 173,602评论 0 370
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 61,750评论 1 304
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 70,684评论 6 404
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 54,151评论 1 317
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 42,349评论 3 433
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 41,430评论 0 282
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 47,986评论 1 328
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 39,969评论 3 351
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 42,071评论 1 359
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 37,667评论 5 352
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 43,358评论 3 342
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 33,757评论 0 25
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 34,944评论 1 278
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 50,684评论 3 384
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 47,123评论 2 368

推荐阅读更多精彩内容