Apollo 2 如何支持 @Value 注解自动更新
前言
Apollo 在 v0.10.0 版本后,支持自动更新。v0.10.0之前的版本在配置变化后不会重新注入,需要重启才会更新。
也就是说,如果一个属性加入了 @Value 注解,并且这个配置在配置中心也存在,那么,配置中心修改属性值后,就会自动更新这个值。同时,有个开关可以控制这个功能是否关闭(默认开启)。
配置文件中写入 apollo.autoUpdateInjectedSpringProperties = false
即可关闭该功能。
如何实现?
此次提交的 PR 详情可见 https://codecov.io/gh/ctripcorp/apollo/pull/972/diff.
大致先说下实现思路:
Apollo 实现了BeanPostProcessor
接口,这个接口的作用则是每个 bean 初始化成前后做操作
。
在 postProcessBeforeInitialization
方法中,会取出这个 Bean 的所有属性和方法,并判断他们是否含有 @Value
注解从而进行处理。
具体处理逻辑,则是: 将符合条件的属性封装成一个 SpringValue
对象,放在一个Map
中。当 clien
检测到配置发生变化时,就会更新这个 Map
里面的值,从而达到自动更新的目的。
当然,这只是大概的思路,具体细节则要复杂一些。接下来我们就说说具体的实现细节。
实现细节
相关类:
-
SpringValue
@Value 注解的详细信息数据结构。 -
SpringValueRegistry
@Value 注册中心,保存了他的 key/value 机构。 -
SpringValueDefinitionProcessor
针对 Spring 3.x 版本做的特殊操作。 -
SpringValueProcessor
处理 @Value 注解的类。 -
ConfigPropertySourcesProcessor
注册 SpringValueProcessor 到容器。 -
PropertySourcesProcessor
将 Config 和自动更新监听器绑定,同时注入 Spring 环境。
逻辑步骤:
-
无论是 XML 方式,注解方式,SpringBoot 方式,都会触发注册机制,即自动注册
SpringValueProcessor
处理器到 Spring 容器(他主要是个BeanPostProcessor
)。这是 apollo 自定义的@Value
处理器。 -
不仅仅注册
SpringValueProcessor
,还注册PropertySourcesProcessor
,这是一个BeanFactoryPostProcessor
,即在 Spring bean 工厂初始化后,可以进行修改的一个类。这里的时机比SpringValueProcessor
早。 -
PropertySourcesProcessor
在具体方法中,会初始化所有的 Config(ConfigService.getConfig(namespace)
),并设置到 Spring 的环境中(存储所有的 Property,且同名状态下优先级最高,目的是让 Spring 自己注入到变量中)。同时,创建一个自动更新监听器,监听所有的 Config。 -
SpringValueProcessor
在容器初始化 Bean 的时候,会处理所有带有@Value
注解的类,并放入到SpringValueRegistry
的 Map 中。注意:SpringValueRegistry
是单例的。而 自动更新监听器 也是包含一个SpringValueRegistry
的。因此,每当一个 Config 变化的时候,都会触发 change 事件,并调用监听器的 onChange 方法,如果匹配,该方法则会更新SpringValueRegistry
内部的值——完成自动更新。 -
这里有个问题:所有的配置都放在
SpringValueRegistry
中,一个 client 会持有多个namespace
,每个namespace
可能会有重名的配置。那么会不会发生冲突呢?实际上,apollo 考虑到了这点,在设计namespace
的时候,就有一个 order 属性,用于处理这种情况,order 越小,优先级越高。当一个配置没有显时的设置namespace
时,apollo 将其归纳为优先级最高的namespace
——即 order 最小的namespace
。而实现优先级的则是Spring PropertySource
内部的排序机制,说白了就是一个 List,优先级最高的下标为0,当循环匹配的时候,优先匹配下标为0的配置。 -
在
shouldTriggerAutoUpdate
方法里,有个判断很绕:根据 key 获取 Spring 环境中的配置值,判断这个值和刚刚发生的变化值是否相等,如果相等,就更新 value,反之,跳过此次事件
。
解释一下:我们知道,@value
对应的是优先级最高的namespace
,environment
获取的也是优先级最高的 namespace 的配置。
如果一个配置更新了,但environment
优先级最高的配置却没有更新,那么@value
对应的更新事件就不应该触发。
如果一个配置更新了,environment
获取到的优先级最高的配置也更新了,那么@value
对应的更新时间就应该触发。
这里,其实就是@value
是否更新的重要判断。
总结
关于这个小功能,为什么要单独拉出来说一说呢?实际上,该功能涉及到的东西还是很多的。例如:
- 一个普通的 Java 项目如何和 Spring 框架融合 —— 注册,初始化,注入 Spring 环境等操作。
- 如何玩转 Spring 的
PropertySource
的 order 机制。 - 每一个
namespace
都有一个长轮询,发生更新后,apollo 触发监听器的更新事件,其中包括自动更新监听器
,但是,需要通过shouldTriggerAutoUpdate
的判断才能进行更新,因为 @value 可能会和多个 namespace 重名,需要通过优先级来过滤。即:如果 Spring 环境中优先级最高的 config 更新了,那么@value
对应的 field 就需要更新,反之,不能更新(namespace
不匹配)。