SpringBoot 中 @ConfigurationProperties 配置后 apollo 自动刷新

清疚 2021-10-06 13:06 1366阅读 0赞

### 1、在配置文件（如：application.properties）中，开启Apollo的自动更新 ###

spring.boot.enableautoconfiguration=true

### 2.实现ApplicationContextAware ###

package com.qbz.test.commons.web.config;
    
    
    import com.ctrip.framework.apollo.model.ConfigChangeEvent;
    import com.ctrip.framework.apollo.spring.annotation.ApolloConfigChangeListener;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.BeansException;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.cloud.context.environment.EnvironmentChangeEvent;
    import org.springframework.cloud.context.scope.refresh.RefreshScope;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.stereotype.Component;
    
    /** * apollo 自动刷新 * * @author qubianzhong * @Date 20:32 2019/11/11 */
    @Component
    @Slf4j
    public class ApolloRefreshConfig implements ApplicationContextAware { 
    
        ApplicationContext applicationContext;
    
        @Autowired
        RefreshScope refreshScope;
    
    	//这里指定Apollo的namespace，非常重要，如果不指定，默认只使用application
        @ApolloConfigChangeListener(value = { ConfigConsts.NAMESPACE_APPLICATION,"business","everything"})
        public void onChange(ConfigChangeEvent changeEvent) { 
            for (String changedKey : changeEvent.changedKeys()) { 
                log.info("apollo changed namespace:{} Key:{} value:{}", changeEvent.getNamespace(), changedKey, changeEvent.getChange(changedKey));
            }
            refreshProperties(changeEvent);
        }
    
        public void refreshProperties(ConfigChangeEvent changeEvent) { 
            this.applicationContext.publishEvent(new EnvironmentChangeEvent(changeEvent.changedKeys()));
            refreshScope.refreshAll();
        }
    
        @Override
        public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { 
            this.applicationContext = applicationContext;
        }
    }