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

背景

近日业务同学反映在Apollo界面更改配置后, 服务中对应变量的值却没有改变
相关配置key定义如下:

@ApolloJsonValue("${apollo.config.map:{}}")
private Map> apolloConfigMap;

分析

问题确认

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

尝试本地复现

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

远程debug

  1. 将项目的代码clone到本地,远程debug
  2. 在apollo热更新代码处打断点,具体是: AutoUpdateConfigChangeListener#onChange方法。
public void onChange(ConfigChangeEvent changeEvent) {
  Set keys = changeEvent.changedKeys();
  if (CollectionUtils.isEmpty(keys)) {
    return;
  }
  for (String key : keys) {
    // 1. check whether the changed key is relevant
    Collection 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放一位也是有道理的,配置变更先更新配置,再执行其它监听器,因为在其它监听器中也许需要用到热更新后的值。

解决方法

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

  1. 如果需要用到动态配置,并且动态配置是加密的,就需要修改AutoUpdateConfigChangeListener逻辑,先发送事件。注意新增事件类后,需要配置jasypt.encryptor.refreshed-event-classes,其值为事件类的全限定名称。
  2. 如果需要用到动态配置,但动态配置是不需要加密的,需要修改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));
    }
  3. 不使用Apollo的热更新,属性值直接调用Apolo的Config获取,也能获取到变更后的值。伪代码如下:
Config apolloConfig = ConfigService.getConfig()
- apolloConfig.getProperty()

文章来源于互联网:Jasypt与Apollo一起使用造成Apollo热更新失效问题分析

THE END
分享
二维码