微服务配置中心-Nacos

一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。

# OPEN-API
curl -x GET "http://serverIp:8848/nacos/v1/cs/configs?dataId=dataIdparam&group=groupParam&tenant=tenantParam
"

public String getConfig(String dataId, String group, long timeoutMs) throws NacosException

@NacosInjected
private ConfigService configService;

@Test
public void testPublishConfig() throws NacosException {
    configService.publishConfig(DATA_ID, DEFAULT_GROUP, "9527");
}

String serverAddr = "{serverAddr}";
String dataId = "{dataId}";
String group = "{group}";
Properties properties = new Properties();
properties.put("serverAddr", serverAddr);
ConfigService configService = NacosFactory.createConfigService(properties);
String content = configService.getConfig(dataId, group, 5000);
System.out.println(content);
configService.addListener(dataId, group, new Listener() {
	@Override
	public void receiveConfigInfo(String configInfo) {
		System.out.println("recieve1:" + configInfo);
	}
	@Override
	public Executor getExecutor() {
		return null;
	}
});

// 测试让主线程不退出，因为订阅配置是守护线程，主线程退出守护线程就会退出。 正式代码中无需下面代码
while (true) {
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

			String serverAddr = "localhost";
			String dataId = "DATA_ID";
			String group = "DEFAULT_GROUP";
			Properties properties = new Properties();
			properties.put("serverAddr", serverAddr);
			configService = NacosFactory.createConfigService(properties);
			String content = configService.getConfig(dataId, group, 5000);
			// 加载文件前设置分隔符失效(不使用任何分隔符).
			config.setDelimiterParsingDisabled(true);

			// 将字符串转换成PropertiesConfiguration格式
			config.load(new ByteArrayInputStream(content.getBytes()));

			configService.addListener(dataId, group, new Listener() {
				// 监听变化
				public void receiveConfigInfo(String configInfo) {
					try {
						// 需要先clear再load，不然load不生效
						config.clear();
						config.load(new ByteArrayInputStream(configInfo.getBytes()));
					} catch (ConfigurationException e) {
						e.printStackTrace();
					}
				}
				public Executor getExecutor() {
					return null;
				}
			});
		} catch (ConfigurationException e) {
			logger.error("create conf file error.", e);
			e.printStackTrace();
		}