文章目录
- bootstrap配置文件的读取
- 什么是配置中心?以及如何实现一个配置中心?
- SpringBoot如何实现配置的管控?
- SpringCloud项目是如何对bootstrap配置文件进行加载的?
- Nacos是如何实现配置文件的读取加载的?
- 开发配置中心前必须了解的前置知识
- 配置中心Server和Client端代码的编写
- 配置中心Core核心功能代码的编写
- 配置中心源码优化---本地缓存与读写锁
网关项目源码
RPC项目源码
配置中心项目源码
bootstrap配置文件的读取
我们首先来了解一下springboot是如何做配置管理的。
了解了springboot对配置文件的管理,我们就能知道为什么springcloud类型的项目要使用bootstrap配置文件了。
关于SpringBoot是如何加载application和bootstrap配置文件的底层原理这里就不再次赘述了,大家可以移步到知识星球内部的如下位置进行学习。
简单回忆一下,既然和配置文件相关,那么我们找到spring的run方法中的如下这行代码然后往下分析即可。
ConfigurableEnvironment environment = this.prepareEnvironment(listeners, bootstrapContext, applicationArguments);
因为通过上面的学习我们知道Environment中存储了我们项目的所有配置信息。
这里我们着重分析一下这一行代码中都做了多少事情。
private ConfigurableEnvironment prepareEnvironment(SpringApplicationRunListeners listeners, DefaultBootstrapContext bootstrapContext, ApplicationArguments applicationArguments) {ConfigurableEnvironment environment = this.getOrCreateEnvironment();this.configureEnvironment(environment, applicationArguments.getSourceArgs());ConfigurationPropertySources.attach(environment);listeners.environmentPrepared(bootstrapContext, environment);DefaultPropertiesPropertySource.moveToEnd(environment);Assert.state(!environment.containsProperty("spring.main.environment-prefix"), "Environment prefix cannot be set via properties.");this.bindToSpringApplication(environment);if (!this.isCustomEnvironment) {EnvironmentConverter environmentConverter = new EnvironmentConverter(this.getClassLoader());environment = environmentConverter.convertEnvironmentIfNecessary(environment, this.deduceEnvironmentClass());}ConfigurationPropertySources.attach(environment);return environment;
}
首先是基于当前环境,创建一个环境对象。
这里由于我们的项目是Web项目,所以创建的是:StandardServletEnvironment
并且这里会层层的通过extends的继承关系,不断的初始化父类。
最终,又会回到子类的实现。
通过我们前面的了解,我们知道,其实这些代码的作用就是往容器末尾不断的添加配置文件的信息。
不过上面的创建的是系统的环境,而我们自己编写的配置文件的信息的加载,并不是在这里完成的。
我们最终读取配置文件的代码,是通过监听器的方式来完成的。
listeners.environmentPrepared(bootstrapContext, environment);
而事件监听是spring提供的一个非常重要的扩展机制,很多功能我们都可以基于监听器这种方式来实现。
我们只需要负责发布事件,对应的事件监听器就执行相应的代码来处理这个事件。
可以发现,在我们的环境创建好之后,然后就会发布一个环境预备的事件。那么此时就等待对应的监听器进行处理即可。
public void environmentPrepared(ConfigurableBootstrapContext bootstrapContext, ConfigurableEnvironment environment) {this.initialMulticaster.multicastEvent(new ApplicationEnvironmentPreparedEvent(bootstrapContext, this.application, this.args, environment));
}
事件发布之后,通过层层的下叠,最终,spring通过拿到所有注册的监听器的方式,让这些监听器判断当前事件是否是由自己处理的,如果是,就处理当前事件即可。
这里我们可以知道,其实我们发布的就是一个环境预备完成的事件。
按图索骥即可。
继续往下找,就会发现,通过迭代器的方式,会通过这些后置处理器对我们的配置文件信息进行处理。
再早期的版本中,用的是ConfigFile进行配置文件处理。
只不过版本高了就废弃了,而是用其他几个。
不过大致的意思也差不多。
因此,到此为止,其实我们大概就知道了,当项目流程到达这一步的时候,其实Spring做的事情就是通过IO流的方式去读取所有的配置文件信息,并且对他们进行解析。
这里我们跳到看ConfigDataEnvironment即可
因此,通过上面我们可以看到,只要我们再规定的位置编写配置文件,spring就可以帮助我们去加载这些配置文件。
并且,我们也可以通过实现自己的监听器的方式,再触发对应的环境准备完毕事件之后,使用我们的监听器去处理我们的配置文件。
这里,我通过实现一下按照上面的方法,实现监听器的方式,来加载配置文件信息。
特别注意, 在 Spring Boot 中,ApplicationEnvironmentPreparedEvent事件发生在 ApplicationContext 创建之前,这意味着使用 @Component 或 @Configuration 注解的方式无法确保监听器被及时注册。
相反,我需要在应用启动时手动注册该监听器。或者使用spring.factories的方式来完成自动装配。
# Application Listeners
org.springframework.context.ApplicationListener=\
blossom.project.config.core.listener.BootstrapApplicationListener
package blossom.project.config.core.listener;import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.context.event.ApplicationEnvironmentPreparedEvent;
import org.springframework.boot.env.OriginTrackedMapPropertySource;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.MutablePropertySources;
import org.springframework.stereotype.Component;import java.io.InputStream;
import java.util.Map;
import java.util.Objects;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;/*** @author: ZhangBlossom* @date: 2023/12/26 22:33* @contact: QQ:4602197553* @contact: WX:qczjhczs0114* @blog: https://blog.csdn.net/Zhangsama1* @github: https://github.com/ZhangBlossom* BootstrapListener类* 用于在项目启动的时候通过环境准备事件完成对bootstrap配置文件的读取加载* 特别注意* 在 Spring Boot 中,ApplicationEnvironmentPreparedEvent* 事件发生在 ApplicationContext 创建之前,* 这意味着使用 @Component 或 @Configuration 注解的方式无法确保监听器被及时注册。* 相反,我需要在应用启动时手动注册该监听器。*/
//@Component
//@Configuration
//@AutoConfiguration
public class BootstrapListenerimplements ApplicationListener<ApplicationEnvironmentPreparedEvent> {static {System.out.println("成功被加载...");}@Overridepublic void onApplicationEvent(ApplicationEnvironmentPreparedEvent event) {MutablePropertySources propertySources = event.getEnvironment().getPropertySources();Properties properties = new Properties();try {InputStream inputStream = BootstrapListener.class.getClassLoader().getResourceAsStream("bootstrap" +".properties");properties.load(inputStream);ConcurrentHashMap<Object,Object> cache = new ConcurrentHashMap<>();for (Map.Entry<Object, Object> entry : properties.entrySet()) {cache.put(entry.getKey(),entry.getValue());}propertySources.addLast(new OriginTrackedMapPropertySource("bootstrap.properties",properties));}catch (Exception e){e.printStackTrace();}}
}
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
public class ConfigApplication {public static void main(String[] args) {SpringApplication app = new SpringApplication(ConfigApplication.class);app.addListeners(new BootstrapListener());ConfigurableApplicationContext context = app.run(args);BootstrapListener bean = context.getBean(BootstrapListener.class);System.out.println(bean);ConfigurableEnvironment environment = context.getEnvironment();System.out.println(environment);}
}
运行代码之后发现,成功了。
当然,我还发现了另一种解决方法,就是使用@PropertySource注解。
但是使用这个注解的一个问题在于他只能解析比较常规的配置文件。对于txt这种应该是解析不了。
而且很明显,我们不应该再代码中硬编码。所以我个人比较倾向于使用监听器的方式去解析配置文件。
@Configuration
@PropertySource("classpath:bootstrap.yml")
public class PropertySourceConfig {
}
因此,我们的第一个问题,如何处理bootstrap类型的文件的问题,就已经解决了。
接下来我们可以研究一下,Nacos是如何实现配置文件的加载的,这也对我们上面分析的逻辑有确定作用。