SpringBoot读取自定义格式的Nacos配置的示例详解

public class nacosconfiglocalcatch implements initializingbean {
	/**
	 * 实现加载nacos配置的逻辑
	 */
	@override
	public void afterpropertiesset() {
	}
}

listener listener=new listener(){
				@override
				public executor getexecutor() {
					return threadpoolexecutor;
				}
				@override
				public void receiveconfiginfo(string configinfo) {
					log.info("{}#receiveconfiginfo receive configinfo. configinfo={}", configinfo);
					compile(configinfo, nacosconfiginfo);
				}
			}

package com.vzan.config.securityurl;

import lombok.data;

/**
 * @author 欧益强
 * @date  2023年11月13日 下午2:14:37
 */
@data
public class nacosconfiginfo {

    private string serveraddr;
    private string namespace;
    private string group;
    private string dataid;
    private boolean refresh = true;

    public nacosconfiginfo() {
    }
    public nacosconfiginfo(string serveraddr, string namespace, string group, string dataid, boolean refresh) {
        this.serveraddr = serveraddr;
        this.namespace = namespace;
        this.group = group;
        this.dataid = dataid;
        this.refresh = refresh;
    }
    public long gettimeout() {
        return 5000l;
    }

}

/**
 *
 */
package com.vzan.config.securityurl;

import com.alibaba.cloud.nacos.nacosconfigproperties;
import com.alibaba.nacos.api.nacosfactory;
import com.alibaba.nacos.api.propertykeyconst;
import com.alibaba.nacos.api.config.configservice;
import com.alibaba.nacos.api.config.listener.listener;
import com.alibaba.nacos.api.exception.nacosexception;
import com.google.common.collect.lists;

import cn.hutool.json.jsonutil;
import lombok.extern.slf4j.slf4j;

import org.slf4j.logger;
import org.slf4j.loggerfactory;
import org.springframework.beans.factory.initializingbean;
import org.springframework.util.stringutils;

import javax.annotation.resource;
import java.util.hashmap;
import java.util.list;
import java.util.map;
import java.util.properties;
import java.util.concurrent.executor;
import java.util.concurrent.linkedblockingdeque;
import java.util.concurrent.threadpoolexecutor;
import java.util.concurrent.timeunit;

/**
 * @author eakom
 * @date 2023年11月13日 下午2:11:46
 */
@slf4j
public class nacosconfiglocalcatch implements initializingbean {
	/**
	 * 定义需要获取nacos配置的dataid
	 */
	private list<string> nacosconfiglocalcacheinfolist = lists.newarraylist("live-common-setting");
	/**
	 * 定义一个map，存在配置到本定
	 */
	private map<string, string> localcatchmap = new hashmap<>();

	@resource
	private nacosconfigproperties nacosconfigproperties;

	private static threadpoolexecutor threadpoolexecutor;
	/**
	 * 初始化线程
	 */
	static {
		threadpoolexecutor = new threadpoolexecutor(2, 4, 1, timeunit.seconds, new linkedblockingdeque<>(100),
				new threadpoolexecutor.callerrunspolicy());
	}

	/**
	 * 实现加载nacos配置的逻辑
	 */
	@override
	public void afterpropertiesset() {
		nacosconfiglocalcacheinfolist.foreach(k -> {
			nacosconfiginfo nacosconfiginfo = new nacosconfiginfo(nacosconfigproperties.getserveraddr(),
					nacosconfigproperties.getnamespace(), nacosconfigproperties.getgroup(), k, true);

			this.intnacosconfig(nacosconfiginfo);
		});
	}
	
	/**
	 * 获取configservice
	 * 
	 * @param nacosconfiginfo nacosconfiginfo
	 * @return configservice
	 */
	private configservice getconfigservice(nacosconfiginfo nacosconfiginfo) {
		string serveraddr = nacosconfiginfo.getserveraddr();
		string namespace = nacosconfiginfo.getnamespace();
		properties properties = new properties();
		properties.put(propertykeyconst.server_addr, serveraddr);
		if (!stringutils.isempty(namespace)) {
			properties.put(propertykeyconst.namespace, namespace);
		}
		configservice configservice;
		try {
			configservice = nacosfactory.createconfigservice(properties);
		} catch (nacosexception e) {
			e.printstacktrace();
			throw new runtimeexception("nacos config 配置 异常");
		}
		return configservice;
	}
	
	/**
	 * 初始化nacos配置
	 * @param nacosconfiginfo
	 */
	private void intnacosconfig(nacosconfiginfo nacosconfiginfo) {
		configservice configservice = this.getconfigservice(nacosconfiginfo);
		try {
			string config = configservice.getconfig(nacosconfiginfo.getdataid(), 
				nacosconfiginfo.getgroup(),nacosconfiginfo.gettimeout());
			log.info("{}#afterpropertiesset init configinfo. configinfo={}", config);
			// 初始化
			compile(config, nacosconfiginfo);
			// 监听
			configservice.addlistener(nacosconfiginfo.getdataid(), nacosconfiginfo.getgroup(), 
				new listener(){
				@override
				public executor getexecutor() {
					return threadpoolexecutor;
				}
				@override
				public void receiveconfiginfo(string configinfo) {
					log.info("{}#receiveconfiginfo receive configinfo. configinfo={}", configinfo);
					compile(configinfo, nacosconfiginfo);
				}
				});
		} catch (nacosexception e) {
			e.printstacktrace();
			throw new runtimeexception("nacos server 监听 异常! dataid = " + nacosconfiginfo.getdataid());
		}
	}
	/**
	 * 加载nacos配置到本定环境
	 * @param config
	 * @param nacosconfiginfo
	 */
	private void compile(string config, nacosconfiginfo nacosconfiginfo) {
		if ("live-common-setting".equals(nacosconfiginfo.getdataid())) {
			livecommonsetting json = jsonutil.tobean(config, livecommonsetting.class);
			if (json == null) {
				log.error("common配置解析失败");
				return;
			}
		}
		localcatchmap.put(nacosconfiginfo.getdataid(), config);
	}

	

	public string get(string dataid) {
		return localcatchmap.get(dataid);
	}
	/**
	*获取配置
	*/
	public livecommonsetting getlivecommonsetting() {
		string config = localcatchmap.get("live-common-setting");
		livecommonsetting fromjson = jsonutil.tobean(config, livecommonsetting.class);
		return fromjson;
	}

}

@configuration(proxybeanmethods = false)
public class securityurlconfig {
	@bean
	@conditionalonproperty(value = "enabled.securityurl",matchifmissing = false)
	public nacosconfiglocalcatch initnacosconfiglocalcatch() {
		nacosconfiglocalcatch config=new nacosconfiglocalcatch();
		return config;
	}
}