Apollo配置中心 原理分析
- 关键字 ：Apollo原理、Apollo动态刷新机制
什么是Apollo？
- Apollo（阿波罗）是携程框架部门研发的开源配置管理中心，能够集中化管理应用不同环境、不同集群的配置，配置修改后能够实时推送到应用端，并且具备规范的权限、流程治理等特性。
Apollo得原理
-
说起Apollo得原理，不得不引入官方（宋大佬）提供得一张Apollo得设计架构图：
Apollo配置中心架构图
从下往上看依次是：
① ConfigService：配置服务端，供apollo-client端调用- 提供配置获取接口：例如：ConfigService.getConfig()
- 提供配置推送接口（ 实际是基于客户端得长轮询，来实现类似配置推送功能 ）
② AdminService：配置Portal，可视化配置得后端服务
- 提供配置管理接口
- 提供配置修改发布接口
③ Eureka：实现服务注册与发现（为什么选择Eureka？答案）
- ConfigService/AdminService 会向其注册实例
- 与ConfigService部署在一起
④ Client：客户端依赖，使用方以jar包依赖得方式与服务端交互
- 与服务端交互，定时刷新配置
- 长轮询实时获取配置
- 实现客户端动态刷新功能
⑤ MetaServer：元数据服务集群，类似于一个 Eureka得通用代理（屏蔽不同语言得差异）
- 供Portal与Client调用
⑥ SLB：负载均衡
- 由于元数据服务是集群，前面需要提供一层负载均衡策略，然后获取到Eureka注册中心得服务列表，再由调用端发起服务请求
配置发布后的实时推送设计：
配置发布后的实时推送
大致过程：
① 用户在Portal操作配置发布
② Portal调用Admin Service的接口操作发布
③ Admin Service发布配置后，发送ReleaseMessage给各个Config Service
④ Config Service收到ReleaseMessage后，通知对应的客户端
发送ReleaseMessage的实现方式
Config Service通知客户端的实现方式
客户端设计
客户端设计
实现原理：
① 客户端和服务端保持了一个长连接，从而能第一时间获得配置更新的推送。（通过Http Long Polling实现）
② 客户端还会定时从Apollo配置中心服务端拉取应用的最新配置。
- 为了防止推送机制失效导致配置不更新
- 客户端定时拉取会上报本地版本，所以一般情况下，对于定时拉取的操作，服务端都会返回304 - Not Modified
- 默认为每5分钟拉取一次，客户端也可以通过在运行时指定系统属性
apollo.refreshInterval来覆盖，单位为分钟。 - 客户端从Apollo配置中心服务端获取到应用的最新配置后，会保存在内存中
- 客户端会把从服务端获取到的配置在本地文件系统缓存一份（出现网络故障时，依然可以从本地文件恢复配置）
应用程序可以从Apollo客户端获取最新的配置、订阅配置更新通知
和Spring集成的原理
应用属性动态刷新原理与示例
-
常用得动态刷新大致分为两种情况：
① 第一种：
@Value("${test.refresh}")
private String refresh;
此种引入apollo-client客户端之后，启动类加上@EnableApolloConfig，如果有涉及到属性发布，即可刷新
-
原理：就是com.ctrip.framework.apollo.spring.property.SpringValue中会存一个弱引用bean，然后收到刷新事件时，直接反射调用对应的bean设置值。逻辑在com.ctrip.framework.apollo.spring.config.PropertySourcesProcessor（此处就不一步步源码分析了，请读者参考这几个类自己撸一遍源码）
② 第二种：
@Data
@ConfigurationProperties(prefix = "test")
public class DaaSProperties {
private boolean refresh;
}
以@ConfigurationProperties得形式得属性，需要额外添加监听器Bean，方法上加上注解@ApolloConfigChangeListener。例如：
@Configuration
@Slf4j
public static class ConfigChangeListener implements ApplicationEventPublisherAware {
private static ApplicationEventPublisher applicationEventPublisher;
@ApolloConfigChangeListener(value = "O2O.test.daas")
private void onChanged(ConfigChangeEvent configChangeEvent){
Set<String> strings = configChangeEvent.changedKeys();
strings.forEach( s ->{
ConfigChange change = configChangeEvent.getChange(s);
change.getOldValue();
log.info("【配置变更】Key：{}，OldValue:{},NewValue:{}",change.getPropertyName(),change.getOldValue(),change.getNewValue());
});
applicationEventPublisher.publishEvent(new EnvironmentChangeEvent(strings));// 刷新ConfigurationProperties Bean
}
@Override
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
ConfigChangeListener.applicationEventPublisher = applicationEventPublisher;
}
}
原理：核心在于发布EnvironmentChangeEvent事件，触发ConfigurationPropertiesRebinder监听器，重新刷新对应的bean（请读者自己看一下这几个类得实现就会一目了然了）@Value 与 @ConfigurationProperties的动态刷新处理类都是通过DefaultApolloConfigRegistrarHelper注册的。
-
本文大部分原理性得东西都是参考官网来的，有些表达不明显得地方作者只是稍加改动，作者只是梳理了一下，便于大家抓重点（因为官网文档太多了，文档很全👍）
-
其中示例代码以及涉及到动态刷新得类是作者自己总结得，所以如果你不是很了解动态刷新的原理最好还是看一下作者提供得参考类，找一下源码得位置.
- ☛ 文章要是勘误或者知识点说的不正确，欢迎评论，毕竟这也是作者通过阅读源码获得的知识，难免会有疏忽！
- ☛ 要是感觉文章对你有所帮助，不妨点个关注，或者移驾看一下作者的其他文集，也都是干活多多哦，文章也在全力更新中。
- ☛ 著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处！
