Nacos ģ Key ԪΨһȷ, NamespaceĬǿմռ䣨publicĬ DEFAULT_GROUP

@SpringBootApplication
public class NacosConfigApplication {

    public static void main(String[] args) throws InterruptedException {
        ConfigurableApplicationContext applicationContext = SpringApplication.run(NacosConfigApplication.class, args);

         while(true) {
        //̬ˢʱµ EnviromentУÿһдEnviromentлȡ
         String userName = applicationContext.getEnvironment().getProperty("common.name");
        String userAge = applicationContext.getEnvironment().getProperty("common.age");
        System.err.println("common name :" + userName + "; age: " + userAge);
            TimeUnit.SECONDS.sleep(1);
        }
    }
}
ƴ

spring.profiles.active=dev
ƴ

spring.cloud.nacos.config.namespace=71bb9785-231f-4eca-b4dc-6be446e12ff8
ƴ

spring.cloud.nacos.config.group=DEVELOP_GROUP
ƴ

# Զ Data Id 
#̵ͬͨ ֹ֧ DataId
spring.cloud.nacos.config.sharedConfigs[0].data-id= common.yaml
spring.cloud.nacos.config.sharedConfigs[0].group=REFRESH_GROUP
spring.cloud.nacos.config.sharedConfigs[0].refresh=true

# config external configuration
# ֧һӦö DataId 
spring.cloud.nacos.config.extensionConfigs[0].data-id=ext-config-common01.properties
spring.cloud.nacos.config.extensionConfigs[0].group=REFRESH_GROUP
spring.cloud.nacos.config.extensionConfigs[0].refresh=true

spring.cloud.nacos.config.extensionConfigs[1].data-id=ext-config-common02.properties
spring.cloud.nacos.config.extensionConfigs[1].group=REFRESH_GROUP
ƴ

@RestController
@RefreshScope
public class TestController {

    @Value("${common.age}")
    private String age;

    @GetMapping("/common")
    public String hello() {
        return age;
    }
}
ƴ

public class ConfigServerDemo {

    public static void main(String[] args) throws NacosException, InterruptedException {
        String serverAddr = "localhost";
        String dataId = "nacos-config-demo.yaml";
        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("===recieve:" + configInfo);
            }

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

        //
        //boolean isPublishOk = configService.publishConfig(dataId, group, "content");
        //System.out.println(isPublishOk);
        //propertiesʽ
        configService.publishConfig(dataId,group,"common.age=30", ConfigType.PROPERTIES.getType());

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

    ȡõҪ NacosConfigService  getConfig ͨ¸÷ֱӴӱļȡõֵļڻΪգͨ HTTP GET Զȡã浽ؿСͨ HTTP ȡԶʱNacos ṩ۶ϲԣһdzʱʱ䣬ԴĬΡ

     ClientWorker ͨµ̳߳óѯĹһǵ̵߳ executorÿ 10ms ÿ 3000 Ϊһȡѯ cacheData ʵװΪһ LongPollingTask ύڶ̳߳ executorService 

   ʱͻ DumpService  init ݿ load ô洢ڱشϣһЩҪԪϢ MD5 ֵڴС˻ļбһʱ䣬жϵǴݿ dump ȫݻDzݣϴ 6h ڵĻ

    õĴλ ConfigController#publishConfigСȺһʼҲֻһ̨̨òMysqlнг־û˲ÿòѯȥ MySQL ǻ dump ڱļнû˵̨֮Ҫ֪ͨˢڴͱشеļݣᷢһΪ ConfigDataChangeEvent ¼¼ͨ HTTP ֪ͨмȺڵ㣨ļڴˢ¡

    ͻ˻һѯȡ˵ñ˴߼LongPollingServiceУһ Runnable ΪClientLongPolling˻Ὣܵѯװһ ClientLongPolling 񣬸һ AsyncContext Ӧͨʱ̳߳Ӻ 29.5s ִСȿͻ 30s ijʱʱǰ 500ms Ϊ̶ϱ֤ͻ˲Ϊʱɳʱ.