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();}}