上一篇講配置變更時會發布RefreshEvent事件，監聽這個事件可以實現配置刷新。具體看一下。

1、監聽RefreshEvent

//org.springframework.cloud.endpoint.event.RefreshEventListener#onApplicationEvent
public void onApplicationEvent(ApplicationEvent event) {
    if (event instanceof ApplicationReadyEvent) {
        handle((ApplicationReadyEvent) event);
    }
    else if (event instanceof RefreshEvent) {
        handle((RefreshEvent) event);
    }
}

//org.springframework.cloud.endpoint.event.RefreshEventListener#handle
public void handle(RefreshEvent event) {
   if (this.ready.get()) { // don't handle events before app is ready
      log.debug("Event received " + event.getEventDesc());
      //調用refresh
       Set<String> keys = this.refresh.refresh();
      log.info("Refresh keys changed: " + keys);
   }
}

//org.springframework.cloud.context.refresh.ContextRefresher#refresh
public synchronized Set<String> refresh() {
   Set<String> keys = refreshEnvironment();
   this.scope.refreshAll();
   return keys;
}

1.1、發布EnvironmentChangeEvent

//org.springframework.cloud.context.refresh.ContextRefresher#refreshEnvironment
public synchronized Set<String> refreshEnvironment() {
   Map<String, Object> before = extract(
         this.context.getEnvironment().getPropertySources());
   addConfigFilesToEnvironment();
   Set<String> keys = changes(before,
         extract(this.context.getEnvironment().getPropertySources())).keySet();
   this.context.publishEvent(new EnvironmentChangeEvent(this.context, keys));
   return keys;
}

1.2、銷毀beans

//org.springframework.cloud.context.scope.refresh.RefreshScope#refreshAll
public void refreshAll() {
    //銷毀bean
   super.destroy();
    //發布事件，沒什么實現
   this.context.publishEvent(new RefreshScopeRefreshedEvent());
}

循環銷毀bean

//org.springframework.cloud.context.scope.GenericScope#destroy()
public void destroy() {
   List<Throwable> errors = new ArrayList<Throwable>();
   Collection<BeanLifecycleWrapper> wrappers = this.cache.clear();
   for (BeanLifecycleWrapper wrapper : wrappers) {
      try {
         Lock lock = this.locks.get(wrapper.getName()).writeLock();
         lock.lock();
         try {
            wrapper.destroy();
         }
         finally {
            lock.unlock();
         }
      }
      catch (RuntimeException e) {
         errors.add(e);
      }
   }
   if (!errors.isEmpty()) {
      throw wrapIfNecessary(errors.get(0));
   }
   this.errors.clear();
}

2、監聽EnvironmentChangeEvent

//org.springframework.cloud.context.properties.ConfigurationPropertiesRebinder#onApplicationEvent
public void onApplicationEvent(EnvironmentChangeEvent event) {
   if (this.applicationContext.equals(event.getSource())
         // Backwards compatible
         || event.getKeys().equals(event.getSource())) {
      rebind();
   }
}

重新綁定

//org.springframework.cloud.context.properties.ConfigurationPropertiesRebinder#rebind()
public void rebind() {
   this.errors.clear();
   for (String name : this.beans.getBeanNames()) {
      rebind(name);
   }
}

循環bean重新綁定

public boolean rebind(String name) {
   if (!this.beans.getBeanNames().contains(name)) {
      return false;
   }
   if (this.applicationContext != null) {
      try {
          //獲取bean
         Object bean = this.applicationContext.getBean(name);
          //如果是代理類，獲取被代理對象
         if (AopUtils.isAopProxy(bean)) {
            bean = ProxyUtils.getTargetObject(bean);
         }
         if (bean != null) {
            // TODO: determine a more general approach to fix this.
            // see https://github.com/spring-cloud/spring-cloud-commons/issues/571
            if (getNeverRefreshable().contains(bean.getClass().getName())) {
               return false; // ignore
            }
             //銷毀bean
            this.applicationContext.getAutowireCapableBeanFactory()
                  .destroyBean(bean);
             //初始化bean
            this.applicationContext.getAutowireCapableBeanFactory()
                  .initializeBean(bean, name);
            return true;
         }
      }
      catch (RuntimeException e) {
         this.errors.put(name, e);
         throw e;
      }
      catch (Exception e) {
         this.errors.put(name, e);
         throw new IllegalStateException("Cannot rebind to " + name, e);
      }
   }
   return false;
}

通過將原來的bean銷毀并且重新創建一個全新的bean來實現配置的刷新。這樣做有個問題，和原來的bean綁定的bean，可能就不能用了。還有一些bean重的緩存，比如說數據庫連接池，也被銷毀了。