多少钱网站设计,网站建设毕业设计任务书,电子商务网站后台,html网页制作颜色代码Spring Cloud Config 规范
首先Spring Cloud 是基于 Spring 来扩展的#xff0c;Spring 本身就提供当创建一个Bean时可从Environment 中将一些属性值通过Value的形式注入到业务代码中的能力。那Spring Cloud Config 要解决的问题就是#xff1a;
如何将配置加载到 Environm…Spring Cloud Config 规范
首先Spring Cloud 是基于 Spring 来扩展的Spring 本身就提供当创建一个Bean时可从Environment 中将一些属性值通过Value的形式注入到业务代码中的能力。那Spring Cloud Config 要解决的问题就是
如何将配置加载到 Environment 。配置变更时如何控制 Bean 是否需要 create,重新触发一次 Bean 的初始化才能将 Value 注解指定的字段从 Environment 中重新注入。配置变更时如何控制新的配置会更新到 Environment 中才能保证配置变更时可注入最新的值。
要解决以上三个问题Spring Cloud Config 规范中刚好定义了核心的三个接口
PropertySourceLocator抽象出这个接口就是让用户可定制化的将一些配置加载到 Environment。这部分的配置获取遵循了 Spring Cloud Config 的理念即希望能从外部储存介质中来 loacte。RefreshScope: Spring Cloud 定义这个注解是扩展了 Spring 原有的 Scope 类型。用来标识当前这个 Bean 是一个refresh 类型的 Scope。其主要作用就是可以控制 Bean 的整个生命周期。ContextRefresher抽象出这个 Class是让用户自己按需来刷新上下文(比如当有配置刷新时希望可以刷新上下文将最新的配置更新到 Environment重新创建 Bean 时就可以从 Environment 中注入最新的配置)。
Spring Cloud Config 原理
Spring Cloud Config 的启动过程
1、如何将配置加载到EnvironmentPropertySourceLocator
在整个 Spring Boot 启动的生命周期过程中有一个阶段是 prepare environment。在这个阶段会publish 一个 ApplicationEnvironmentPreparedEvent通知所有对这个事件感兴趣的 Listener,提供对 Environment 做更多的定制化的操作。Spring Cloud 定义了一个BootstrapApplicationListener在 BootstrapApplicationListener 的处理过程中有一步非常关键的操作如下所示
private ConfigurableApplicationContext bootstrapServiceContext(ConfigurableEnvironment environment, final SpringApplication application,String configName) {//省略ClassLoader classLoader Thread.currentThread().getContextClassLoader();// Use names and ensure unique to protect against duplicatesListString names new ArrayList(SpringFactoriesLoader.loadFactoryNames(BootstrapConfiguration.class, classLoader));//省略}
这是 Spring 的工厂加载机制可通过在 META-INF/spring.factories 文件中配置一些程序中预定义的一些扩展点。比如 Spring Cloud 这里的实现可以看到 BootstrapConfiguration 不是一个具体的接口而是一个注解。通过这种方式配置的扩展点好处是不局限于某一种接口的实现而是同一类别的实现。可以查看 spring-cloud-context 包中的 spring.factories 文件关于BootstrapConfiguration的配置有一个比较核心入口的配置就是
org.springframework.cloud.bootstrap.BootstrapConfiguration\
org.springframework.cloud.bootstrap.config.PropertySourceBootstrapConfiguration
可以发现 PropertySourceBootstrapConfiguration 实现了 ApplicationContextInitializer 接口其目的就是在应用程序上下文初始化的时候做一些额外的操作。在 Bootstrap 阶段会通过 Spring Ioc 的整个生命周期来初始化所有通过key为_org.springframework.cloud.bootstrap.BootstrapConfiguration_ 在 spring.factories 中配置的 Bean。Spring Cloud Alibaba Nacos Config 的实现就是通过该key来自定义一些在Bootstrap 阶段需要初始化的一些Bean。在该模块的 spring.factories 配置文件中可以看到如下配置
org.springframework.cloud.bootstrap.BootstrapConfiguration\
org.springframework.cloud.alibaba.nacos.NacosConfigBootstrapConfiguration
在 Bootstrap 阶段初始化的过程中会获取所有 ApplicationContextInitializer 类型的 Bean并设置回SpringApplication主流程当中。如下 BootstrapApplicationListener 类中的部分代码所示 private void apply(ConfigurableApplicationContext context, SpringApplication application, ConfigurableEnvironment environment) {SuppressWarnings(rawtypes)//这里的 context 是一个 bootstrap 级别的 ApplicationContext这里已经含有了在 bootstrap阶段所有需要初始化的 Bean。//因此可以获取 ApplicationContextInitializer.class 类型的所有实例ListApplicationContextInitializer initializers getOrderedBeansOfType(context,ApplicationContextInitializer.class);//设置回 SpringApplication 主流程当中application.addInitializers(initializers .toArray(new ApplicationContextInitializer[initializers.size()]));//省略...
} 这样一来就可以通过在 SpringApplication 的主流程中来回调这些ApplicationContextInitializer 的实例做一些初始化的操作。如下 SpringApplication 类中的部分代码所示 private void prepareContext(ConfigurableApplicationContext context, ConfigurableEnvironment environment, SpringApplicationRunListeners listeners,ApplicationArguments applicationArguments, Banner printedBanner) {context.setEnvironment(environment);postProcessApplicationContext(context);//回调在BootstrapApplicationListener中设置的ApplicationContextInitializer实例applyInitializers(context);listeners.contextPrepared(context);//省略...
}protected void applyInitializers(ConfigurableApplicationContext context) {for (ApplicationContextInitializer initializer : getInitializers()) {Class? requiredType GenericTypeResolver.resolveTypeArgument(initializer.getClass(), ApplicationContextInitializer.class);Assert.isInstanceOf(requiredType, context, Unable to call initializer.);initializer.initialize(context);}
} 在 applyInitializers 方法中会触发 PropertySourceBootstrapConfiguration 中的 initialize 方法。如下所示 Override
public void initialize(ConfigurableApplicationContext applicationContext) {CompositePropertySource composite new CompositePropertySource(BOOTSTRAP_PROPERTY_SOURCE_NAME);AnnotationAwareOrderComparator.sort(this.propertySourceLocators);boolean empty true;ConfigurableEnvironment environment applicationContext.getEnvironment();for (PropertySourceLocator locator : this.propertySourceLocators) {PropertySource? source null;//回调所有实现PropertySourceLocator接口实例的locate方法source locator.locate(environment);if (source null) {continue;}composite.addPropertySource(source);empty false;}if (!empty) {//从当前Enviroment中获取 propertySourcesMutablePropertySources propertySources environment.getPropertySources();//省略...//将composite中的PropertySource添加到当前应用上下文的propertySources中insertPropertySources(propertySources, composite);//省略...} 在这个方法中会回调所有实现 PropertySourceLocator 接口实例的locate方法 locate 方法返回一个 PropertySource 的实例统一add到CompositePropertySource实例中。如果 composite 中有新加的PropertySource,最后将composite中的PropertySource添加到当前应用上下文的propertySources中。Spring Cloud Alibaba Nacos Config 在 Bootstrap 阶段通过Java配置的方式初始化了一个 NacosPropertySourceLocator 类型的Bean。从而在 locate 方法中将存放在Nacos中的配置信息读取出来将读取结果存放到 PropertySource 的实例中返回。具体如何从Nacos中读取配置信息可参考 NacosPropertySourceLocator 类的实现。
Spring Cloud Config 正是提供了PropertySourceLocator接口来提供应用外部化配置可动态加载的能力。Spring Ioc 容器在初始化 Bean 的时候如果发现 Bean 的字段上含有 Value 的注解就会从 Enviroment 中的PropertySources 来获取其值完成属性的注入。
Spring Cloud Config 外部化配置可动态刷新
感知到外部化配置的变更这部分代码的操作是需要用户来完成的。Spring Cloud Config 只提供了具备外部化配置可动态刷新的能力并不具备自动感知外部化配置发生变更的能力。比如如果你的配置是基于Mysql来实现的那么在代码里面肯定要有能力感知到配置发生变化了然后再显示的调用 ContextRefresher 的 refresh方法从而完成外部化配置的动态刷新(只会刷新使用RefreshScope注解的Bean)。
例如在 Spring Cloud Alibaba Nacos Config 的实现过程中Nacos 提供了对dataid 变更的Listener 回调。在对每个dataid 注册好了相应的Listener之后如果Nacos内部通过长轮询的方式感知到数据的变更就会回调相应的Listener,在 Listener 的实现过程中就是通过调用 ContextRefresher 的 refresh方法完成配置的动态刷新。具体可参考 NacosContextRefresher 类的实现。
Sring Cloud Config的动态配置刷新原理图如下所示 ContextRefresher的refresh的方法主要做了两件事
触发PropertySourceLocator的locator方法需要加载最新的值并替换 Environment 中旧值Bean中的引用配置值需要重新注入一遍。重新注入的流程是在Bean初始化时做的操作那也就是需要将refresh scope中的Bean 缓存失效当再次从refresh scope中获取这个Bean时发现取不到就会重新触发一次Bean的初始化过程。
这两个操作所对应的代码如下所示 public synchronized Set refresh() { MapString, Object before extract(this.context.getEnvironment().getPropertySources());//1、加载最新的值并替换Envrioment中旧值addConfigFilesToEnvironment();SetString keys changes(before,extract(this.context.getEnvironment().getPropertySources())).keySet();this.context.publishEvent(new EnvironmentChangeEvent(context, keys));//2、将refresh scope中的Bean 缓存失效: 清空this.scope.refreshAll();return keys;
} addConfigFilesToEnvironment 方法中发生替换的代码如下所示 ConfigurableApplicationContext addConfigFilesToEnvironment() { ConfigurableApplicationContext capture null;try {//省略...//1、这里会重新触发PropertySourceLoactor的locate的方法,获取最新的外部化配置capture (SpringApplicationBuilder)builder.run();MutablePropertySources target this.context.getEnvironment().getPropertySources();String targetName null;for (PropertySource? source : environment.getPropertySources()) {String name source.getName();//省略..//只有不是标准的 Source 才可替换if (!this.standardSources.contains(name)) {if (target.contains(name)) {//开始用新的PropertySource替换旧值target.replace(name, source);}//}}}//return capture;
} this.scope.refreshAll() 清空缓存的操作代码如下所示
Overridepublic void destroy() {ListThrowable errors new ArrayListThrowable();//清空Refresh Scope 中的缓存CollectionBeanLifecycleWrapper wrappers this.cache.clear();//省略...}为了验证每次配置刷新时Bean 是新创建的特意写了一个Demo 验证了下如下所示
Acm Properties: beijing-region
//刷新前
Object Instance is :com.alibaba.demo.normal.ConfigProperties1be9634
2018-11-01 19:16:32.535 INFO 27254 --- [gPullingdefault] startup date [Thu Nov 01 19:16:32 CST 2018]; root of context hierarchy
Acm Properties: qingdao-region
//刷新后
Object Instance is :com.alibaba.demo.normal.ConfigProperties2c6965e0
Spring Cloud Config 扩展Scope的核心类:RefreshScope
可以看到上面的代码中有 this.scope.refreshAll()其中的scope就是RefreshScope。是用来存放scope类型为refresh类型的Bean即使用RefreshScope注解标识的Bean也就是说当一个Bean既不是singleton也不是prototype时就会从自定义的Scope中去获取(Spring 允许自定义Scope)然后调用Scope的get方法来获取一个实例Spring Cloud 正是扩展了Scope从而控制了整个 Bean 的生命周期。当配置需要动态刷新的时候 调用this.scope.refreshAll()这个方法就会将整个RefreshScope的缓存清空完成配置可动态刷新的可能。
更多关于Scope的分析请参考 这里
后续
关于ContextRefresh 和 RefreshScope的初始化配置是在RefreshAutoConfiguration类中完成的。而RefreshAutoConfiguration类初始化的入口是在spring-cloud-context中的META-INF/spring.factories中配置的。从而完成整个和动态刷新相关的Bean的初始化操作。 原文链接 本文为云栖社区原创内容未经允许不得转载。
