diff --git a/nutzboot-starter/nutzboot-starter-nacos-config-client/pom.xml b/nutzboot-starter/nutzboot-starter-nacos-config-client/pom.xml new file mode 100644 index 00000000..c68fac3e --- /dev/null +++ b/nutzboot-starter/nutzboot-starter-nacos-config-client/pom.xml @@ -0,0 +1,24 @@ + + + + nutzboot-starter + org.nutz + 2.3.1-SNAPSHOT + + 4.0.0 + nutzboot-starter-nacos-config-client + + UTF-8 + + NutzBoot, micoservice base on Nutz + + + 0.9.0 + com.alibaba.nacos + nacos-client + + + + \ No newline at end of file diff --git a/nutzboot-starter/nutzboot-starter-nacos-config-client/src/main/java/org/nutz/boot/starter/nacos/NacosConfigureStarter.java b/nutzboot-starter/nutzboot-starter-nacos-config-client/src/main/java/org/nutz/boot/starter/nacos/NacosConfigureStarter.java new file mode 100644 index 00000000..5fb39b0e --- /dev/null +++ b/nutzboot-starter/nutzboot-starter-nacos-config-client/src/main/java/org/nutz/boot/starter/nacos/NacosConfigureStarter.java @@ -0,0 +1,125 @@ +package org.nutz.boot.starter.nacos; + +import com.alibaba.nacos.api.NacosFactory; +import com.alibaba.nacos.api.config.ConfigService; +import com.alibaba.nacos.api.config.listener.Listener; +import org.nutz.boot.AppContext; +import org.nutz.boot.annotation.PropDoc; +import org.nutz.boot.starter.ServerFace; +import org.nutz.ioc.impl.PropertiesProxy; +import org.nutz.ioc.loader.annotation.Inject; +import org.nutz.ioc.loader.annotation.IocBean; +import org.nutz.lang.Lang; +import org.nutz.lang.Strings; +import org.nutz.lang.stream.StringInputStream; +import org.nutz.lang.util.NutMap; +import org.nutz.log.Log; +import org.nutz.log.Logs; + +import java.io.IOException; +import java.util.Properties; +import java.util.concurrent.Executor; + +/** + * @author wentao + * @email wentao0291@gmail.com + * @date 2019-03-06 21:45 + */ +@IocBean +public class NacosConfigureStarter implements ServerFace { + + /** + * 获取日志对象 + */ + private static final Log log = Logs.get(); + /** + * Nacos配置项前缀 + */ + protected static final String NACOS_PRE = "nacos.config."; + /** + * Nacos远程地址配置项 + */ + @PropDoc(value = "Nacos远程地址") + public static final String NACOS_ADDR = NACOS_PRE + "addr"; + /** + * Nacos Data ID 配置项 + */ + @PropDoc(value = "Nacos Data ID") + public static final String NACOS_DATA_ID = NACOS_PRE + "data_id"; + /** + * Nacos分组配置项 + */ + @PropDoc(value = "Nacos分组") + public static final String NACOS_GROUP = NACOS_PRE + "group"; + /** + * Nacos数据类型配置项（用于识别使用哪种方式解析配置项） + * 支持配置： json, properties, xml + */ + @PropDoc(value = "Nacos数据类型") + public static final String NACOS_DATA_TYPE = NACOS_PRE + "data_type"; + + @Inject + protected AppContext appContext; + + + @Override + public void start() throws Exception { + + PropertiesProxy conf = appContext.getConf(); + + String serverAddr = conf.get(NACOS_ADDR); + String dataId = conf.get(NACOS_DATA_ID); + String group = conf.get(NACOS_GROUP); + String dataType = conf.get(NACOS_DATA_TYPE); + + if(Strings.isBlank(serverAddr) || Strings.isBlank(dataId) || Strings.isBlank(group) || Strings.isBlank(dataType)) { + log.debugf("nacos server config is not found or incomplete, skip..."); + } else { + Properties properties = new Properties(); + properties.put("serverAddr", serverAddr); + ConfigService configService = NacosFactory.createConfigService(properties); + String configInfo = configService.getConfig(dataId, group, 5000); + log.debugf("get nacos config：%s", configInfo); + if (Strings.isNotBlank(configInfo)) { + setConfig(configInfo, dataType); + } + configService.addListener(dataId, group, new Listener() { + @Override + public void receiveConfigInfo(String configInfo) { + log.debugf("receive nacos server config：%s", configInfo); + if (Strings.isNotBlank(configInfo)) { + setConfig(configInfo, dataType); + } + } + + @Override + public Executor getExecutor() { + return null; + } + }); + } + } + + private void setConfig(String content, String contentType) { + PropertiesProxy conf = appContext.getConf(); + if ("json".equals(contentType)) { + NutMap configMap = new NutMap(content); + conf.putAll(configMap); + } else if ("xml".equals(contentType)) { + Properties properties = new Properties(); + try { + properties.loadFromXML(new StringInputStream(content)); + for (Object key : properties.keySet()) { + conf.put(key.toString(), properties.get(key).toString()); + } + } catch (IOException e) { + throw Lang.makeThrow("nacos config xml parse error!"); + } + } else if ("properties".equals(contentType)) { + PropertiesProxy propertiesProxy = new PropertiesProxy(new StringInputStream(content)); + conf.putAll(propertiesProxy); + } else { + throw Lang.makeThrow("nacos.config.data_type is not found or not recognize，only json,xml and properties are support!"); + } + } +} diff --git a/nutzboot-starter/nutzboot-starter-nacos-config-client/src/main/resources/META-INF/nutz/org.nutz.boot.starter.NbStarter b/nutzboot-starter/nutzboot-starter-nacos-config-client/src/main/resources/META-INF/nutz/org.nutz.boot.starter.NbStarter new file mode 100644 index 00000000..c07e7714 --- /dev/null +++ b/nutzboot-starter/nutzboot-starter-nacos-config-client/src/main/resources/META-INF/nutz/org.nutz.boot.starter.NbStarter @@ -0,0 +1 @@ +org.nutz.boot.starter.NacosConfigureStarter diff --git a/nutzboot-starter/pom.xml b/nutzboot-starter/pom.xml index aea864ba..695920d1 100644 --- a/nutzboot-starter/pom.xml +++ b/nutzboot-starter/pom.xml @@ -72,7 +72,8 @@ nutzboot-starter-logback-exts nutzboot-starter-sentinel-annotation nutzboot-starter-tio-websocket - + nutzboot-starter-nacos-config-client + org.nutz