Sentinel Dashboard集成Nacos

news2024/11/24 11:29:56

1.前言

当项目上Sentinel Dashboard做流量监控的时候，我们可以通过Sentinel控制台修改限流配置，但当我们使用Nacos作为配置中心动态配置流控规则的时候，问题就来了。

首先我们要明白，Sentinel Dashboard的配置是从机器的内存中加载的，如果使用Nacos、Apollo、Zookeeper等作为我们动态加载限流规则的配置中心的时候，我们的配置信息流向是这样的：

就是说客户端从配置中心获取配置，Sentinel Dashboard又从客户端机器的内存中获取配置。

在这种情况下，Sentinel Dashboard可以修改配置，Nacos也可以修改配置，这就会存在数据一致性问题，我们可以从两方面考虑

1）Nacos修改了配置，Sentinel Dashboard会同步更新吗？答案是肯定的，因为Nacos配置变更会通知客户端，客户端配置变更后也会通知Sentinel Dashboard

2）如果在Sentinel Dashboard修改了配置会通知Nacos吗？答案是不会。但是可以通过修改源码实现。

Sentinel控制台在做流控规则的时候，都会调用Sentinel-Dashboard源码中的 一个名叫：FlowControllerV1的接口类，因为流控规则的所有操作，调用的 接口都是如图所示：

这个路径对应的就是FlowControllerV1这个类，但是同时还存在一个 FlowControllerV2的接口类，这个类主要提供的是流控规则的CURD，这两者有啥区别呢？ 

区别在于：V2可以实现指定数据源的规则拉取和发布，这也就意味着Sentinel-Dashboard可以从Nacos等配置中心进行相互通信，从而实现数据一致性，Sentinel开发者已经做好封装，我们改一下源码配置一下就好了（后面会有教程）。这样我们的配置关系就变成了了这样：

2.实战：Sentinel Dashboard集成Nacos

第一步：下载Sentinel源码，本案例用的是Sentinel-v1.8.6

Sentinel官网下载地址：

https://github.com/alibaba/Sentinel/releases

下载好之后，解压，import project，可以看到sentinel-dashboard就是我们要改动的spring-boot项目

 

 第二步：将pom.xml中的sentinel-datasource-nacos的scope去掉

 第三步：进入resources/app/scripts/directives/sidebar/sidebar.html，全局搜一下“dashboard.flowV1”，替换成"dashboard.flow"，也就是将V1去除：去除之后就 会调用FlowControllerV2中的CURD的接口

 其实Sentinel的开发者已经做好相关的适配，如下图，可以支持集成Apollo、Nacos、Zeekeeper，我们现在是以Nacos为例，进入src/test/java/com.alibaba.csp.sentinel.dashboard.rule.nacos目录，将整个nacos目录及其相关文件复制到src/main/java/com.alibaba.csp.sentinel.dashboard.rule.nacos

注：代码的红叉是因为我复制过去了，相同包名相同class导致的，不必在意，实在强迫症的话，可以把test里面的这几个删掉就好了，不删也不影响运行

 复制过来之后，如下图：

其中NacosConfigUtil就一些常量，我自定义了些常量并改名为NacosConfigConstant了，不在意细节

1.NacosConfigConstant.java

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

public class NacosConfigConstant { 
	public static final String DATA_ID_POSTFIX="-flow-rules";
	public static final String GROUP_ID="SENTINEL_GROUP";  
}

 2.配置nacos相关配置

 2.1: application.properties添加nacos配置：

#config my nacos
sentinel.nacos.serverAddr=192.168.1.105:8848
sentinel.nacos.namespace=
sentinel.nacos.groupId=SENTINEL_GROUP

2.2: 新建Nacos配置类NacosPropertiesConfiguration.java

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

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

@ConfigurationProperties(prefix = "sentinel.nacos")
public class NacosPropertiesConfiguration {
	
	private String serverAddr;
	private String dataId;
	private String groupId;
	private String namespace;

	public String getServerAddr() {
		return serverAddr;
	}

	public void setServerAddr(String serverAddr) {
		this.serverAddr = serverAddr;
	}

	public String getDataId() {
		return dataId;
	}

	public void setDataId(String dataId) {
		this.dataId = dataId;
	}

	public String getGroupId() {
		return groupId;
	}

	public void setGroupId(String groupId) {
		this.groupId = groupId;
	}

	public String getNamespace() {
		return namespace;
	}

	public void setNamespace(String namespace) {
		this.namespace = namespace;
	}

}

3.FlowRuleNacosProvider.java，稍微改动了一下，如下：

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

import java.util.ArrayList;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.FlowRuleEntity;
import com.alibaba.csp.sentinel.dashboard.rule.DynamicRuleProvider;
import com.alibaba.csp.sentinel.datasource.Converter;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.utils.StringUtils;

@Service("flowRuleNacosProvider")
public class FlowRuleNacosProvider implements DynamicRuleProvider<List<FlowRuleEntity>> {
	
	@Autowired
	private NacosPropertiesConfiguration nacosPropertiesConfiguration;
	@Autowired
	private ConfigService configService;
	@Autowired
	private Converter<String, List<FlowRuleEntity>> converter;

	/**
	 * @Description: 通过ConfigService.getConfig方法从NacosConfigServer中读取指定配置信息，通过converter转化为FlowRule规则
	 * @Author: LiJianhong
	 * @Param: [appName]
	 * @Return: java.util.List<com.alibaba.csp.sentinel.dashboard.datasource.entity.
	 *          rule.FlowRuleEntity>
	 */
	@Override
	public List<FlowRuleEntity> getRules(String appName) throws Exception {
		String dataId = appName + NacosConfigConstant.DATA_ID_POSTFIX; //user-service-flow-rules
		String groupId = nacosPropertiesConfiguration.getGroupId();
		String rules = configService.getConfig(dataId, groupId, 3000);
		if (StringUtils.isEmpty(rules)) {
			return new ArrayList<>();
		}
		return converter.convert(rules);
	}
}

4.FlowRuleNacosPublisher.java，也是稍微改动了一下：

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

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.FlowRuleEntity;
import com.alibaba.csp.sentinel.dashboard.rule.DynamicRulePublisher;
import com.alibaba.csp.sentinel.datasource.Converter;
import com.alibaba.csp.sentinel.util.AssertUtil;
import com.alibaba.nacos.api.config.ConfigService;

@Service("flowRuleNacosPublisher")
public class FlowRuleNacosPublisher implements DynamicRulePublisher<List<FlowRuleEntity>> {
	
	@Autowired
	private NacosPropertiesConfiguration nacosPropertiesConfiguration;
	@Autowired
	private ConfigService configService;
	@Autowired
	private Converter<List<FlowRuleEntity>, String> converter;

	
	@Override
	public void publish(String app, List<FlowRuleEntity> rules) throws Exception {
		AssertUtil.notEmpty(app, "appName connot be empty");
		if (rules == null) {
			return;
		}
		String dataId = new StringBuilder(app).append(NacosConfigConstant.DATA_ID_POSTFIX).toString();
		configService.publishConfig(dataId, nacosPropertiesConfiguration.getGroupId(), converter.convert(rules));
	}
	
}

 5. 修改com.alibaba.csp.sentinel.dashboard.controller.v2.FlowControllerV2，将注入的bean改成我们改过之后的bean

6.最后mvn clean package打包运行jar即可。

接下来是测试环节：

运行改动后的sentinel-dashboard 

首先，我在Nacos配置中心配置了dataId=user-service-flow-rules限流规则，如下：

[
    {
        "app": "user-service",
        "clusterConfig": {
            "acquireRefuseStrategy": 0,
            "clientOfflineTime": 2000,
            "fallbackToLocalWhenFail": true,
            "flowId": 1001,
            "resourceTimeout": 2000,
            "resourceTimeoutStrategy": 0,
            "sampleCount": 10,
            "strategy": 0,
            "thresholdType": 1,
            "windowIntervalMs": 1000
        },
        "clusterMode": true,
        "controlBehavior": 0,
        "count": 30.0,
        "gmtModified": 1690385332131,
        "grade": 1,
        "id": 1001,
        "limitApp": "default",
        "resource": "com.lee.demo.dubbo.demo.user.ISentinelService",
        "strategy": 0
    },
    {
        "app": "user-service",
        "clusterConfig": {
            "acquireRefuseStrategy": 0,
            "clientOfflineTime": 2000,
            "fallbackToLocalWhenFail": true,
            "flowId": 1002,
            "resourceTimeout": 2000,
            "resourceTimeoutStrategy": 0,
            "sampleCount": 10,
            "strategy": 0,
            "thresholdType": 0,
            "windowIntervalMs": 1000
        },
        "clusterMode": true,
        "controlBehavior": 0,
        "count": 10.0,
        "gmtModified": 1690373927810,
        "grade": 1,
        "id": 1002,
        "limitApp": "default",
        "resource": "com.lee.demo.dubbo.demo.user.IHelloService",
        "strategy": 0
    }
]

com.lee.demo.dubbo.demo.user.ISentinelService的count配置的是30

com.lee.demo.dubbo.demo.user.IHelloService的count配置的是10

然后看下Sentinel-Dashboard的限流规则是与Nacos一致的：

1）在Nacos修改配置查看Sentinel-Dashboard是否更新配置：

可以看到Sentinel-Dashboard的配置是更新了

 2）在Sentinel-Dashboard更新配置，检查是否同步到Nacos，这一步才是验证我们这么辛苦改代码的关键

 可以看到，Nacos成功同步了Sentinel-Dashboard的配置修改

注：我发现改了之后，在Sentinel-Dashboard对配置的CRUD之后，页面没有刷新，要我们手动刷新一下才会看到最新数据~~o(>_<)o ~~，这个我没有过多去排查前端的异常，毕竟我只是后端开发嘛。

至此，Sentinel-Dashboard集成Nacos案例演示完毕。

最后分享一下集成Nacos过程中遇到的问题：

1)Sentinel-Dashboard控制台可以新增限流规则同步Nacos，但是“修改”配置的时候弹出警告“失败”，没提示啥原因，经过debug才发现，是因为新增和修改都需要进行限流规则的参数校验，校验的必要参数如下：

private <R> Result<R> checkEntityInternal(FlowRuleEntity entity) {
        if (entity == null) {
            return Result.ofFail(-1, "invalid body");
        }
        if (StringUtil.isBlank(entity.getApp())) {
            return Result.ofFail(-1, "app can't be null or empty");
        }
        if (StringUtil.isBlank(entity.getLimitApp())) {
            return Result.ofFail(-1, "limitApp can't be null or empty");
        }
        if (StringUtil.isBlank(entity.getResource())) {
            return Result.ofFail(-1, "resource can't be null or empty");
        }
        if (entity.getGrade() == null) {
            return Result.ofFail(-1, "grade can't be null");
        }
        if (entity.getGrade() != 0 && entity.getGrade() != 1) {
            return Result.ofFail(-1, "grade must be 0 or 1, but " + entity.getGrade() + " got");
        }
        if (entity.getCount() == null || entity.getCount() < 0) {
            return Result.ofFail(-1, "count should be at lease zero");
        }
        if (entity.getStrategy() == null) {
            return Result.ofFail(-1, "strategy can't be null");
        }
        if (entity.getStrategy() != 0 && StringUtil.isBlank(entity.getRefResource())) {
            return Result.ofFail(-1, "refResource can't be null or empty when strategy!=0");
        }
        if (entity.getControlBehavior() == null) {
            return Result.ofFail(-1, "controlBehavior can't be null");
        }
        int controlBehavior = entity.getControlBehavior();
        if (controlBehavior == 1 && entity.getWarmUpPeriodSec() == null) {
            return Result.ofFail(-1, "warmUpPeriodSec can't be null when controlBehavior==1");
        }
        if (controlBehavior == 2 && entity.getMaxQueueingTimeMs() == null) {
            return Result.ofFail(-1, "maxQueueingTimeMs can't be null when controlBehavior==2");
        }
        if (entity.isClusterMode() && entity.getClusterConfig() == null) {
            return Result.ofFail(-1, "cluster config should be valid");
        }
        return null;
    }

因此我把Nacos配置中心的限流规则根据这个必要参数都配置了一下之后，再从Sentinel Dashboard修改配置成功了。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/795106.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

go学习 3、基础数据类型

go学习 3、基础数据类型

3、基础数据类型 基础数据类型&#xff1a;数字、字符串、布尔型复合类型&#xff1a;数组、结构体引用类型&#xff1a;指针、切片、字典、函数、通道接口类型 3.1 整型 有符号、无符号 int8/int16/int32/int64 uint8/uint16/uint32/units 64 Unicode字符rune类型是和int32…
阅读更多...
R语言无法调用stats.dll的问题解决方案[补充]

R语言无法调用stats.dll的问题解决方案[补充]

写在前面 在去年10月份&#xff0c;出过一起关于R语言无法调用stats.dll的问题解决方案,今天&#xff08;你看到后是昨天&#xff09;不知道为什么&#xff0c;安装包&#xff0c;一直安装不了&#xff0c;真的是炸裂了。后面再次把R与Rstuido升级。说实话&#xff0c;我是真不…
阅读更多...
整套停车位地磁检测方案出售，主控使用stm32驱动nb-iot模块bc95数据上传远程云服务器。

整套停车位地磁检测方案出售，主控使用stm32驱动nb-iot模块bc95数据上传远程云服务器。

地磁车辆检测器&#xff0c;是车辆本身含有的铁磁物质会对车辆存在区域的地磁信号产生影响&#xff0c;使车辆存在区域的地球磁力线发生弯曲。当车辆经过传感器附近&#xff0c;传感器能够灵敏感知到信号的变化&#xff0c;经信号分析就可以得到检测目标的相关信息。 朋友创业…
阅读更多...
安装github中的存储库作为Python包

安装github中的存储库作为Python包

第一步&#xff0c;安装git 安装教程&#xff1a;https://zhuanlan.zhihu.com/p/114068278 第二步&#xff0c;在github上复制该库的链接 第三步&#xff0c;使用命令行一键下载并安装包 pip install "githttps://github.com/openai/CLIP.git"如果当pip install…
阅读更多...
笔记本充满电后，充电器可以长期不拔，会议安全隐患吗?

笔记本充满电后，充电器可以长期不拔，会议安全隐患吗?

笔记本充满电后&#xff0c;一直插着不拔 1.建议人在身边可以暂时不拔&#xff0c;偶尔还是要使用电池当笔记本电池充满之后&#xff0c;电脑会自动使用电源供电&#xff0c;不会使用电池供电 2.笔记本电池都带有电池保护机制&#xff0c;在电池充满电后会自动停止充电 3.现在…
阅读更多...
RNN架构解析——认识RNN模型

RNN架构解析——认识RNN模型

目录 RNN模型作用分类按照输入和输出的结构进行分类按照RNN的内部构造进行分类 RNN模型 RNN单层网络结构 作用 分类 按照输入和输出的结构进行分类 按照RNN的内部构造进行分类
阅读更多...
Ftp和UDP的区别之如何加速文件传输

Ftp和UDP的区别之如何加速文件传输

FTP&#xff08;文件传输协议&#xff09;是一种传输大文件的老方法&#xff0c;它的速度慢&#xff0c;而且容易受到网络环境的影响。在当今这个文件越来越大&#xff0c;项目交付时间越来越紧&#xff0c;工作分布在全球各地的时代&#xff0c;有没有办法让 FTP 加速呢&#…
阅读更多...
JS学习第二部分

JS学习第二部分

在前面&#xff0c;第一章节 &#xff0c;学了JS的基本语法和一些常用的用法。在第二章节&#xff0c; 学了DOM&#xff0c;就是节点信息&#xff0c;教我们怎么在JS里面获取HTML的标签。接着&#xff0c;我们学习第三章节&#xff0c;怎么在JS里面对HTML的css样式进行操作。 …
阅读更多...
3ds MAX NURBS曲线绘制鼠标

3ds MAX NURBS曲线绘制鼠标

先引用一段大佬的话&#xff0c;解释为什么除了样条线还有这种曲线 NURBS是有理B-splines曲线https://www.zhihu.com/search?q%E6%9C%89%E7%90%86B-splines%E6%9B%B2%E7%BA%BF&search_sourceEntity&hybrid_search_sourceEntity&hybrid_search_extra%7B%22sourceT…
阅读更多...
＜Postman＞Postman接口测试以及使用案例

＜Postman＞Postman接口测试以及使用案例

说明&#xff1a;现在所有的系统都有登录token设置&#xff1b; 所以需要先进行登录&#xff0c;获取两个token&#xff1b; 关于token和refresh token 传统的认证方式一般采用cookie/session来实现&#xff0c;这是我们的出发点。 1.为什么选用token而不选用cookie/session…
阅读更多...
OSI模型简介及socket，tcp，http三者之间的区别和原理

OSI模型简介及socket，tcp，http三者之间的区别和原理

1.OSI模型简介&#xff08;七层网络模型&#xff09; OSI 模型(Open System Interconnection model)&#xff1a;一个由国际标准化组织提出的概念模型&#xff0c;试图提供一个使各种不同的计算机和网络在世界范围内实现互联的标准框架。 它将计算机网络体系结构划分为七层,每…
阅读更多...
spring 存储对象 + 获取对象

spring 存储对象 + 获取对象

前言 本篇在spring中如何使用五大类注释与方法注释将对象加入IOC容器中&#xff0c;了解如何使用注释来获取容器中的Bean对象&#xff0c;如有错误&#xff0c;请在评论区指正&#xff0c;让我们一起交流&#xff0c;共同进步&#xff01; 文章目录 前言1.通过注释将类加入IoC…
阅读更多...
【C++ 重要知识点总结】自定义类型-类和结构体

【C++ 重要知识点总结】自定义类型-类和结构体

类 类的基本特性 数据抽象和封装继承多态 1 类的构成——抽象 概念 数据抽象是一种依赖于接口和实现的分离的编程技术。类的接口包括用户所能执行的操作&#xff1b;类的实现包括类的数据成员、负责接口实现的函数体以及定义类所需要的的各种私有函数。封装实现了类的接口和实…
阅读更多...
645. 错误的集合

645. 错误的集合

645. 错误的集合 class Solution { public static int[] findErrorNums(int[] nums) {Arrays.sort(nums);int dup-1;int miss1;for (int i 1; i < nums.length; i) {if(nums[i]nums[i-1]){dupnums[i];}if(nums[i]-nums[i-1]>1){missnums[i]-1;}}return new int[]{dup,…
阅读更多...
Vmware vSphere 5.0系列

Vmware vSphere 5.0系列

Vmware vSphere 5.0 我们都用过 vmware workstation 这款产品&#xff0c;可以使我们安装很多虚拟机&#xff0c;但是 vmware 的核心产品远非局限于 workstation。 vSphere 是 VMware 推出的基于云的新一代数据中心虚拟化套件&#xff0c;提供了虚拟化基础架构、高可用性、集…
阅读更多...
Tesseract开源的OCR工具及python pytesseract安装使用

Tesseract开源的OCR工具及python pytesseract安装使用

一 、介绍 Tesseract是一款由Google赞助的开源OCR。 pytesseract是python包装器&#xff0c;它为可执行文件提供了pythonic API。 Tesseract 已经有 30 年历史&#xff0c;开始它是惠普实验室的一款专利软件&#xff0c;在2005年后由Google接手并进一步开发和完善。Tesseract支…
阅读更多...
【Unity 实用插件篇】| 可视化图表插件XCharts (折线图、柱状图、饼图等)详细教学

【Unity 实用插件篇】| 可视化图表插件XCharts (折线图、柱状图、饼图等)详细教学

前言 【Unity 实用插件篇】| 可视化图表插件XCharts (折线图、柱状图、饼图等)详细教学一、XCharts介绍1.1 特性1.2 相关网站链接1.3 效果展示 二、XCharts导入三、XCharts快速使用3.1 添加一个简单图表3.2 添加多个Seire3.3 给图表添加其他组件3.4 添加Serie组件&#xff0c;如…
阅读更多...
什么是Maven，Maven的概述及基本使用

什么是Maven，Maven的概述及基本使用

MAVEN 一、Maven简介1.1、Maven概述1.2、Maven仓库1.3项目获取jar包过程 二、Maven使用2.1Maven安装配置2.1.1配置环境变量2.1.2配置本地仓库2.1.3配置阿里云私服 2.2Maven基本使用2.2.1Maven常用指令2.2.2Maven生命周期 总结 一、Maven简介 Apache Maven是一个项目管理和构建…
阅读更多...
自动驾驶数据标注有哪些？

自动驾驶数据标注有哪些？

自动驾驶汽车&#xff1a;人工智能(AI)的焦点 人工智能驱动汽车解决方案的市场规模预计到 2025年将增长十倍以上&#xff0c;提升车内体验的商机领域以及 AI 模型的无偏见训练数据的重要性。在本篇中&#xff0c;我们将介绍车外体验的关键组成部分&#xff0c;以及自动驾驶数据…
阅读更多...
Python 爬虫的学习 day01 ，爬虫的基本知识， requests 和 charde模块， get函数的使用

Python 爬虫的学习 day01 ，爬虫的基本知识， requests 和 charde模块， get函数的使用

1.Python 爬虫 1.1什么是网络爬虫 网络爬虫&#xff0c;又称为网页蜘蛛&#xff0c;网络机器人&#xff0c;是一种按照一定的规则&#xff0c;自动地抓取万维网信息的程序或者脚本&#xff0c;另外一些不常使用的名字还有蚂蚁、自动索引、模拟程序或者蠕虫。 1.2 网络爬虫的特…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023