快捷導(dǎo)航

讀寫nacos的配置中心的參數(shù)及變動(dòng)監(jiān)聽方式

更新時(shí)間：2026年02月11日 17:16:19 作者：OK_boom

Spring應(yīng)用可以通過NacosDataSource下載配置參數(shù),使用ConfigService的publishConfig方法更新Nacos上的配置,但同一服務(wù)內(nèi)部更新配置不會(huì)觸發(fā)configUpdate事件,ConfigService也提供了監(jiān)聽事件功能

最簡單的方法

是借組sentinel的NacosDataSource完成這個(gè)操作，如下例子：

@Configuration
@Slf4j
@Getter
public class AuthenConfig {
  @Value("${spring.cloud.nacos.discovery.server-addr}")
  private String nacosAddrs;
  private String groupId="my-seta-business";
  private String dataId="my-seta-business:authen-Config";

  private EasyShiroProperties properties;
  @PostConstruct
  public void init(){
    ReadableDataSource<String, EasyShiroProperties> nacosDataSource = new NacosDataSource<>(nacosAddrs, groupId, dataId,
            source -> JsonUtils.fromJson(source, new TypeReference<>() {
            }));
    synchronized (nacosDataSource.getProperty()) {
      nacosDataSource.getProperty().addListener(new PropertyListener(){
        private void updateLocal(Object value){
          properties=(EasyShiroProperties)value;
        }
        @Override
        public void configUpdate(Object value) { //nacos的配置更新時(shí)觸發(fā)
           log.info("configUpdate:"+value);
           updateLocal(value);
        }

        @Override
        public void configLoad(Object value) {//第一次下載nacos配置時(shí)觸發(fā)
          log.info("configLoad:"+value);
          updateLocal(value);
        }
      });
    }
  }
}

監(jiān)聽器有兩個(gè)事件

一個(gè)是首次下載觸發(fā)的configLoad,一個(gè)是nacos配置更新觸發(fā)的configUpload。

那么如何用代碼更新nacos上的配置？用ConfigService的publishConfig,下面例子：

String groupId="my-seta-business";
    String dataId="my-seta-business:authen-Config";
    try {
      ConfigService configService = NacosFactory.createConfigService("128.30.14.249:8848");
      System.out.println(configService.publishConfig(dataId, groupId, "{\"sessionTimeOut\":3600,\"cacheEnabled\":true,\"sessionRegion\":\"my-seata-business-region\",\"sessionTokenName\":\"access-token\",\"jwtTokenName\":\"access-token\"}"));
    } catch (NacosException e) {
      e.printStackTrace();
    }

值得注意的是

同一個(gè)服務(wù)里面即使用上述方法更新配置到nacos，也不會(huì)觸發(fā)configUpdate事件，configUpdate必須是本服務(wù)以外的地方發(fā)生更新才會(huì)觸發(fā)，可見作者比較嚴(yán)謹(jǐn)。

如果我沒用sentinel，只想用ConfigService監(jiān)聽配置中心的數(shù)據(jù)異動(dòng)又怎樣做呢？ConfigService也有監(jiān)聽事件，代碼如下：

/**
 * Created by rocklee on 2022/4/20 14:13
 */
@Slf4j
@Configuration
public class AccountConfig implements InitializingBean , DisposableBean {
  @Value("${spring.application.name}")
  private String app;
  @Value("${spring.profiles.active:}")
  private String profile;
  @Value("${spring.cloud.nacos.config.file-extension}")
  private String fileExtension;
  @Value("${spring.cloud.nacos.config.server-addr}")
  private String configServerAddr;
  private ConfigService configService;
  @PostConstruct
  public void init(){
  }

  @Override
  public void afterPropertiesSet() throws Exception {
    String dataId=app+(StringUtils.isBlank(profile)?"": "-"+profile)+"."+fileExtension;
    final String group="DEFAULT_GROUP";
    Properties properties=new Properties();
    properties.put(PropertyKeyConst.SERVER_ADDR, configServerAddr);
    configService= NacosFactory.createConfigService(properties);
    log.info("nacos config:"+configService.getConfig(dataId,group,1000));
    try {
      configService.addListener(dataId, group, new AbstractListener() {
        @Override
        public void receiveConfigInfo(String configInfo) {
          System.out.println(configInfo);
        }
      });
    } catch (NacosException e) {
      e.printStackTrace();
    }
  }

  @Override
  public void destroy() throws Exception {
    configService.shutDown();
  }
}