Spring Cloud微服务架构Sentinel数据双向同步
作者:Java白羊 发布时间:2021-07-16 04:17:04
Sentinel数据双向同步
上面实现了Nacos单向同步配置规则到Sentinel,但是只是单向的,没有实现Sentinel向Nacos同步规则配置;下面我们来实现Sentinel同步配置到Nacos,以及两者的双向数据同步结合使用。
我们回顾一下,首先Sentinel规则的存储默认是存储在内存的,应用重启之后规则会丢失。因此我们通过配置中心Nacos保存规则,然后通过定时拉取Nacos数据来获取规则配置,可以做到动态实时的刷新规则。但是这种方式是单向的,并且有一定的限制,我们是否可以在Sentinel和Nacos这两个中间件之间双向同步数据呢?下面我们来实现Sentinel数据双向同步。
前言
因为实现Sentinel-Nacos数据双向同步,需要使用到推(Push)模式在两边相互推送数据。那么什么是Sentinel的拉模式和推模式呢?Sentinel的规则管理有哪些模型呢?下面我们一一来进行解答:
什么是推模式和拉模式?
推模式:注册中心统一推送,客户端通过注册 * 时刻监听变化
拉模式:客户端主动向配置中心定时轮询拉取配置
Sentinel的规则管理模型
Sentinel的规则管理,主要有以下三种模型:
首先原始模式下的Sentinel Dashboard配置的规则重启应用后就会丢失,这种方式肯定是有极大风险的,生产环境不推荐使用。
其次,拉模式的确不会对Sentinel客户端造成压力,但是Sentinel客户端多了以后会对Nacos注册中心造成压力,并且也无法保证实时性。拉模式的应用场景一般是处理压力小的一方向处理压力大的一方获取数据,并且没有太高的实时性要求,比如定时拉取日志数据。
我们可以使用推模式作为Sentinel客户端的规则同步方式,通过 * 监听Nacos服务端口,来实现规则的实时更新。这就需要涉及到Sentinel Dashboard的规则管理及推送功能:集中管理和推送规则,sentinel-core
提供了 API 和扩展接口来接收和推送信息。并且这种方式,不用担心Sentinel客户端配置的规则错误会导致正确的配置丢失,因为Nacos有配置一键回滚机制,并且还有MySQL作为持久化手段。
总结:生产环境建议使用 Push模式的数据同步中间件(比如Nacos),并且可以的话最好实现数据双向同步。当然还有文件同步的方式,但是无法保证实时性和动态性,因此只是作为一种备份手段。
了解了规则双向同步的过程和原理,下面我们来实现Sentinel规则持久化到Nacos和规则数据双向同步使用测试:
准备工作
1. 版本选取
因为上面我们使用的是 Spring Cloud Alibaba 2021.0.1.0*
和 Spring Cloud 2021.0.1
,因此对应Sentinel版本为Sentinel 1.8.3,下载的使用需要注意版本。
2. 下载Sentinel源码
下载Sentinel对应客户端版本的 sentinel-dashboard
源码
源码地址如下,点击Tags选择版本为1.8.3,然后点击下载ZIP压缩包,下载地址如下:
https://github.com/alibaba/Sentinel/tree/1.8.3
3. 解压并导入项目
将压缩包解压,用IDE工具打开sentinel-dashboard项目,由于是将Sentinel控制台定义的规则持久化到Nacos,所以,只需要打开sentinel-dashboard项目即可:
然后将sentinel项目中的sentinel-dashboard子模块项目,导入到IDE中即可:
我们导入sentinel整个项目,因为会需要下载很多用不到的依赖,比较耽误时间。事实上,我们只需要导入我们需要改造的sentinel-dashboard子模块就可以了。
完成了前面的准备工作,下面我们可以正式开始改造源码了:
改造Sentinel控制台
为什么需要改造Sentinel控制台源码?
因为Sentinel源码本身只支持Nacos同步配置到Sentinel,并不支持Sentinel同步配置到Nacos(阿里的AHAS倒是提供这个功能了,所以说阿里的开源只开一半,还需要社区提供源码修改方案)。因此,我们需要改造Sentinel控制台以支持Sentinel推送规则到Nacos。
我们可以通过Sentinel扩展接口中的DynamicRuleProvider和DynamicRulePublisher接口来实现自己的拉取者(Provider)和推送者(Publisher)接口逻辑。
源码改造的过程
我们从Sentinel-Nacos规则双向同步的底层原理出发,从sentinel-dashboard源码一步步进行改造。这样在更换版本也不会出现不适配的情况,并且从底层代码一步步修改的方式比起直接用打包好的jar包的方式,即使出现了适配问题也能更好、更快的理解并分析出问题出现的原因,对于解决bug和修改任何版本的Sentinel源码都是有帮助的。
主要分为下面三大部分进行改造:
全局修改
全局依赖修改
全局配置修改
后端代码修改
配置类修改
创建规则交互层(拉取与推送实现类)
规则控制层修改
前端代码修改
前端页面调整
前端接口调整
我们这里是Sentinel 1.8.3版本,基于理解原理和实践的原因,下面我们针对 sentinel-dashboard
源码进行手动改造。
1. 全局修改
① 修改POM依赖
想要将 dashboard 的规则持久化到Nacos,需要在sentinel-dashboard子项目的pom.xml中添加一个依赖(源码中已经添加,不过只在测试环境下打包),将作用域扩大:
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-datasource-nacos</artifactId>
<!--<scope>test</scope>-->
</dependency>
② 修改properties配置文件
在resources目录下,找到配置文件 application.properties
文件,在末尾添加一下配置:
# Nacos Configurations
sentinel.nacos.serverAddr=localhost:8848
sentinel.nacos.namespace=
sentinel.nacos.group-id=SENTINEL-GROUP
全部依赖和配置就改造完成了,下面进行后端代码和前端代码的改造。
来源:https://juejin.cn/post/7153431718781779976
猜你喜欢
- mybatis 3 | 参考文档MyBatis 是一款优秀的持久层框架,它支持自定义 SQL、存储过程以及高级映射。MyBatis 免除了几
- 之前文章中我们讲到,java中实现同步的方式是使用synchronized block。在java 5中,Locks被引入了,来提供更加灵活
- 简单介绍synchronized是Java中的关键字,是一种同步锁。它修饰的对象有以下几种:1. 修饰一个代码块,被修饰的代码块称为同步语句
- 背景朋友想从XX超市app购买一些物美价廉的东西,但是因为人多货少经常都是缺货的状态,订阅了到货通知也没什么效果,每次收到短信通知进入app
- 引言:关于java IO流的操作是非常常见的,基本上每个项目都会用到,每次遇到都是去网上找一找就行了,屡试不爽。上次突然一个同事问了我jav
- float是单精度类型,精度是8位有效数字,取值范围是10的-38次方到10的38次方,float占用4个字节的存储空间double是双精度
- 1、JDBCJDBC 就是 数据库开发 操作的 代名词,因为只要是现代商业项目的开发那么一定是离不开 数据库 的,不管你搞的是什么,只要是想
- 今天聊一个小伙伴在星球上的提问:问题不难,解决方案也有很多,因此我决定撸一篇文章和大家仔细说说这个问题。1. 配置文件位置首先小伙伴们要明白
- ArrayList线程不安全怎么办?有三种解决方法:使用对应的 Vector 类,这个类中的所有方法都加上了 synchronized 关键
- 轨迹压缩算法场景描述给定一个GPS数据记录文件,每条记录包含经度和维度两个坐标字段,根据距离阈值压缩记录,将过滤后的所有记录的经纬度坐标构成
- 添加MyBatis的代码并修改以下部分:1.添加MyBatisConfigpackage myshop.config;import java
- 运行远程主机上的shell脚本下面的例子是教给大家如何通过java程序,运行远程主机上的shell脚本。(我讲的不是一个黑客学习教程,而是使
- 最近有个粉丝提了个问题,说他在Spring Security中用JWT做退出登录的时无法获取当前用户,导致无法证明“我就是要退出的那个我”,
- 一、首先编写一个工具类Hello:public class Hello { public static void say(Str
- 实现效果如图所示:首先公布实现代码:一. 自定义实现import.org.springframework.security.core.use
- 本文实例讲述了Java实现的求逆矩阵算法。分享给大家供大家参考,具体如下:package demo;public class MatrixI
- 一. 安装依赖包yum install -y wgetyum install -y gcc-c++yum install -y zlib-d
- 示例 1 :使用搜索表单创建全屏模式我们要构建的小应用程序有一个应用程序栏,右侧有一个搜索按钮。按下此按钮时,将出现一个全屏模式对话框。它不
- public/protected/privatepublic表示公开,private表示私有,protected表示保护,什么都不写表示默认
- 什么是动态线程池?在线程池日常实践中我们常常会遇到以下问题:代码中创建了一个线程池却不知道核心参数设置多少比较合适。参数设置好后,上线发现需