xxl-conf配置中心

简介: ### 一、实现一个轻量级简单的配置中心,同时不考虑使用zk?1.由于我们使用的配置中心需要兼容多套环境,因此需要多环境2.需要有权限控制3.需要对配置的信息,能够实时响应4.如果配置信息存储在数据库,为了减轻数据库的压力,可以进行持久化到磁盘文件中当时这里会有一个问题需要考虑,如果持久化到磁盘,需要考虑如果配置发生了改变,需要能够实时同步到磁盘文件中,因此此时需要考虑一个线程进行实时同步。5.对应配置信息发生增、删、改,能够实时更新和修改

一、实现一个轻量级简单的配置中心,同时不考虑使用zk?

1.由于我们使用的配置中心需要兼容多套环境,因此需要多环境

2.需要有权限控制

3.需要对配置的信息,能够实时响应

4.如果配置信息存储在数据库,为了减轻数据库的压力,可以进行持久化到磁盘文件中

当时这里会有一个问题需要考虑,如果持久化到磁盘,需要考虑如果配置发生了改变,需要能够实时同步到磁盘文件中,因此此时需要考虑一个线程进行实时同步。

5.对应配置信息发生增、删、改,能够实时更新和修改

二、xxl-conf的官方架构图


image-20230124004652800.png

image-20230124005119740.png


从图中,我们可以看到配置中心如果执行了配置操作,此时会做一个写的操作到文件,其会做一个广播、同步的操作,同步镜像文件,执行配置的刷新操作。在调用的时候,能够实时拉取到最新的配置信息。这里做了两个持久化,一个是持久化到了数据库,一个是持久化到文件。在之前的版本,xxl-conf使用过zookeeper作为存储配置的作为配置中心。

三、xxl-conf的使用

一个是服务端,一个是客户端。服务端提供了一个可视化的界面,我们可以在可视化界面中,执行配置信息的增、删、查、改。同时接入的业务系统需要引入xxl-conf-core。

服务端,我们可以看到配置管理中的key-value的对应信息,同时描述信息。

image-20230124005457822.png


客户端:引入xxl-conf-core的依赖即可。

配置配置信息:

xxl.conf.admin.address=http://localhost:8080/

xxl.conf.env=test

xxl.conf.access.token=

xxl.conf.mirrorfile=/data/applogs/xxl-conf/xxl-conf-mirror-sample.properties

可以看到主要是服务端的请求地址、对应的配置环境、token、镜像文件存放的路径。

如果配置成功后,可以运行接入的业务系统的例子,可以看到文件路径中会有启动的服务端和业务系统的日志信息,同时还有配置文件的配置信息

image-20230124011428838.png

可以看到配置配置数据信息在信息配置后,持久化到了磁盘文件中。

image-20230124010142278.png

此时可以看到运行获取配置的效果:

image-20230124011538457.png

可以看到获取到了对应的key和value的值。

四、表结构

image-20230124012249721.png

       可以看到xxl-conf中有三张表是值得我们关注的,一张是xxl_conf_node,一张是xxl_conf_node_msg。从ConfController的增、删、改种可以看到,在做配置信息的变更后,同时会sendConfMsg的动作,此时xxl_conf_node_msg中会存在数据。另外一张表是一张审计日志表,方便查看谁对配置做了修改。

       xxl_conf_env是对应环境的信息。xxl_conf_user是用户信息。xxl_conf_project是对应的项目的名称信息。

五、原理

在启动服务端的时候,由于XxlConfNodeServiceImpl实现了InitializingBean, DisposableBean接口,因此会做线程启动。

image-20230124013331808.png

可以看到主要的代码:

   查配置消息表信息

  遍历配置消息,进行文件同步

  同步完成后,执行老配置消息清理

// new message, filter readed

List<XxlConfNodeMsg>messageList=xxlConfNodeMsgDao.findMsg(readedMessageIds);

if (messageList!=null&&messageList.size()>0) {

  for (XxlConfNodeMsgmessage: messageList) {

       readedMessageIds.add(message.getId());

       // sync file 同步文件

       setFileConfData(message.getEnv(), message.getKey(), message.getValue());

     }

   }

       // clean old message; 清理老消息

       if ( (System.currentTimeMillis()/1000) %confBeatTime==0) {

           xxlConfNodeMsgDao.cleanMessage(confBeatTime);

           readedMessageIds.clear();

}

找到记录消息的xxl_conf_node_msg,如果存在,则需要做文件同步处理,同时清理调老的消息。

启动客户端,可以看到会做初始化操作:

        三个初始化,初始化完成后,做监听操作。首先对远程的配置信息进行初始化,然后初始化镜像文件,初始化缓存信息和线程,循环刷新和监控。完成后监听所有的key发生改变的时候,做刷新操作。

/**

    * init 初始化

    *

    * @param adminAddress

    * @param env

    */

   publicstaticvoidinit(StringadminAddress, Stringenv, StringaccessToken, Stringmirrorfile) {

       // init

       // init remote util 初始化远程配置

       XxlConfRemoteConf.init(adminAddress, env, accessToken);

       // init mirror util

       XxlConfMirrorConf.init(mirrorfile);

       // init cache + thread, cycle refresh + monitor

       XxlConfLocalCacheConf.init();

       // listener all key change

       XxlConfListenerFactory.addListener(null, newBeanRefreshXxlConfListener());

   }

此时也会启动线程操作:

   只不过此时获取的所有的配置信息

//获取所有配置的节点列表,这里是拿到所有信息的关键方法

List<XxlConfNode>confNodeList=xxlConfNodeDao.pageList(offset, pagesize, null, null, null);

   while (confNodeList!=null&&confNodeList.size()>0) {

    for (XxlConfNodeconfNoteItem: confNodeList) {

       // sync file 同步文件

       StringconfDataFile=setFileConfData(confNoteItem.getEnv(), confNoteItem.getKey(), confNoteItem.getValue());

       // collect confDataFile

       confDataFileList.add(confDataFile);

    }

   offset+=1000;

   confNodeList=xxlConfNodeDao.pageList(offset, pagesize, null, null, null);

   }

   // clean old registry-data file 清理老的配置文件

   cleanFileConfData(confDataFileList);

获取节点配置信息,如果不为空,则同步对应节点的配置信息,然后清理老的配置文件。这里做了1个1000以上,做多次查询。

然后可以看到变更执行的监听:

XxlConfClient.addListener("default.key01", (key, value) ->logger.info("配置变更事件通知:{}={}", key, value));

总体来说,xxl-conf的作者比较贴心,很容易上手xxl-conf。


目录
相关文章
|
1月前
|
消息中间件 Java Kafka
Kafka【环境搭建 01】kafka_2.12-2.6.0 单机版安装+参数配置及说明+添加到service服务+开机启动配置+验证+chkconfig配置说明(一篇入门kafka)
【2月更文挑战第19天】Kafka【环境搭建 01】kafka_2.12-2.6.0 单机版安装+参数配置及说明+添加到service服务+开机启动配置+验证+chkconfig配置说明(一篇入门kafka)
47 1
|
7天前
|
存储 Linux 数据库
ZooKeeper【搭建 01】apache-zookeeper-3.6.2 单机版安装+配置+添加到service服务+开机启动配置+验证+chkconfig配置(一篇入门zookeeper)
【4月更文挑战第8天】ZooKeeper【搭建 01】apache-zookeeper-3.6.2 单机版安装+配置+添加到service服务+开机启动配置+验证+chkconfig配置(一篇入门zookeeper)
11 0
|
4月前
|
数据库连接
zookeeper应用场景一:实现配置中心动态更新配置
zookeeper应用场景一:实现配置中心动态更新配置
38 0
|
6月前
|
Java API 调度
xxl-job的原理(2)—调度中心管理注册信息
xxl-job的原理(2)—调度中心管理注册信息
96 0
xxl-job的原理(2)—调度中心管理注册信息
|
10月前
|
Java Unix Linux
Nacos config 配置中心详解
Nacos config 配置中心详解
896 0
|
11月前
|
运维 监控 网络协议
Apache ZooKeeper - FourLetterCommands运维命令
Apache ZooKeeper - FourLetterCommands运维命令
130 0
|
11月前
|
监控 Java Apache
Apache ZooKeeper - JMX监控 ZooKeeper 的运行状态
Apache ZooKeeper - JMX监控 ZooKeeper 的运行状态
95 0
|
存储 Java 开发工具
SpringCloud--Config Server配置中心学习总结
使用分布式微服务开发和部署项目,其中的一个优势就是:使用分布式配置协调服务,达到统一配置存储和使用。
160 0
SpringCloud--Config Server配置中心学习总结
|
Nacos 开发者 微服务
Nacos 配置中心(多配置文件加载1) | 学习笔记
快速学习 Nacos 配置中心(多配置文件加载1)
667 0
|
Java Nacos 数据安全/隐私保护
将配置文件发布 Nacos 配置中心|学习笔记
快速学习将配置文件发布 Nacos 配置中心
212 0
将配置文件发布 Nacos 配置中心|学习笔记

热门文章

最新文章

相关实验场景

更多