SpringCloud 环境 @ConfigurationProperties 无法监听到新增和删除 key 问题 #88

   // ApolloApplicationContextInitializer::initialize

   CompositePropertySource composite;
    if (configUtil.isPropertyNamesCacheEnabled()) {

     // 此处每次都会创建一个新的 CachedCompositePropertySource ，但是 name 相同
      composite = new CachedCompositePropertySource(PropertySourcesConstants.APOLLO_BOOTSTRAP_PROPERTY_SOURCE_NAME);
    } else {
      composite = new CompositePropertySource(PropertySourcesConstants.APOLLO_BOOTSTRAP_PROPERTY_SOURCE_NAME);
    }
    for (String namespace : namespaceList) {
      Config config = ConfigService.getConfig(namespace);
      composite.addPropertySource(configPropertySourceFactory.getConfigPropertySource(namespace, config));
    }

 // AbstractConfig::addChangeListener
 @Override
  public void addChangeListener(ConfigChangeListener listener, Set<String> interestedKeys, Set<String> interestedKeyPrefixes) {

    /* 此处根据 PropertySource 名称判断，由于 bootstrapApplicationContext 中已经设置过一次
     * applicationContext 创建时新 new 对象 CachedCompositePropertySource 无法设置到监听里面
     * 进而导致监听器中的保存的一直是旧的 CachedCompositePropertySource，而 applicationContext 实际使用新的
     */
    if (!m_listeners.contains(listener)) {
      m_listeners.add(listener);
      if (interestedKeys != null && !interestedKeys.isEmpty()) {
        m_interestedKeys.put(listener, Sets.newHashSet(interestedKeys));
      }
      if (interestedKeyPrefixes != null && !interestedKeyPrefixes.isEmpty()) {
        m_interestedKeyPrefixes.put(listener, Sets.newHashSet(interestedKeyPrefixes));
      }
    }
  }

public class CachedCompositePropertySource extends CompositePropertySource implements
    ConfigChangeListener {

  private volatile String[] names;

  public CachedCompositePropertySource(String name) {
    super(name);
  }

  @Override
  public String[] getPropertyNames() {
   // 无法触发监听器，缓存仍然是所有旧 key，而 SpringBoot 属性绑定会使用这个方法
    String[] propertyNames = this.names;
    if (propertyNames == null) {
      this.names = propertyNames = super.getPropertyNames();
    }
    return propertyNames;
  }

  @Override
  public void onChange(ConfigChangeEvent changeEvent) {

    // 正常情况下应该触发监听器，让 names 置空，从而触发调用时刷新
   // 此处 applicationContext 中 CachedCompositePropertySource 无法触发
    this.names = null;
  }
}