Apollo源码学习之:配置热更新原理(四)

# 在日志上,会提示:AutoUpdateConfigChangeListener刷新配置成功,所以,你懂的.

public class AutoUpdateConfigChangeListener 
		// 1. 这个是Apollo定义的接口,当配置有变化时,会回调:ConfigChangeListener.onChange方法
       implements ConfigChangeListener{
	
	public void onChange(ConfigChangeEvent changeEvent) {
		
	    Set<String> keys = changeEvent.changedKeys();
		// 事件没有内容的情况下,直接返回.
	    if (CollectionUtils.isEmpty(keys)) {
	      return;
	    }
		
		// 2.遍历有更新的key(比如:jdbc.url)
	    for (String key : keys) {
		  // 3. 委托给:SpringValueRegistry.get方法,根据key,找到:SpringValue
		  //    因为,jdbc.url这个key,可能会存在于多个类里,所以,返回的是集合.
	      Collection<SpringValue> targetValues = springValueRegistry.get(beanFactory, key);
	      if (targetValues == null || targetValues.isEmpty()) {
	        continue;
	      }
	
	      for (SpringValue val : targetValues) {
			// 4. 更新内容  
	        updateSpringValue(val);
	      }
	    }
	} // end onChange

	private void updateSpringValue(SpringValue springValue) {
		try {
		   // 5.获得@Value("${jdbc.url}")注解上的内容.
		   //   调用:ConfigurableBeanFactory.resolveEmbeddedValue("${jdbc.url}")
		   //   调用这个方法的前提是,ConfigurableBeanFactory里已经是最新的配置了,估计:Apollo是先更新了配置,后再触发:ConfigChangeListener
		  Object value = resolvePropertyValue(springValue);
		  
		  // 6. 委托给:SpringValue.update方法
		  springValue.update(value);
		  logger.info("Auto update apollo changed value successfully, new value: {}, {}", value,
			  springValue);
		} catch (Throwable ex) {
		  logger.error("Auto update apollo changed value failed, {}", springValue.toString(), ex);
		}
    } // end updateSpringValue
}

//通过反射进行处理.
public void update(Object newVal) throws IllegalAccessException, InvocationTargetException {
	if (isField()) { 
      injectField(newVal);
    } else {
      injectMethod(newVal);
    }
} // end update

private void injectField(Object newVal) throws IllegalAccessException {
    // 获得Bean对象
	Object bean = beanRef.get();
    if (bean == null) {
      return;
    }
	// 设置允许访问private Field
    boolean accessible = field.isAccessible();
    field.setAccessible(true);
	// 通过反射设置内容
    field.set(bean, newVal);
    field.setAccessible(accessible);
}// end injectField