studio/java.md

1.8 KiB

/*

  • Demo for Nacos
  • pom.xml com.alibaba.nacos nacos-client ${version} */ package com.alibaba.nacos.example;

import java.util.Properties; import java.util.concurrent.Executor; import com.alibaba.nacos.api.NacosFactory; import com.alibaba.nacos.api.config.ConfigService; import com.alibaba.nacos.api.config.listener.Listener; import com.alibaba.nacos.api.exception.NacosException;

/**

  • Config service example
  • @author Nacos

*/ public class ConfigExample {

public static void main(String[] args) throws NacosException, InterruptedException {
	String serverAddr = "localhost";
	String dataId = "application-prod.yml";
	String group = "DEFAULT_GROUP";
	Properties properties = new Properties();
	properties.put(PropertyKeyConst.SERVER_ADDR, 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("receive:" + configInfo);
		}

		@Override
		public Executor getExecutor() {
			return null;
		}
	});

	boolean isPublishOk = configService.publishConfig(dataId, group, "content");
	System.out.println(isPublishOk);

	Thread.sleep(3000);
	content = configService.getConfig(dataId, group, 5000);
	System.out.println(content);

	boolean isRemoveOk = configService.removeConfig(dataId, group);
	System.out.println(isRemoveOk);
	Thread.sleep(3000);

	content = configService.getConfig(dataId, group, 5000);
	System.out.println(content);
	Thread.sleep(300000);

}

}