Spring Cloud 覆写远端的配置属性

覆写远端的配置属性

应用的配置源一般都是远端的Config Server服务器，默认状况下，本地的配置优先级低于远端配置仓库。若是想实现本地应用的系统变量和config文件覆盖远端仓库中的属性值，能够经过以下设置：

spring:
 cloud:
 config:
 allowOverride: true
 overrideNone: true
 overrideSystemProperties: false
复制代码

• overrideNone：当allowOverride为true时，overrideNone设置为true，外部的配置优先级更低，并且不能覆盖任何存在的属性源。默认为false
• allowOverride：标识overrideSystemProperties属性是否启用。默认为true，设置为false意为禁止用户的设置
• overrideSystemProperties：用来标识外部配置是否可以覆盖系统属性，默认为true

客户端经过如上配置，能够实现本地配置优先级更高，且不能被覆盖。因为咱们基于的Spring Cloud当前版本是Edgware.RELEASE，上面的设置并不能起做用，而是使用了PropertySourceBootstrapProperties中的默认值。具体状况见issue：https://github.com/spring-cloud/spring-cloud-commons/pull/250，咱们在下面分析时会讲到具体的bug源。

源码分析

ConfigServicePropertySourceLocator

覆写远端的配置属性归根结底与客户端的启动时获取配置有关，在获取到配置以后如何处理？咱们看一下spring cloud config中的资源获取类ConfigServicePropertySourceLocator的类图。

ConfigServicePropertySourceLocator类图

ConfigServicePropertySourceLocator实质是一个属性资源定位器，其主要方法是locate(Environment environment)。首先用当前运行应用的环境的application、profile和label替换configClientProperties中的占位符并初始化RestTemplate，而后遍历labels数组直到获取到有效的配置信息，最后还会根据是否快速失败进行重试。主要流程以下：

locate处理流程

locate(Environment environment)调用getRemoteEnvironment(restTemplate, properties, label, state)方法经过http的方式获取远程服务器上的配置数据。实现也很简单，显示替换请求路径path中占位符，而后进行头部headers组装，组装好了就能够发送请求，最后返回结果。 在上面的实现中，咱们看到获取到的配置信息存放在CompositePropertySource，那是如何使用它的呢？这边补充另外一个重要的类是PropertySourceBootstrapConfiguration，它实现了ApplicationContextInitializer接口，该接口会在应用上下文刷新以前refresh()被回调，从而执行初始化操做，应用启动后的调用栈以下：

SpringApplicationBuilder.run() -> SpringApplication.run() -> SpringApplication.createAndRefreshContext() -> SpringApplication.applyInitializers() -> PropertySourceBootstrapConfiguration.initialize()
复制代码

PropertySourceBootstrapConfiguration

而上述ConfigServicePropertySourceLocator的locate方法会在initialize中被调用，从而保证上下文在刷新以前可以拿到必要的配置信息。具体看一下initialize方法：

public class PropertySourceBootstrapConfiguration implements ApplicationContextInitializer<ConfigurableApplicationContext>, Ordered {

	private int order = Ordered.HIGHEST_PRECEDENCE + 10;

	@Autowired(required = false)
	private List<PropertySourceLocator> propertySourceLocators = new ArrayList<>();

	@Override
	public void initialize(ConfigurableApplicationContext applicationContext) {
		CompositePropertySource composite = new CompositePropertySource(
				BOOTSTRAP_PROPERTY_SOURCE_NAME);
		//对propertySourceLocators数组进行排序，根据默认的AnnotationAwareOrderComparator
		AnnotationAwareOrderComparator.sort(this.propertySourceLocators);
		boolean empty = true;
		//获取运行的环境上下文
		ConfigurableEnvironment environment = applicationContext.getEnvironment();
		for (PropertySourceLocator locator : this.propertySourceLocators) {
			//遍历this.propertySourceLocators
			PropertySource<?> source = null;
			source = locator.locate(environment);
			if (source == null) {
				continue;
			}
			logger.info("Located property source: " + source);
			//将source添加到PropertySource的链表中
			composite.addPropertySource(source);
			empty = false;
		}
		//只有source不为空的状况，才会设置到environment中
		if (!empty) {
			//返回Environment的可变形式，可进行的操做如addFirst、addLast
			MutablePropertySources propertySources = environment.getPropertySources();
			String logConfig = environment.resolvePlaceholders("${logging.config:}");
			LogFile logFile = LogFile.get(environment);
			if (propertySources.contains(BOOTSTRAP_PROPERTY_SOURCE_NAME)) {
				//移除bootstrapProperties
				propertySources.remove(BOOTSTRAP_PROPERTY_SOURCE_NAME);
			}
			//根据config server覆写的规则，设置propertySources
			insertPropertySources(propertySources, composite);
			reinitializeLoggingSystem(environment, logConfig, logFile);
			setLogLevels(environment);
			//处理多个active profiles的配置信息
			handleIncludedProfiles(environment);
		}
	}
	//...
}
复制代码

下面咱们看一下，在initialize方法中进行了哪些操做。

• 根据默认的 AnnotationAwareOrderComparator 排序规则对propertySourceLocators数组进行排序
• 获取运行的环境上下文ConfigurableEnvironment
• 遍历propertySourceLocators时
  • 调用 locate 方法，传入获取的上下文environment
  • 将source添加到PropertySource的链表中
  • 设置source是否为空的标识标量empty
• source不为空的状况，才会设置到environment中
  • 返回Environment的可变形式，可进行的操做如addFirst、addLast
  • 移除propertySources中的bootstrapProperties
  • 根据config server覆写的规则，设置propertySources
  • 处理多个active profiles的配置信息

初始化方法initialize处理时，先将全部PropertySourceLocator类型的对象的locate方法遍历，而后将各类方式获得的属性值放到CompositePropertySource中，最后调用insertPropertySources(propertySources, composite)方法设置到Environment中。Spring Cloud Context中提供了覆写远端属性的PropertySourceBootstrapProperties，利用该配置类进行判断属性源的优先级。

private void insertPropertySources(MutablePropertySources propertySources, CompositePropertySource composite) {
		MutablePropertySources incoming = new MutablePropertySources();
		incoming.addFirst(composite);
		PropertySourceBootstrapProperties remoteProperties = new PropertySourceBootstrapProperties();
		new RelaxedDataBinder(remoteProperties, "spring.cloud.config")
				.bind(new PropertySourcesPropertyValues(incoming));
		//若是不容许本地覆写
		if (!remoteProperties.isAllowOverride() || (!remoteProperties.isOverrideNone()
				&& remoteProperties.isOverrideSystemProperties())) {
			propertySources.addFirst(composite);
			return;
		}
		//overrideNone为true，外部配置优先级最低
		if (remoteProperties.isOverrideNone()) {
			propertySources.addLast(composite);
			return;
		}
		if (propertySources
				.contains(StandardEnvironment.SYSTEM_ENVIRONMENT_PROPERTY_SOURCE_NAME)) {
			//根据overrideSystemProperties，设置外部配置的优先级
			if (!remoteProperties.isOverrideSystemProperties()) {
				propertySources.addAfter(
						StandardEnvironment.SYSTEM_ENVIRONMENT_PROPERTY_SOURCE_NAME,
						composite);
			}
			else {
				propertySources.addBefore(
						StandardEnvironment.SYSTEM_ENVIRONMENT_PROPERTY_SOURCE_NAME,
						composite);
			}
		}
		else {
			propertySources.addLast(composite);
		}
	}
复制代码

上述实现主要是根据PropertySourceBootstrapProperties中的属性，调整多个配置源的优先级。从其实现能够看到 PropertySourceBootstrapProperties 对象的是被直接初始化，使用的是默认的属性值而并未注入咱们在配置文件中设置的。

修复后的实现：

@Autowired(required = false)
private PropertySourceBootstrapProperties remotePropertiesForOverriding;
private void insertPropertySources(MutablePropertySources propertySources, CompositePropertySource composite) {
    MutablePropertySources incoming = new MutablePropertySources();
  	incoming.addFirst(composite);
 	PropertySourceBootstrapProperties remoteProperties = remotePropertiesForOverriding == null ? new PropertySourceBootstrapProperties() : remotePropertiesForOverriding;
        ...
    
}
复制代码

订阅最新文章，欢迎关注个人公众号

参考

Spring Cloud Edgware.RELEASE