Springboot 加载配置文件源码分析

本文的分析是基于springboot 2.2.0.RELEASE。

本篇文章的相关源码位置:https://github.com/wbo112/blogdemo/tree/main/springbootdemo/springboot-profiles

springboot加载配置文件如application.yml是通过

org.springframework.boot.context.config.ConfigFileApplicationListener

这个类来完成的。这个类的加载也是通过spring.factories文件中来加载的。

ConfigFileApplicationListener

这个类同时实现了EnvironmentPostProcessor、ApplicationListener这两个接口。

EnvironmentPostProcessor接口需要实现的postProcessEnvironment方法，这个方法主要就是用来对Environment来进行增强处理的。而Environment主要是用来表示当前应用程序运行环境的接口。在我们这里来说读取的配置文件最终也会放到这里面来。

简单的调用关系就是下面的图来，具体是怎么调到onApplicationEvent的，比较简单，就不和大家一起看了。直接看本次的重点吧。

下面的方法都是ConfigFileApplicationListener这个类中

在addPropertySources中首先会添加一个用来处理生成随机数的RandomValuePropertySource，然后就会通过内部类Loader来加载配置文件。所以我们本次的主要是看Loader类的load方法的执行流程

下面我们来具体看看load方法的执行流程

void load() {//配置文件的加载就是通过这里来完成的。//DEFAULT_PROPERTIES = "defaultProperties";//LOAD_FILTERED_PROPERTY是一个set<String>,里面有两个元素{"spring.profiles.active","spring.profiles.include"}FilteredPropertySource.apply(this.environment, DEFAULT_PROPERTIES, LOAD_FILTERED_PROPERTY,//下面这里是一个lambda表达式，这里暂时省略，后面具体调用到这里我们再具体看。(defaultProperties) -> {......});}

上面的会调用到FilteredPropertySource的静态方法，这个也比较简单，就几行代码。最终又会调用到上面我们的省略的lambda表达式

static void apply(ConfigurableEnvironment environment, String propertySourceName, Set<String> filteredProperties,Consumer<PropertySource<?>> operation) {//这个是获取到当前程序的运行时环境。主要就是当前系统的环境变量、当前程序的环境变量等等，下面放个图一起看看MutablePropertySources propertySources = environment.getPropertySources();//这里是从运行时环境中查找key=defaultProperties的属性值，一般情况下，我们没有配置这个属性，获取到的original就是null,就会走到下面的if分支中，回到我们的lambda表达式中，我们就看这个分支吧PropertySource<?> original = propertySources.get(propertySourceName);if (original == null) {operation.accept(null);return;}propertySources.replace(propertySourceName, new FilteredPropertySource(original, filteredProperties));try {operation.accept(original);}finally {propertySources.replace(propertySourceName, original);}}

我们看看上面的MutablePropertySources propertySources = environment.getPropertySources();里面的内容

可以看到它里面有个propertySourceList，里面有6个对象，里面具体内容不打开看了。我们最终读取的配置文件也会添加到这个列表里面去

我们再回到上面的代码，看看lambda表达式中的调用吧

//这个就是上面load方法中我们之前省略掉的lambda表达式了//这里的入参defaultProperties是null(defaultProperties) -> {//这里定义一个profiles,用来存放我们需要加载的profile的名字。this.profiles = new LinkedList<>();this.processedProfiles = new LinkedList<>();this.activatedProfiles = false;this.loaded = new LinkedHashMap<>();//这个方法首先会在profiles中添加一个null的空对象。代表一个全局的profile,这个它一定会加载。//后面会继续从environment中查找属性为"spring.profiles.active","spring.profiles.include"的值通过属性绑定的形式转化成profile,也添加到profiles中来，我们这里没有定义这两个属性，所以也就不会添加了//继续判断profiles的size,如果只有一个null的话，会在里面添加一个名为default的profile,作为默认的profileinitializeProfiles();//到这里我们的profiles中已经有两个对象了,一个全局的null,一个默认的default。//如果我们没有定义自己的profile，那就会使用保留默认的；//如果我们定义了自己的profile，就会删除掉默认的名为default的profilewhile (!this.profiles.isEmpty()) {Profile profile = this.profiles.poll();//首先这里的profile的是null,不会进入下面的if分支if (isDefaultProfile(profile)) {//这里会判断如果不是默认的profile，就会加入到environment激活的Profile列表中addProfileToEnvironment(profile.getName());}//在这里就会去加载配置文件。//这里有3个参数//1. 我们本次的profile//2. 是个lambda表达式，主要是对要加载的配置文件进行过滤。如果不符合需要，就不会加载//3. 也是个lambda表达式，主要是是解析后的文档进行一个处理(加入到临时列表中)//这个方法比较重要。我们进这个方法去看看load(profile, this::getPositiveProfileFilter,addToLoaded(MutablePropertySources::addLast, false));this.processedProfiles.add(profile);}load(null, this::getNegativeProfileFilter, addToLoaded(MutablePropertySources::addFirst, true));addLoadedPropertySources();applyActiveProfiles(defaultProperties);});

//这个方法就是从指定的位置去查找配置文件进行加载private void load(Profile profile, DocumentFilterFactory filterFactory, DocumentConsumer consumer) {//getSearchLocations()获取的要查找配置文件的目录位置//默认的会从下面4个位置去查找file:./config/, file:./, classpath:/config/, classpath:/getSearchLocations().forEach((location) -> {boolean isFolder = location.endsWith("/");//由于我们上面的查找路径都是/结束的，所以查找的是目录，这里会返回需要查找的文件名applicationSet<String> names = isFolder ? getSearchNames() : NO_SEARCH_NAMES;//下面的方法就是从指定位置，使用profile，根据指定的名字去查找配置文件进行加载names.forEach((name) -> load(location, name, profile, filterFactory, consumer));});}

上面看到getSearchLocations()，getSearchNames()分别是指定配置文件查找位置和具体的文件名。在ConfigFileApplicationListener类中也提供了对应的set方法，说明我们也可以根据自己的需要来进行指定。

从上面也能看到我们idea开发中在resource目录中配置的application.yml中目录和文件名分别是通过

getSearchLocations()

和

getSearchNames()

指定的。

从上面也能看到默认会在

file:./config/, file:./, classpath:/config/, classpath:/

这4个位置去寻找文件名为

application

的配置文件。下面就是具体去查找并加载配置文件了

private void load(String location, String name, Profile profile, DocumentFilterFactory filterFactory,DocumentConsumer consumer) {//我们这里的name ="application",所以就不会走到这个分支if (!StringUtils.hasText(name)) {......}Set<String> processed = new HashSet<>();// this.propertySourceLoaders就是具体来负责加载配置文件的。它是在ConfigFileApplicationListener构造方法中赋值的，//具体的代码是下面这行//this.propertySourceLoaders = SpringFactoriesLoader.loadFactories(PropertySourceLoader.class,getClass().getClassLoader());//当前的有两个类PropertiesPropertySourceLoader,YamlPropertySourceLoader//PropertiesPropertySourceLoader来加载后缀"properties", "xml" 的配置文件//YamlPropertySourceLoader来加载后缀为"yml", "yaml"的配置文件for (PropertySourceLoader loader : this.propertySourceLoaders) {for (String fileExtension : loader.getFileExtensions()) {if (processed.add(fileExtension)) {//具体在这里就会遍历PropertySourceLoader，来加载配置文件//loader就是PropertySourceLoader//location + name就是文件前缀了。如file:./config/application//"." + fileExtension是文件后缀//后面几个参数都是入口传入的loadForFileExtension(loader, location + name, "." + fileExtension, profile, filterFactory,consumer);}}}}

在这里就是分别使用PropertiesPropertySourceLoader,YamlPropertySourceLoader去做具体的加载解析了

private void loadForFileExtension(PropertySourceLoader loader, String prefix, String fileExtension,Profile profile, DocumentFilterFactory filterFactory, DocumentConsumer consumer) {//这里是生成文档过滤器//第一次进来的profile==null，不会走进下面的if分支//下面这有两个DocumentFilter,它们有什么区别呢？//第一个defaultFilter传入的是null,也就是说如果当前加载的配置文件中如果没有spring.profiles这个属性，那就会被加载//第二个profileFilter传入的是profile，那就需要配置文件中的spring.profiles包含了当前的profile，且处于激活状态DocumentFilter defaultFilter = filterFactory.getDocumentFilter(null);DocumentFilter profileFilter = filterFactory.getDocumentFilter(profile);if (profile != null) {// Try profile-specific file & profile section in profile file (gh-340)//这里就会去查找类似我们工程中的配置文件application-test.properties了String profileSpecificFile = prefix + "-" + profile + fileExtension;load(loader, profileSpecificFile, profile, defaultFilter, consumer);load(loader, profileSpecificFile, profile, profileFilter, consumer);// Try profile specific sections in files we\'ve already processed//这个情况就是类似我们配置文件application-test.properties的情况了//虽然profile==test时会去加载application-test.properties，但是由于application-test.properties配置文件中的//spring.profiles=sitdba，是不能被profile=test的profileFilter匹配到的，//但是可以被profiles=sitdbaprofileFilter匹配匹配到，也就是会在下面的for循环中被加载到for (Profile processedProfile : this.processedProfiles) {if (processedProfile != null) {String previouslyLoaded = prefix + "-" + processedProfile + fileExtension;load(loader, previouslyLoaded, profile, profileFilter, consumer);}}}//第一次profile==null，就会加载类似application.yml这种，文件名中没有包含profile的配置文件// Also try the profile-specific section (if any) of the normal fileload(loader, prefix + fileExtension, profile, profileFilter, consumer);}

在这里就是具体拼接文件名:如application.yml,application-xxx.properties这种配置文件具体去加载了

private void load(PropertySourceLoader loader, String location, Profile profile, DocumentFilter filter,DocumentConsumer consumer) {try {//这里就是使用资源加载器去加载指定位置上的资源，也就是加载我们的配置文件。//如果找不到配置文件就直接返回，如果能找到就进行后面配置文件的加载了Resource resource = this.resourceLoader.getResource(location);if (resource == null || !resource.exists()) {if (this.logger.isTraceEnabled()) {StringBuilder description = getDescription("Skipped missing config ", location, resource,profile);this.logger.trace(description);}return;}if (!StringUtils.hasText(StringUtils.getFilenameExtension(resource.getFilename()))) {if (this.logger.isTraceEnabled()) {StringBuilder description = getDescription("Skipped empty config extension ", location,resource, profile);this.logger.trace(description);}return;}String name = "applicationConfig: [" + location + "]";//这里会将配置文件转化成Document。//yml文件中会用---进行区分成不同的文件，所以这里就是一个list，表示加载多个List<Document> documents = loadDocuments(loader, name, resource);//例如一个空的文件，就会走到这里，返回if (CollectionUtils.isEmpty(documents)) {if (this.logger.isTraceEnabled()) {StringBuilder description = getDescription("Skipped unloaded config ", location, resource,profile);this.logger.trace(description);}return;}List<Document> loaded = new ArrayList<>();//这里会对Document进行过滤，对于符合条件的进行后续处理for (Document document : documents) {//这个过滤的话主要有两点//1.如果profile是null,那么就需要document的document.getProfiles()为空，就是配置文件中没有spring.profiles//2.如果profile不是null，那么就判断document的profiles中包含profile，且当前激活的profile包含了document的profileif (filter.match(document)) {//这个是查找document中的spring.profiles.active加入到profiles中，在入口的lambda表达式就会继续从profiles中去遍历查找配置文件//在这个方法中只会添加一次，后面再添加的话，判断之前已经有添加，就会直接返回。同时在添加完了激活的profile后，会删除掉开始加入的名为default的默认的profileaddActiveProfiles(document.getActiveProfiles());//这个是通过spring.profiles.include属性添加引入的外部文件的profileaddIncludedProfiles(document.getIncludeProfiles());//将document加入到loaded列表中loaded.add(document);}}//这里对上面的document顺序进行反转Collections.reverse(loaded);if (!loaded.isEmpty()) {//在这里会将document加载到成员变量loaded(它的结构是Map<Profile, MutablePropertySources>，下面的图就是当前loaded中的内容)中loaded.forEach((document) -> consumer.accept(profile, document));if (this.logger.isDebugEnabled()) {StringBuilder description = getDescription("Loaded config file ", location, resource, profile);this.logger.debug(description);}}}catch (Exception ex) {throw new IllegalStateException("Failed to load property source from location \'" + location + "\'", ex);}}

从上面的图上也能看到application-test.propertie并没有在profile=test下面，而是在profile=sitdba下面

我们再次回到之前开头的位置

(defaultProperties) -> {this.profiles = new LinkedList<>();this.processedProfiles = new LinkedList<>();this.activatedProfiles = false;this.loaded = new LinkedHashMap<>();initializeProfiles();while (!this.profiles.isEmpty()) {Profile profile = this.profiles.poll();if (isDefaultProfile(profile)) {addProfileToEnvironment(profile.getName());}load(profile, this::getPositiveProfileFilter,addToLoaded(MutablePropertySources::addLast, false));//将激活并已经解析过的profile添加到列表中，最后会将这个列表中的profile作为environment中激活的profilethis.processedProfiles.add(profile);}//这个是什么场景呢？load(null, this::getNegativeProfileFilter, addToLoaded(MutablePropertySources::addFirst, true));//这里就会将我们加载的配置文件都添加到this.environment.getPropertySources()属性上addLoadedPropertySources();//将上面的this.processedProfiles作为激活的profileapplyActiveProfiles(defaultProperties);}