nacos的各种类型的配置文件 yml 、json、 Properties、 text 等文件类型 发生变化怎么热更新，实现实时监听nacos配置文件变化

2024-03-29 18:28
文章标签 变化 实现 json 怎么 更新 nacos 实时 监听 配置文件 text properties yml 发生变化 文件类型 各种类型

本文主要是介绍nacos的各种类型的配置文件 yml 、json、 Properties、 text 等文件类型 发生变化怎么热更新，实现实时监听nacos配置文件变化，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

本文用的是 Nacos作为配置中心注册监听器方法 实现热更新 nacos 配置文件
从而不用重启项目

依赖、工具类 这边就不写了

因为项目用的是 Json 类型的配置文件
所以下文 主要是对json文件进行实现
别的文件大同小异
先说扯淡的东西

在这里插入图片描述
在nacos 的配置文件中
dataId 这两种声明 是不一样
虽然打开里面的配置信息都是 json格式
但是 dataId的命名不一样 我理解为 aaa 这种 等于你创建了一个没有后缀的配置文件

下面开始直接上实现代码
第一步 配置文件 ：

# nacos 配置文件监听 参数
nacos:listener:dataId:- systemConfig

第二步

package com.init.config.nacos;import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;import java.util.List;/*** User:Json* Date: 2024/3/28*  获取 nacos上的文件名**/
@Data
@Configuration
@ConfigurationProperties("nacos.listener")
public  class DataIdConfig {private List<String> dataId;
}

第三步

package com.init.config.nacos;import com.alibaba.fastjson.JSON;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import com.api.constant.CommonConstant;
import com.api.response.nacos.SystemConfigNacos;
import com.init.utils.RedisUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.StringUtils;import javax.annotation.Resource;
import java.util.List;
import java.util.Properties;
import lombok.extern.slf4j.Slf4j;/*** User:Json* Date: 2024/3/28**/
@Slf4j
@Configuration
public class NacosInitConfig {public static final long DEFAULT_TIMEOUT = 30000;private ConfigService configService;@Value("${spring.cloud.nacos.discovery.server-addr:}")public  String NACOS_SERVER_ADDR;@Value("${spring.cloud.nacos.discovery.namespace:}")public  String NACOS_NAMESPACE;@ResourceDataIdConfig nacosDataIdConfig;@Value("${spring.cloud.nacos.discovery.group}")public  String NACOS_ROUTE_GROUP;private static final String systemConfig="systemConfig";private static final String linkLibrary="linkLibrary";public   void nacos(){try {configService = initConfigService();if (configService == null) {log.error("初始化Nacos 失败！");return;}List<String> dataIdList = nacosDataIdConfig.getDataId();for (String dataId : dataIdList) {//                if (dataId.endsWith("yml")) {
//                    configService.addListener(dataId, NACOS_ROUTE_GROUP, new YmlCallListener());
//                }else if (dataId.endsWith("json")) {
//                    configService.addListener(dataId, NACOS_ROUTE_GROUP, new YmlCallListener());
//                }else{
//                    configService.addListener(dataId,NACOS_ROUTE_GROUP, new YmlCallListener());
//                }switch (dataId){case systemConfig:String configInfo = configService.getConfig(dataId, NACOS_ROUTE_GROUP, DEFAULT_TIMEOUT);//   log.info("获取 systemConfig 配置文件:\r\n{}", configInfo);if(StringUtils.isEmpty(configInfo)){break;}SystemConfigNacos systemConfigNacos = JSON.parseObject(configInfo, SystemConfigNacos.class);
//                        System.out.println(systemConfigNacos.getJwtOrgKey());if(!RedisUtils.hasKey(CommonConstant.REDIS_SYSTEM_CONFIG_NACOS_JAVA)){RedisUtils.setString(CommonConstant.REDIS_SYSTEM_CONFIG_NACOS_JAVA,systemConfigNacos,-1);}configService.addListener(dataId,NACOS_ROUTE_GROUP, new JsonCallListener<>(SystemConfigNacos.class));break;case linkLibrary:break;}}} catch (Exception e) {log.error("初始化 配置文件发生错误", e);}}private ConfigService initConfigService() {try {Properties properties = new Properties();properties.setProperty("serverAddr", NACOS_SERVER_ADDR);properties.setProperty("namespace", NACOS_NAMESPACE);return configService = NacosFactory.createConfigService(properties);} catch (Exception e) {log.error("初始化 Nacos 配置文件发生错误", e);return null;}}
}

第四步：
1.

package com.init.config.nacos;import com.alibaba.fastjson.JSON;
import com.api.constant.CommonConstant;
import com.api.response.nacos.SystemConfigNacos;
import com.init.utils.RedisUtils;
import lombok.AllArgsConstructor;
import com.alibaba.nacos.api.config.listener.Listener;
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.Executor;
/*** User:Json* Date: 2024/3/28**/
@Slf4j
@AllArgsConstructor
public class JsonCallListener<T> implements Listener {private Class<T> instanceClass;@Overridepublic Executor getExecutor() {return null;}@Overridepublic void receiveConfigInfo(String configInfo) {// log.info("nacos中的Json数据发生变化了：{}", configInfo);T systemConfigNacos = JSON.parseObject(configInfo, instanceClass);if(RedisUtils.hasKey(CommonConstant.REDIS_SYSTEM_CONFIG_NACOS_JAVA)){RedisUtils.delete(CommonConstant.REDIS_SYSTEM_CONFIG_NACOS_JAVA);}RedisUtils.setString(CommonConstant.REDIS_SYSTEM_CONFIG_NACOS_JAVA,systemConfigNacos,-1);}
}
package com.init.config.nacos;
import com.alibaba.nacos.api.config.listener.Listener;
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.Executor;
/*** User:Json* Date: 2024/3/28**/
@Slf4j
public class YmlCallListener implements Listener {@Overridepublic Executor getExecutor() {return null;}@Overridepublic void receiveConfigInfo(String configInfo) {//log.info("Yml配置内容发生更改：{}", configInfo);}
}

最后一步

package com.init.init;import com.alibaba.fastjson.JSON;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;import com.api.constant.CommonConstant;
import com.api.response.nacos.SystemConfigNacos;
import com.init.config.nacos.DataIdConfig;
import com.init.config.nacos.JsonCallListener;
import com.init.config.nacos.NacosInitConfig;
import com.init.utils.RedisUtils;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;import javax.annotation.Resource;
import java.util.List;
import java.util.Properties;/*** User:Json* Date: 2024/3/22* Spring Boot应用程序启动后执行某些操作* 我用的是这个 启动项  因为 我要redis  * 如果你不需要用redis * 用* @PostConstructprivate void init() 也行 **/
@Component
@Slf4j
@Data
public class NacosInitializeRunner implements CommandLineRunner {@Autowiredprivate NacosInitConfig nacosInitConfig;@Overridepublic void run(String... args) {nacosInitConfig.nacos();}}

启动项目测试

这篇关于nacos的各种类型的配置文件 yml 、json、 Properties、 text 等文件类型 发生变化怎么热更新，实现实时监听nacos配置文件变化的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/859315。

相关文章

Springboot处理跨域的实现方式(附Demo)

Springboot处理跨域的实现方式(附Demo)

《Springboot处理跨域的实现方式(附Demo)》：本文主要介绍Springboot处理跨域的实现方式(附Demo),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不... 目录Springboot处理跨域的方式1. 基本知识2. @CrossOrigin3. 全局跨域设置4.
阅读更多...
Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

《SpringBoot3.4.3基于SpringWebFlux实现SSE功能(代码示例)》SpringBoot3.4.3结合SpringWebFlux实现SSE功能,为实时数据推送提供... 目录1. SSE 简介1.1 什么是 SSE？1.2 SSE 的优点1.3 适用场景2. Spring WebFlu
阅读更多...
基于SpringBoot实现文件秒传功能

基于SpringBoot实现文件秒传功能

《基于SpringBoot实现文件秒传功能》在开发Web应用时,文件上传是一个常见需求,然而,当用户需要上传大文件或相同文件多次时,会造成带宽浪费和服务器存储冗余,此时可以使用文件秒传技术通过识别重复... 目录前言文件秒传原理代码实现1. 创建项目基础结构2. 创建上传存储代码3. 创建Result类4.
阅读更多...
Java利用JSONPath操作JSON数据的技术指南

Java利用JSONPath操作JSON数据的技术指南

《Java利用JSONPath操作JSON数据的技术指南》JSONPath是一种强大的工具,用于查询和操作JSON数据,类似于SQL的语法,它为处理复杂的JSON数据结构提供了简单且高效... 目录1、简述2、什么是 jsONPath？3、Java 示例3.1 基本查询3.2 过滤查询3.3 递归搜索3.4
阅读更多...
SpringBoot日志配置SLF4J和Logback的方法实现

SpringBoot日志配置SLF4J和Logback的方法实现

《SpringBoot日志配置SLF4J和Logback的方法实现》日志记录是不可或缺的一部分,本文主要介绍了SpringBoot日志配置SLF4J和Logback的方法实现,文中通过示例代码介绍的非... 目录一、前言二、案例一：初识日志三、案例二：使用Lombok输出日志四、案例三：配置Logback一
阅读更多...
Python如何使用__slots__实现节省内存和性能优化

Python如何使用__slots__实现节省内存和性能优化

《Python如何使用__slots__实现节省内存和性能优化》你有想过,一个小小的__slots__能让你的Python类内存消耗直接减半吗,没错,今天咱们要聊的就是这个让人眼前一亮的技巧,感兴趣的... 目录背景：内存吃得满满的类__slots__：你的内存管理小助手举个大概的例子：看看效果如何？1.
阅读更多...
Python+PyQt5实现多屏幕协同播放功能

Python+PyQt5实现多屏幕协同播放功能

《Python+PyQt5实现多屏幕协同播放功能》在现代会议展示、数字广告、展览展示等场景中,多屏幕协同播放已成为刚需,下面我们就来看看如何利用Python和PyQt5开发一套功能强大的跨屏播控系统吧... 目录一、项目概述：突破传统播放限制二、核心技术解析2.1 多屏管理机制2.2 播放引擎设计2.3 专
阅读更多...
Python实现无痛修改第三方库源码的方法详解

Python实现无痛修改第三方库源码的方法详解

《Python实现无痛修改第三方库源码的方法详解》很多时候,我们下载的第三方库是不会有需求不满足的情况,但也有极少的情况,第三方库没有兼顾到需求,本文将介绍几个修改源码的操作,大家可以根据需求进行选择... 目录需求不符合模拟示例 1. 修改源文件2. 继承修改3. 猴子补丁4. 追踪局部变量需求不符合很
阅读更多...
idea中创建新类时自动添加注释的实现

idea中创建新类时自动添加注释的实现

《idea中创建新类时自动添加注释的实现》在每次使用idea创建一个新类时,过了一段时间发现看不懂这个类是用来干嘛的,为了解决这个问题,我们可以设置在创建一个新类时自动添加注释,帮助我们理解这个类的用... 目录前言：详细操作：步骤一：点击上方的 文件（File），点击&nbmyHIgsp;设置（Setti
阅读更多...
SpringBoot实现MD5加盐算法的示例代码

SpringBoot实现MD5加盐算法的示例代码

《SpringBoot实现MD5加盐算法的示例代码》加盐算法是一种用于增强密码安全性的技术,本文主要介绍了SpringBoot实现MD5加盐算法的示例代码,文中通过示例代码介绍的非常详细,对大家的学习... 目录一、什么是加盐算法二、如何实现加盐算法2.1 加盐算法代码实现2.2 注册页面中进行密码加盐2.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2