Spring Cloud Config 用于构建分布式系统的配置中心,本文关注客户端的配置高可用,避免对spring cloud config server的强依赖!
Spring cloud config
在使用spring cloud 构建分布式系统的过程中,为了完成多个服务的配置统一管理,使用了spring cloud config作为配置中心,管理所有微服务的系统配置。
在分布式系统中,配置中心是一个独立的服务部件,作用是专门为其他服务提供系统启动所需的配置信息,保证系统正确启动。
使用中带来一个问题,即配置中心的高可用。
配置中心的高可用问题
配置中心(spring cloud config server)本身可以通过部署多个节点,并且通过服务注册中心(Eureka) 向其他服务系统提供服务。但是这种高可用在我看来本身并不可靠。
- 配置中心不是业务系统,不会有其他业务系统那么高的高可用实施优先级,节点数量,主机性能,稳定性都会有所差距。
- 配置中心可能又会依赖其他系统,如git,降低了高可用性,git一旦停止服务,则配置中心直接挂掉。
- 后果严重 ,配置中心一旦全部失效,会导致所有服务都无法正常启动。
如何缓解
本文从客户端的角度出发,不是增加配置中心的高可用性,而是降低客户端对配置中心的依赖程度,从而提高整个分布式架构的健壮性。仅是缓解,不敢妄谈解决!
Spring cloud config 如何使用可参考:Spring Cloud构建微服务架构(四)分布式配置中心
简单的服务结构如下:
spring cloud config server & client服务A启动的主要步骤:
- 服务A判断Spring-cloud-starter-config是否在classpath
- 根据spring.cloud.config的配置(bootstrap.yml)请求配置中心,获取配置
- 配置中心根据application.name,profile和label访问git获取对应目录下的相应配置文件,并返回给服务A
- 服务A将加载获取到配置,并根据是否allowOverride来决定是否覆盖本地配置
- 继续启动...
本文关注的就是第4步中容易出现的问题,当配置中心/Git无法响应请求时,服务A能做什么。
更具体点
服务A在启动过程中调用了Spring cloud的启动环境配置类PropertySourceBootstrapConfiguration,该类实现了ApplicationContextInitializer接口,查看源码
// method initialize
CompositePropertySource composite = new CompositePropertySource("bootstrapProperties");
for (PropertySourceLocator locator : this.propertySourceLocators) {
PropertySource<?> source = null;
source = locator.locate(environment);
if (source == null) {
continue;
}
logger.info("Located property source: " + source);
composite.addPropertySource(source);
}
insertPropertySources(propertySources, composite);
其中的PropertySourceLocator就是spring cloud config
提供的获取访问配置中心获取配置的方法。
可以看到,获取的结果被放入了composite中,并最终和本地的其他配置项合并。
insertPropertySources(propertySources, composite);
怎么做
理清了这个启动顺序,那么我们要做的是在这一步骤之后,判断服务A是否从配置中心获取到了配置数据。
- 如果获得了配置数据,备份配置数据。
- 如果没有获得,从备份配置数据中获取替代配置中心的配置数据完成启动。
代码很简单,如下:
public class CloudConfigSupportConfiguration implements
ApplicationContextInitializer<ConfigurableApplicationContext>, Ordered {
private int order = Ordered.HIGHEST_PRECEDENCE + 11;
@Override
public void initialize(ConfigurableApplicationContext applicationContext) {
if (!isHasCloudConfigLocator(this.propertySourceLocators)) {
logger.info("未启用Config Server管理配置");
return;
}
logger.info("检查Config Service配置资源");
ConfigurableEnvironment environment = applicationContext.getEnvironment();
MutablePropertySources propertySources = environment.getPropertySources();
logger.info("加载PropertySources源:" + propertySources.size() + "个");
CloudConfigSupportProperties configSupportProperties = new CloudConfigSupportProperties();
new RelaxedDataBinder(configSupportProperties, CloudConfigSupportProperties.CONFIG_PREFIX)
.bind(new PropertySourcesPropertyValues(propertySources));
if (!configSupportProperties.isEnable()) {
logger.warn("未启用配置备份功能,可使用{}.enable打开", CloudConfigSupportProperties.CONFIG_PREFIX);
return;
}
if (isCloudConfigLoaded(propertySources)) {
PropertySource cloudConfigSource = getLoadedCloudPropertySource(propertySources);
logger.info("成功获取ConfigService配置资源");
//备份
Map<String, Object> backupPropertyMap = makeBackupPropertyMap(cloudConfigSource);
doBackup(backupPropertyMap, configSupportProperties.getFile());
} else {
logger.error("获取ConfigService配置资源失败");
Properties backupProperty = loadBackupProperty(configSupportProperties.getFile());
if (backupProperty != null) {
HashMap backupSourceMap = new HashMap<>(backupProperty);
PropertySource backupSource = new MapPropertySource("backupSource", backupSourceMap);
propertySources.addFirst(backupSource);
logger.warn("使用备份的配置启动:{}", configSupportProperties.getFile());
}
}
}
}
要注意的是,启动顺序的设置
private int order = Ordered.HIGHEST_PRECEDENCE + 11;
这是因为spring cloud使用的PropertySourceBootstrapConfiguration启动顺序为
private int order = Ordered.HIGHEST_PRECEDENCE + 10;
完成coding后,为了在spring boot(服务A)启动时能够及时调用,需要加入/resources/META-INF/spring.factories的配置
# Bootstrap components
org.springframework.cloud.bootstrap.BootstrapConfiguration=\
df.open.support.configuration.CloudConfigSupportConfiguration\
Ok,启动服务A就会发现,自定义的CloudConfigSupportConfiguration已经生效,并且就在PropertySourceBootstrapConfiguration的后面执行!
至此,客户端的配置高可用就初步完成了,当然对于备份方式,以及服务刷新时的再次备份还需要进一步的工作去实现。
网友评论