Jasypt与Apollo一起使用造成Apollo热更新失效问题分析

背景

近日业务同学反映在Apollo界面更改配置后, 服务中对应变量的值却没有改变

相关配置key定义如下:

@ApolloJsonValue("${apollo.config.map:{}}")

private Map<String, List<String>> apolloConfigMap;

分析

问题确认

通过远程debug服务发现,更改apollo配置后，服务中变量的值确实没有改变。重启也不行。

尝试本地复现

在本地编写demo,按照如上变量配置方式配置, 多次修改apollo配置后，变量的值都能即时热更新, 本地复现失败

远程debug

将项目的代码clone到本地,远程debug
在apollo热更新代码处打断点，具体是: AutoUpdateConfigChangeListener#onChange方法。

public void onChange(ConfigChangeEvent changeEvent) {

  Set<String> keys = changeEvent.changedKeys();

  if (CollectionUtils.isEmpty(keys)) {

    return;

  }

  for (String key : keys) {

    // 1. check whether the changed key is relevant

    Collection<SpringValue> targetValues = springValueRegistry.get(beanFactory, key);

    if (targetValues == null || targetValues.isEmpty()) {

      continue;

    }

    // 2. check whether the value is really changed or not (since spring property sources have hierarchies)

    if (!shouldTriggerAutoUpdate(changeEvent, key)) {

      continue;

    }

    // 3. update the value

    for (SpringValue val : targetValues) {

      updateSpringValue(val);

    }

  }

}

这个方法比较简单，循环变更的key, 第一步校验变更的key确实是bean中的属性,第二步校验确实需要热更新bean中属性值，第三步是真正的热更新。

3. 通过调试发现，在第二步时，shouldTriggerAutoUpdate方法返回了false,导致不会进行热更新。

4. 我们来看下shouldTriggerAutoUpdate方法

private boolean shouldTriggerAutoUpdate(ConfigChangeEvent changeEvent, String changedKey) {

  ConfigChange configChange = changeEvent.getChange(changedKey);

  if (configChange.getChangeType() == PropertyChangeType.DELETED) {

    return true;

  }

  return Objects.equals(environment.getProperty(changedKey), configChange.getNewValue());

}

逻辑比较简单，返回false的是最后一句, environment中获取到的属性值与apollo中配置的新值不一样。

5. 为什么会不一样？

经过调试发现 key:apollo.config.map的值最终是从com.ulisesbocchio.jasyptspringboot.caching.CachingDelegateEncryptablePropertySource中获取，而此类中有一个cache, apollo配置变更时，此cache中存的仍是旧配置。此类是jasypt相关包中的类，此包是与加解密相关的。

关键代码如下:

public Object getProperty(String name) {

    // Can be called recursively, so, we cannot use computeIfAbsent.

    if (cache.containsKey(name)) {

        return cache.get(name);

    }

    synchronized (name.intern()) {

        if (!cache.containsKey(name)) {

            Object resolved = getProperty(resolver, filter, delegate, name);

            if (resolved != null) {

                cache.put(name, resolved);

            }

        }

        return cache.get(name);

    }

}

结论

因为Jasypt会封装Apollo的PropertySource类，缓存属性值，导致配置不能热更新

延伸思考

1. 为什么apollo的配置会从jasypt类中获取呢?

我们来看下com.ulisesbocchio.jasyptspringboot.EncryptablePropertySourceConverter这个类，这是一个property converter。它的作用即是封装服务中各种的PropertySource, 当服务查询配置的值时，如果配置需要解密的话，可以实现解密。而Apollo也会创建一个PropertySource对象, 也会被jasypt包装,导致配置变更时cache无法更新。

2. 能不能apollo配置变更时更新cache或使cache失效

CachingDelegateEncryptablePropertySource类确实有一个refresh方法，可以清空缓存，下次再查询属性值时，会从真正的PropertySource中获取。而refresh方法是在com.ulisesbocchio.jasyptspringboot.caching.RefreshScopeRefreshedEventListener#onApplicationEvent方法中被调用。可以看出，如果apollo配置变更时发送事件，jasypt的onApplicationEvent应该可以被触发，并清空cache。

经过验证确实可以通过编写一个Apollo配置变更监听器，在监听器中发送ApplicationEvent事件，达到清空Cache的目的。但是经过验证，自己定义的监听器，在AutoUpdateConfigChangeListener#onChange之后执行,还是无法热更新。

Apollo将AutoUpdateConfigChangeListener监听器是放在监听器集合中的第一位的，第一个执行。所以必要要更改的话，需要更改AutoUpdateConfigChangeListener的逻辑，首先发送事件，然后再执行onChange方法中的第二步。但Apollo将AutoUpdateConfigChangeListener放一位也是有道理的，配置变更先更新配置，再执行其它监听器，因为在其它监听器中也许需要用到热更新后的值。

解决方法

解决方法有三种，需要根据使用的场景不同选择不同的方法

如果需要用到动态配置，并且动态配置是加密的，就需要修改AutoUpdateConfigChangeListener逻辑，先发送事件。注意新增事件类后，需要配置jasypt.encryptor.refreshed-event-classes,其值为事件类的全限定名称。
如果需要用到动态配置，但动态配置是不需要加密的，需要修改EncryptablePropertySourceConverter类，使其不包装Apollo相关的PropertySource类。

public void convertPropertySources(MutablePropertySources propSources) {

propSources.stream()

.filter(ps -> !(ps instanceof EncryptablePropertySource))

.filter(ps -> !(ps instanceof CompositePropertySource && ps.getName().startsWith("Apollo")))

.map(this::makeEncryptable)

.collect(toList())

.forEach(ps -> propSources.replace(ps.getName(), ps));

}
不使用Apollo的热更新，属性值直接调用Apolo的Config获取，也能获取到变更后的值。伪代码如下:

Config apolloConfig = ConfigService.getConfig(<namespace>)

- apolloConfig.getProperty()

巴特西