AI智能
改变未来

springboot自动扫描添加的BeanDefinition源码解析


1.

springboot启动过程中,首先会收集需要加载的bean的定义,作为BeanDefinition对象,添加到BeanFactory中去。

由于BeanFactory中只有

getBean

之类获取

bean

对象的方法,所以将将BeanDefinition添加到BeanFactory中,是通过

BeanDefinitionRegistry

接口的

void registerBeanDefinition(String beanName, BeanDefinition beanDefinition) throws BeanDefinitionStoreException;

方法来完成的。

所以我们的BeanFactory的实现类如果需要具备通过beanName来返回bean对象和添加删除BeanDefinition的能力,至少实现

BeanFactory

BeanDefinitionRegistry

的这两个接口。

这里我们就来看看springboot是如何查找bean的定义,添加到BeanFactory中的。

由于我们这里只是关注查找bean对象的定义,所以这里我们这里提到的BeanFactory主要会关注

BeanDefinitionRegistry

这个接口。

我们本地主要分析

springboot

扫描加载

bean

的配置,和我们的代码关系不大,所以我们的代码就用最简单的吧。具体代码如下:

package com.example.bootargs;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplicationpublic class BootargsApplication {public static void main(String[] args) {SpringApplication.run(BootargsApplication.class, args);}}

后面提到的主类统一是

com.example.bootargs.BootargsApplication

2.

Springboot 查找bean的定义主要是通过

ConfigurationClassPostProcessor

这个类来完成的。

ConfigurationClassPostProcessor

实现了

BeanDefinitionRegistryPostProcessor

接口。

BeanDefinitionRegistryPostProcessor

接口就是通过

postProcessBeanDefinitionRegistry

方法来给

BeanDefinitionRegistry

的实现类来添加bean的定义。

BeanDefinitionRegistryPostProcessor

继承了

BeanFactoryPostProcessor

接口,而

BeanFactoryPostProcessor

接口主要是用来对

BeanFactory

进行增强。在springboot启动过程中首先会创建

BeanFactory

,再调用

BeanFactoryPostProcessor

BeanFactory

进行增强,最后才会去创建

bean

对象。

通过

BeanFactoryPostProcessor

对BeanFactory进行增强,主要是通过

PostProcessorRegistrationDelegate

的静态方法来完成的。在这过程中就会调用到

ConfigurationClassPostProcessor

这个类。

由于

ConfigurationClassPostProcessor

实现了

BeanDefinitionRegistryPostProcessor

接口,

PostProcessorRegistrationDelegate

就会调用

ConfigurationClassPostProcessor

postProcessBeanDefinitionRegistry

方法中,就会调用到

processConfigBeanDefinitions

方法来查找bean的定义。我们就从这里作为入口来看吧。

3.

下面我们就去看看

ConfigurationClassPostProcessor

processConfigBeanDefinitions

方法

/*** Build and validate a configuration model based on the registry of* {@link Configuration} classes.*/public void processConfigBeanDefinitions(BeanDefinitionRegistry registry) {List<BeanDefinitionHolder> configCandidates = new ArrayList<>();String[] candidateNames = registry.getBeanDefinitionNames();//在下面的这个for循环中,会从beanFactory中已经有的bean的定义中寻找有Configuration注解的配置类。//默认这里获取到的只有一个包含SpringBootApplication注解的主类for (String beanName : candidateNames) {......configCandidates.add(new BeanDefinitionHolder(beanDef, beanName));}}//如果没有找到配置类,就直接返回// Return immediately if no @Configuration classes were foundif (configCandidates.isEmpty()) {return;}......//在这里就通过ConfigurationClassParser去解析配置类// Parse each @Configuration classConfigurationClassParser parser = new ConfigurationClassParser(this.metadataReaderFactory, this.problemReporter, this.environment,this.resourceLoader, this.componentScanBeanNameGenerator, registry);Set<BeanDefinitionHolder> candidates = new LinkedHashSet<>(configCandidates);Set<ConfigurationClass> alreadyParsed = new HashSet<>(configCandidates.size());do {StartupStep processConfig = this.applicationStartup.start("spring.context.config-classes.parse");//所有bean的定义的查找都是在这里完成的。下面我们去看看这里的parse方法parser.parse(candidates);......}

ConfigurationClassParser

中的

parse

方法中,由于我们的配置类是通过注解来定义的,所以会走

AnnotatedBeanDefinition

这个分支。继续会调用到

processConfigurationClass(new ConfigurationClass(metadata, beanName), DEFAULT_EXCLUSION_FILTER);

这句,我们就直接进到这个

processConfigurationClass

方法去看吧。

protected void processConfigurationClass(ConfigurationClass configClass, Predicate<String> filter) throws IOException {//在这里首先看配置类上是否有Conditional注解,如果有的话,就去解析处理,看看是否要跳过这个注解类if (this.conditionEvaluator.shouldSkip(configClass.getMetadata(), ConfigurationPhase.PARSE_CONFIGURATION)) {return;}//所有解析出来的配置类都要放置到configurationClasses中,key是当前解析出来的配置类,value就是表示这个配置类是通过谁来导入的。//如果这个配置类不是通过别的类来导入的,这时key和value就是一样的。ConfigurationClass existingClass = this.configurationClasses.get(configClass);//如果通过多个配置类导入了同一个配置类,那么把这个和配置类的导入关系就要进行一下合并if (existingClass != null) {if (configClass.isImported()) {if (existingClass.isImported()) {existingClass.mergeImportedBy(configClass);}// Otherwise ignore new imported config class; existing non-imported class overrides it.return;}else {// Explicit bean definition found, probably replacing an import.// Let\'s remove the old one and go with the new one.this.configurationClasses.remove(configClass);this.knownSuperclasses.values().removeIf(configClass::equals);}}// Recursively process the configuration class and its superclass hierarchy.//这里是将配置类转化为SourceClass对象SourceClass sourceClass = asSourceClass(configClass, filter);do {//在这里就会进行真正的配置类的解析出来。//注意这里是个do-while循环,处理完当前的配置类,会继续去处理当前配置类的父类。//如果当前类的父类类名不是java开头,且没有被处理过的话,就会在这个do-while循环中继续去处理sourceClass = doProcessConfigurationClass(configClass, sourceClass, filter);}while (sourceClass != null);this.configurationClasses.put(configClass, configClass);}

this.conditionEvaluator.shouldSkip(configClass.getMetadata(), ConfigurationPhase.PARSE_CONFIGURATION)

这个的过滤主要是通过

org.springframework.context.annotation.Condition

接口的子类去实现

matches

方法完成的。

举个例子简单说下:

@Configuration(proxyBeanMethods = false)@ConditionalOnMissingBean(name = AbstractApplicationContext.MESSAGE_SOURCE_BEAN_NAME, search = SearchStrategy.CURRENT)@AutoConfigureOrder(Ordered.HIGHEST_PRECEDENCE)@Conditional(ResourceBundleCondition.class)@EnableConfigurationPropertiespublic class MessageSourceAutoConfiguration

上面是

MessageSourceAutoConfiguration

类的定义,首先会查找它上面的

Conditional

注解,会找到两个注解:

  • @ConditionalOnMissingBean(name = AbstractApplicationContext.MESSAGE_SOURCE_BEAN_NAME, search = SearchStrategy.CURRENT)

    由于这个这个注解上面有

    @Conditional(OnBeanCondition.class)

    ,所以会交给

    OnBeanCondition

    这个类去处理。

  • @Conditional(ResourceBundleCondition.class)

    ,则会交给

    ResourceBundleCondition

    这个类去处理。

processConfigurationClass

这个方法会有多个地方,主要会出现在三个地方:

  1. 就是调用
    parse

    方法的时候会调用到这个

    processConfigurationClass

    方法。

  2. doProcessConfigurationClass

    中解析当前配置类的属性时也可能会多次调用到

    processConfigurationClass

    方法。

  3. this.deferredImportSelectorHandler.process()

    调用时也可能会调用到

    processConfigurationClass

    方法

我们这里解析的所有配置类都添加到都会调用到

configurationClasses.put(configClass, configClass)

方法,所以我们最终有多个类添加到

configurationClasses

集合中,就至少有多少次调用到

processConfigurationClass

方法(有Conditional注解的判断,所以调用次数可能多于最终添加到

configurationClasses

集合中元素个数)

@Nullableprotected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass, Predicate<String> filter)throws IOException {//在这里,查看类是否有Component注解,有的话,查找当前类的内部类,进行处理if (configClass.getMetadata().isAnnotated(Component.class.getName())) {// Recursively process any member (nested) classes first//这里就可能会递归调用到上面的processConfigurationClass方法processMemberClasses(configClass, sourceClass, filter);}// Process any @PropertySource annotations//在这里,查看类是否有PropertySources注解,有的话去解析属性配置,添加到环境上下文中去for (AnnotationAttributes propertySource : AnnotationConfigUtils.attributesForRepeatable(sourceClass.getMetadata(), PropertySources.class,org.springframework.context.annotation.PropertySource.class)) {if (this.environment instanceof ConfigurableEnvironment) {processPropertySource(propertySource);}else {logger.info("Ignoring @PropertySource annotation on [" + sourceClass.getMetadata().getClassName() +"]. Reason: Environment must implement ConfigurableEnvironment");}}// Process any @ComponentScan annotations//在这里,查看类是否有ComponentScans注解,有的话,就根据这里的条件去进行目录扫描,查找bean的定义//由于我们当前的类上有SpringBootApplication注解,所以这里是能够找到ComponentScan注解的,就会进到这个方法里面去Set<AnnotationAttributes> componentScans = AnnotationConfigUtils.attributesForRepeatable(sourceClass.getMetadata(), ComponentScans.class, ComponentScan.class);if (!componentScans.isEmpty() &&!this.conditionEvaluator.shouldSkip(sourceClass.getMetadata(), ConfigurationPhase.REGISTER_BEAN)) {for (AnnotationAttributes componentScan : componentScans) {// The config class is annotated with @ComponentScan -> perform the scan immediately//在这里,就会去处理ComponentScans注解相关的内容。//ComponentScans注解上有个basePackages属性,用来指定扫描的包的名字。//如果没有指定basePackages属性,就在当前类的包下及其所有子包下去查找相关的bean的定义。//我们一般不会指定basePackages属性,那么会在当前sourceClass类的包及其所有子包下去查找bean的定义。//我们自己代码中定义的controller,service,dao等等都是在这一步获取到bean的定义的。Set<BeanDefinitionHolder> scannedBeanDefinitions =this.componentScanParser.parse(componentScan, sourceClass.getMetadata().getClassName());// Check the set of scanned definitions for any further config classes and parse recursively if neededfor (BeanDefinitionHolder holder : scannedBeanDefinitions) {BeanDefinition bdCand = holder.getBeanDefinition().getOriginatingBeanDefinition();if (bdCand == null) {bdCand = holder.getBeanDefinition();}if (ConfigurationClassUtils.checkConfigurationClassCandidate(bdCand, this.metadataReaderFactory)) {//这里也会间接调用到processConfigurationClass方法parse(bdCand.getBeanClassName(), holder.getBeanName());}}}}// Process any @Import annotations//在这里,就会去处理类上的import注解。//getImports(sourceClass)首先会获取到import的类。//这里会有两个,一个是AutoConfigurationPackage上注解的AutoConfigurationPackages.Registrar.class//另一个是EnableAutoConfiguration上的注解AutoConfigurationImportSelector.class)//下面我们去看看processImports这个方法//这里面也可能会调用到processConfigurationClass方法processImports(configClass, sourceClass, getImports(sourceClass), filter, true);......}

doProcessConfigurationClass

是真正用来处理配置类的。

在这个方法中会依次处理内部类、

PropertySources

注解、

ComponentScans

注解、

Import

注解、

ImportResource

注解、

Bean

注解、接口上的默认方法、继续递归到它的父类。

其中:

  • 内部类会继续调用

    processConfigurationClass

    方法递归去处理

  • PropertySources

    注解解析后添加到环境上下文中

  • ComponentScans

    注解扫描到的到的类会直接被添加到

    beanFactory

    中,也会继续调用

    processConfigurationClass

    方法递归去处理

  • Import

    注解会分3种情况处理:

    Import

    的类如果实现了

    ImportSelector

    。且实现了它的子接口

    DeferredImportSelector

    ,则会添加到

    deferredImportSelectors

    中,后续进行处理。如果没有实现子接口,就递归调用

    processImports

    进行处理。

  • Import

    的类如果实现了

    ImportBeanDefinitionRegistrar

    。则添加到当前配置类的属性中,进行后续处理。

  • 不属于上面两种情况的话,就继续递归调用
    processConfigurationClass

    进行处理。

  • ImportResource

    注解、

    Bean

    注解、接口上的默认方法这些都会解析后添加到当前配置类的属性上,后续进行处理

  • 对下面方法的几个入参简单描述下:

    • configClass

      currentSourceClass

      这两个参数直接都是指代我们包含

      SpringBootApplication

      注解的主类。

      其中

      configClass

      表示当前处理的类是被谁导入的,

      currentSourceClass

      表示当前正在处理的类。这两者一般底层是同一个资源类,但是有可能会有递归调用,这时两者就可能会不同。

    • importCandidates

      是通过

      import

      注解导入的类,这里是

      AutoConfigurationPackages.Registrar.class

      AutoConfigurationImportSelector.class

      importCandidates

      就是当前被导入的类,也就是在这里被处理的类

    • exclusionFilter

      是在

      ConfigurationClassParser

      中定义的,用来过滤

      java.lang.annotation.

      org.springframework.stereotype.

      开头的注解

    • checkForCircularImports

      表示是否检查递归导入

    private void processImports(ConfigurationClass configClass, SourceClass currentSourceClass,Collection<SourceClass> importCandidates, Predicate<String> exclusionFilter,boolean checkForCircularImports) {if (importCandidates.isEmpty()) {return;}//这里是错误检查,检查是否出现了递归if (checkForCircularImports && isChainedImportOnStack(configClass)) {this.problemReporter.error(new CircularImportProblem(configClass, this.importStack));}else {//先将当前的配置类压入栈this.importStack.push(configClass);try {//这里,就会对import标签导入的类进行处理for (SourceClass candidate : importCandidates) {//AutoConfigurationImportSelector.class类就会走下面的分支if (candidate.isAssignable(ImportSelector.class)) {// Candidate class is an ImportSelector -> delegate to it to determine importsClass<?> candidateClass = candidate.loadClass();//首先在这里创建一个AutoConfigurationImportSelector类的对象,ImportSelector selector = ParserStrategyUtils.instantiateClass(candidateClass, ImportSelector.class,this.environment, this.resourceLoader, this.registry);Predicate<String> selectorFilter = selector.getExclusionFilter();if (selectorFilter != null) {exclusionFilter = exclusionFilter.or(selectorFilter);}if (selector instanceof DeferredImportSelector) {//在这里,将当前的配置类和AutoConfigurationImportSelector的对象封装成DeferredImportSelectorHolder对象//添加到延迟导入的集合deferredImportSelectors中this.deferredImportSelectorHandler.handle(configClass, (DeferredImportSelector) selector);}else {String[] importClassNames = selector.selectImports(currentSourceClass.getMetadata());Collection<SourceClass> importSourceClasses = asSourceClasses(importClassNames, exclusionFilter);processImports(configClass, currentSourceClass, importSourceClasses, exclusionFilter, false);}}//AutoConfigurationPackages.Registrar.class这个类就会走到这个分支中//在这个分支中,首先创建AutoConfigurationPackages.Registrar的对象//添加到当前配置类的importBeanDefinitionRegistrars属性中去else if (candidate.isAssignable(ImportBeanDefinitionRegistrar.class)) {// Candidate class is an ImportBeanDefinitionRegistrar ->// delegate to it to register additional bean definitionsClass<?> candidateClass = candidate.loadClass();ImportBeanDefinitionRegistrar registrar =ParserStrategyUtils.instantiateClass(candidateClass, ImportBeanDefinitionRegistrar.class,this.environment, this.resourceLoader, this.registry);configClass.addImportBeanDefinitionRegistrar(registrar, currentSourceClass.getMetadata());}else {// Candidate class not an ImportSelector or ImportBeanDefinitionRegistrar ->// process it as an @Configuration classthis.importStack.registerImport(currentSourceClass.getMetadata(), candidate.getMetadata().getClassName());processConfigurationClass(candidate.asConfigClass(configClass), exclusionFilter);}}}catch (BeanDefinitionStoreException ex) {throw ex;}catch (Throwable ex) {throw new BeanDefinitionStoreException("Failed to process import candidates for configuration class [" +configClass.getMetadata().getClassName() + "]", ex);}finally {this.importStack.pop();}}}

    上面的

    import

    导入类处理完了,下面我们继续回到

    doProcessConfigurationClass

    中去看剩余的部分

    @Nullableprotected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass, Predicate<String> filter)throws IOException {......//这部分前面已经分析过了,我们就继续看后面的吧// Process any @ImportResource annotations// 这里是处理ImportResource注解AnnotationAttributes importResource =AnnotationConfigUtils.attributesFor(sourceClass.getMetadata(), ImportResource.class);if (importResource != null) {String[] resources = importResource.getStringArray("locations");Class<? extends BeanDefinitionReader> readerClass = importResource.getClass("reader");for (String resource : resources) {String resolvedResource = this.environment.resolveRequiredPlaceholders(resource);configClass.addImportedResource(resolvedResource, readerClass);}}// Process individual @Bean methods//这里是处理配置类内部的有Bean注解的方法,添加到配置类的beanMethods属性中Set<MethodMetadata> beanMethods = retrieveBeanMethodMetadata(sourceClass);for (MethodMetadata methodMetadata : beanMethods) {configClass.addBeanMethod(new BeanMethod(methodMetadata, configClass));}// Process default methods on interfaces//这里处理配置类实现的接口上默认方法上有Bean注解的话,也添加到beanMethods属性中processInterfaces(configClass, sourceClass);// Process superclass, if any//这里去获取配置类的父类,如果存在父类且父类类名不是java开头且还没有被处理过,就会返回父类,继续进行父类的处理。if (sourceClass.getMetadata().hasSuperClass()) {String superclass = sourceClass.getMetadata().getSuperClassName();if (superclass != null && !superclass.startsWith("java") &&!this.knownSuperclasses.containsKey(superclass)) {this.knownSuperclasses.put(superclass, configClass);// Superclass found, return its annotation metadata and recursereturn sourceClass.getSuperClass();}}// No superclass -> processing is completereturn null;}

    到这里

    processConfigurationClass

    方法就整个分析完了。

    下面就会走到

    parse

    方法的最后一句了。我们进去看看

    public void parse(Set<BeanDefinitionHolder> configCandidates) {......//就会走到下面这行代码this.deferredImportSelectorHandler.process();}

    这里主要是对延迟导入的类进行处理

    public void process() {//在上面代码中我们分析到this.deferredImportSelectors中只有一个//由前面的配置类和AutoConfigurationImportSelector类的对象封装的DeferredImportSelectorHolder对象List<DeferredImportSelectorHolder> deferredImports = this.deferredImportSelectors;this.deferredImportSelectors = null;try {if (deferredImports != null) {DeferredImportSelectorGroupingHandler handler = new DeferredImportSelectorGroupingHandler();deferredImports.sort(DEFERRED_IMPORT_COMPARATOR);//这里会对延迟导入的类进行分组,添加到handler中,由于我们这里只有一个对象,所以这块的分组,我们可以不用太关注//同时会将前面的配置类添加到handler对象的configurationClasses属性中deferredImports.forEach(handler::register);//下面就会交给handler去进行处理handler.processGroupImports();}}finally {this.deferredImportSelectors = new ArrayList<>();}}}

    下面我们看看

    processGroupImports

    是如何处理的

    public void processGroupImports() {//这里就按分组去处理了for (DeferredImportSelectorGrouping grouping : this.groupings.values()) {Predicate<String> exclusionFilter = grouping.getCandidateFilter();//这里的grouping.getImports()就回去获取系统的配置类,我们下面去看这个getImportsgrouping.getImports().forEach(entry -> {......}}

    这里的

    grouping.getCandidateFilter()

    来自两部分:

    +

    • 另一部分是来自

      ConfigurationClassParser

      定义的lambda表达式

    这个是在

    ConfigurationClassParser

    类的一个静态内部类

    DeferredImportSelectorGrouping

    中的方法

    public Iterable<Group.Entry> getImports() {//这里的deferredImports中只有一个对象,还是之前的DeferredImportSelectorHolderfor (DeferredImportSelectorHolder deferredImport : this.deferredImports) {//这里的this.group就是之前分组的deferredImport.getImportSelector().getImportGroup();方法的返回值创建的对象//具体就是AutoConfigurationImportSelector.AutoConfigurationGroup的对象//下面我们先看看这个process方法this.group.process(deferredImport.getConfigurationClass().getMetadata(),deferredImport.getImportSelector());}return this.group.selectImports();}

    process

    是在

    AutoConfigurationImportSelector.AutoConfigurationGroup

    这个类中

    public void process(AnnotationMetadata annotationMetadata, DeferredImportSelector deferredImportSelector) {Assert.state(deferredImportSelector instanceof AutoConfigurationImportSelector,() -> String.format("Only %s implementations are supported, got %s",AutoConfigurationImportSelector.class.getSimpleName(),deferredImportSelector.getClass().getName()));//下面这行代码也比较重要,我们进去看看AutoConfigurationEntry autoConfigurationEntry = ((AutoConfigurationImportSelector) deferredImportSelector).getAutoConfigurationEntry(annotationMetadata);this.autoConfigurationEntries.add(autoConfigurationEntry);for (String importClassName : autoConfigurationEntry.getConfigurations()) {this.entries.putIfAbsent(importClassName, annotationMetadata);}}
    protected AutoConfigurationEntry getAutoConfigurationEntry(AnnotationMetadata annotationMetadata) {//这里,我们就能看到设置spring.boot.enableautoconfiguration属性去禁止导入系统配置的bean的定义if (!isEnabled(annotationMetadata)) {return EMPTY_ENTRY;}AnnotationAttributes attributes = getAttributes(annotationMetadata);//在下面这行中,就能看到通过ClassLoader去加载META-INF/spring.factories文件,读取内容。放置到cache中//在当前这里,会去获取key=org.springframework.boot.autoconfigure.EnableAutoConfiguration的所有属性配置List<String> configurations = getCandidateConfigurations(annotationMetadata, attributes);configurations = removeDuplicates(configurations);Set<String> exclusions = getExclusions(annotationMetadata, attributes);checkExcludedClasses(configurations, exclusions);configurations.removeAll(exclusions);//在这里获取配置过滤类并创建对象,对上面的configuras进行过滤//这里的配置过滤类也是从cache中获取,key=org.springframework.boot.autoconfigure.AutoConfigurationImportFilterconfigurations = getConfigurationClassFilter().filter(configurations);//这行代码不关键,我们可以不用去关注fireAutoConfigurationImportEvents(configurations, exclusions);//这里返回一个AutoConfigurationEntry对象//其中configurations是过滤器能够匹配到的配置类,exclusions在我们这里是空的return new AutoConfigurationEntry(configurations, exclusions);}

    上面代码中

    getConfigurationClassFilter()

    获取到的是:

    是来自

    spring.factories

    文件中的

    org.springframework.boot.autoconfigure.AutoConfigurationImportFilter

    • org.springframework.boot.autoconfigure.condition.OnClassCondition

      这个类主要检查是否存在指定的类

    • org.springframework.boot.autoconfigure.condition.OnWebApplicationCondition

      这个类主要检查是否存在WebApplicationContext.

    • org.springframework.boot.autoconfigure.condition.OnBeanCondition

      这个类主要检查是否存在指定的bean

    在这个过程中,在生成filter过程中,首先会通过类加载器去读取

    META-INF/spring-autoconfigure-metadata.properties

    这些文件。

    在这里,主要是通过

    类名.ConditionalOnBean

    类名.ConditionalOnSingleCandidate

    类名.ConditionalOnClass

    类名.ConditionalOnWebApplication

    来过滤掉不符合的配置类。

    具体的算法入口都在这3个类的父类

    FilteringSpringBootCondition

    match

    方法,具体的实现入口分别在这3个类的

    getOutcomes

    方法中。

    由于这3个类都是实现了

    Condition

    接口,因此前面分析的

    processConfigurationClass

    方法开始的地方通过

    Conditional

    注解过滤配置类也会用到这3个类。

    从上面也可以看出springboot的按需加载主要也是通过实现

    Condition

    接口来完成的。

    再回到

    process

    这个方法。

    public void process(AnnotationMetadata annotationMetadata, DeferredImportSelector deferredImportSelector) {......//上面的代码刚才已经分析过了//在这里将上面返回的AutoConfigurationEntry对象添加到autoConfigurationEntries中this.autoConfigurationEntries.add(autoConfigurationEntry);for (String importClassName : autoConfigurationEntry.getConfigurations()) {//分别将添加的配置类添加到entries这个属性中//importClassName是新查找到的配置类,annotationMetadata都是同一个就是我们的主类this.entries.putIfAbsent(importClassName, annotationMetadata);}}

    在接下来的

    selectImports

    方法中,首先会对这些新添加的配置类进行排序,然后组装成

    new Entry(this.entries.get(importClassName), importClassName))

    对象的集合。

    这里需要注意的是

    this.entries.get(importClassName)

    这就是我们的主类,

    importClassName

    是我们需要添加的配置类。

    这里主要是为了对当前导入的配置类和它是被谁导入的进行一个关联(在这里,所有要导入的配置类都是由我们的主类来导入的)。

    就是在后面创建

    ConfigurationClass

    对象时会使用

    public ConfigurationClass(MetadataReader metadataReader, @Nullable ConfigurationClass importedBy)

    这个构造方法。

    最后在添加这些配置类到

    beanFactory

    中时通过

    下面再回到

    processGroupImports

    方法

    public void processGroupImports() {for (DeferredImportSelectorGrouping grouping : this.groupings.values()) {Predicate<String> exclusionFilter = grouping.getCandidateFilter();//上面已经分析到grouping.getImports()返回的是Entry对象的集合grouping.getImports().forEach(entry -> {//entry.getMetadata()返回的还是我们之前的主类。//这里的configurationClass也是我们之前的主类。//这个主要是为了在processImports方法中创建的配置类为它们设置importedBy属性ConfigurationClass configurationClass = this.configurationClasses.get(entry.getMetadata());try {//这里又会调用到processImports这个方法。这个在前面已经分析过了,但是这里有一点不一样,下面我们看看不一样的地方processImports(configurationClass, asSourceClass(configurationClass, exclusionFilter),Collections.singleton(asSourceClass(entry.getImportClassName(), exclusionFilter)),exclusionFilter, false);}catch (BeanDefinitionStoreException ex) {throw ex;}catch (Throwable ex) {throw new BeanDefinitionStoreException("Failed to process import candidates for configuration class [" +configurationClass.getMetadata().getClassName() + "]", ex);}});}}

    关于这个

    processImports

    方法的参数前面有描述,这里就不再说了

    下面的这个方法中这时

    importCandidates

    和之前的有点不一样,之前的是通过

    import

    注解导入的分别会走

    for

    循环的前面两个分支,现在大概率会走到后面的

    else

    分支

    private void processImports(ConfigurationClass configClass, SourceClass currentSourceClass,Collection<SourceClass> importCandidates, Predicate<String> exclusionFilter,boolean checkForCircularImports) {this.importStack.push(configClass);try {for (SourceClass candidate : importCandidates) {if (candidate.isAssignable(ImportSelector.class)) {......}else if (candidate.isAssignable(ImportBeanDefinitionRegistrar.class)) {......}else {// Candidate class not an ImportSelector or ImportBeanDefinitionRegistrar ->// process it as an @Configuration class//上次进入这个方法,分别走了上面的两个分支,现在大概率会走到这个分支//这里会将导入的类添加到imports属性中,key是新导入的配置类,value是我们之前的主类this.importStack.registerImport(currentSourceClass.getMetadata(), candidate.getMetadata().getClassName());//这里又会去处理新添加的配置类,在这里是有可能出现递归的,下面我们具体分析下这里的处理逻辑processConfigurationClass(candidate.asConfigClass(configClass), exclusionFilter);}}}......}}

    在上面的

    processImports

    方法中,会处理新添加的配置类,会调用到

    processConfigurationClass

    这个方法。

    到上面为止,

    ConfigurationClassPostProcessor

    processConfigBeanDefinitions

    方法从parse处理的部分就全部分析完了 。

    这部分主要是处理了通过主类上面的注解,将所有的配置类都添加到

    ConfigurationClassParser

    类的成员变量

    configurationClasses

    中。对于配置类上的

    ImportResource

    Bean

    等等则添加配置类的对应的属性上。

    这里需要注意的是在整个整个过程中只有

    ComponentScans

    扫描到的配置类会添加到

    beanFactory

    中。

    下面我们继续看看后面的代码。

    public void processConfigBeanDefinitions(BeanDefinitionRegistry registry) {......do {StartupStep processConfig = this.applicationStartup.start("spring.context.config-classes.parse");parser.parse(candidates);//前面已经分析到了这里parser.validate();//这里就会得到所有的配置类Set<ConfigurationClass> configClasses = new LinkedHashSet<>(parser.getConfigurationClasses());//alreadyParsed第一次是空的,由于这个方法是do-while循环,在后面会对这个变量赋值configClasses.removeAll(alreadyParsed);// Read the model and create bean definitions based on its contentif (this.reader == null) {this.reader = new ConfigurationClassBeanDefinitionReader(registry, this.sourceExtractor, this.resourceLoader, this.environment,this.importBeanNameGenerator, parser.getImportRegistry());}//在这里就会对前面获取的所有的配置类添加到beanFactory中this.reader.loadBeanDefinitions(configClasses);alreadyParsed.addAll(configClasses);processConfig.tag("classCount", () -> String.valueOf(configClasses.size())).end();candidates.clear();//这里就是对比前后beanFactory中的beanDefinition数量是否有增加,如果有增加说明我们在本次do-while代码中添加了beanFactory//下面的逻辑主要是为了判断当前扫描出来的配置类是否全部添加进了beanFactory中,如果有配置类还没有被今天进去,就会循环,重新执行上面的逻辑if (registry.getBeanDefinitionCount() > candidateNames.length) {String[] newCandidateNames = registry.getBeanDefinitionNames();Set<String> oldCandidateNames = new HashSet<>(Arrays.asList(candidateNames));Set<String> alreadyParsedClasses = new HashSet<>();for (ConfigurationClass configurationClass : alreadyParsed) {alreadyParsedClasses.add(configurationClass.getMetadata().getClassName());}for (String candidateName : newCandidateNames) {if (!oldCandidateNames.contains(candidateName)) {BeanDefinition bd = registry.getBeanDefinition(candidateName);if (ConfigurationClassUtils.checkConfigurationClassCandidate(bd, this.metadataReaderFactory) &&!alreadyParsedClasses.contains(bd.getBeanClassName())) {candidates.add(new BeanDefinitionHolder(bd, candidateName));}}}candidateNames = newCandidateNames;}}while (!candidates.isEmpty());// Register the ImportRegistry as a bean in order to support ImportAware @Configuration classesif (sbr != null && !sbr.containsSingleton(IMPORT_REGISTRY_BEAN_NAME)) {sbr.registerSingleton(IMPORT_REGISTRY_BEAN_NAME, parser.getImportRegistry());}if (this.metadataReaderFactory instanceof CachingMetadataReaderFactory) {// Clear cache in externally provided MetadataReaderFactory; this is a no-op// for a shared cache since it\'ll be cleared by the ApplicationContext.((CachingMetadataReaderFactory) this.metadataReaderFactory).clearCache();}}

    上面的其他代码都比较简单,我们下面主要对上面的

    this.reader.loadBeanDefinitions(configClasses);

    做个简单分析吧。

    ConfigurationClassBeanDefinitionReader

    的方法

    public void loadBeanDefinitions(Set<ConfigurationClass> configurationModel) {//这个类还是用来对Conditional注解进行处理,来判断当前配置类是否要被过滤掉TrackedConditionEvaluator trackedConditionEvaluator = new TrackedConditionEvaluator();for (ConfigurationClass configClass : configurationModel) {//在这里会对每个配置类及它的属性进行处理,封装成beanDefinition添加到beanFactory中去loadBeanDefinitionsForConfigurationClass(configClass, trackedConditionEvaluator);}}
    private void loadBeanDefinitionsForConfigurationClass(ConfigurationClass configClass, TrackedConditionEvaluator trackedConditionEvaluator) {//这里就会对Conditional注解进行判断,如果当前类是被导入的,就会去判断导入它的类if (trackedConditionEvaluator.shouldSkip(configClass)) {String beanName = configClass.getBeanName();if (StringUtils.hasLength(beanName) && this.registry.containsBeanDefinition(beanName)) {this.registry.removeBeanDefinition(beanName);}this.importRegistry.removeImportingClass(configClass.getMetadata().getClassName());return;}//如果类是被导入的,就会去对它进行处理if (configClass.isImported()) {registerBeanDefinitionForImportedConfigurationClass(configClass);}//下面就是对配置类的各种属性进行处理//处理方法上的bean注解for (BeanMethod beanMethod : configClass.getBeanMethods()) {loadBeanDefinitionsForBeanMethod(beanMethod);}//处理导入的资源loadBeanDefinitionsFromImportedResources(configClass.getImportedResources());//处理导入的ImportBeanDefinitionRegistrarloadBeanDefinitionsFromRegistrars(configClass.getImportBeanDefinitionRegistrars());}

    在上面的代码也可以看到,单纯的配置类,如果

    configClass.isImported()

    返回

    false

    ,就不会被添加到beanFactory中。也就是如果配置类不是被导入的,就不会将配置类添加到

    beanFactory

    中。

    前面说过

    ComponentScans

    扫描到的类在处理过程中就被添加到了

    beanFactory

    中,其他的配置类都是在上面的方法中被添加进去的。

    所有添加的类大致可以分为两部分:

    1. 通过类上的注解,直接被添加到配置类中。这部分配置类它们的被导入类就是当前的主类。
    2. 另一部分是通过主类上的
      @Import(AutoConfigurationImportSelector.class)

      注解,读取

      META-INF/spring.factories

      文件,经过

      META-INF/spring-autoconfigure-metadata.properties

      文件过滤后被处理的类。

    上面两部分处理的时候都会进行递归,一层一层处理。而且所有的处理过程中也都会根据

    Conditional

    注解进行过滤。

    同时也需要注意虽然添加到

    beanFactory

    中的都是

    beanD

    ,但是具体都是不一样的。比如:

    ScannedGenericBeanDefinition

    是通过

    ComponentScans

    注解添加的

    ConfigurationClassBeanDefinition

    是处理方法上的

    bean

    注解添加的

    AnnotatedGenericBeanDefinition

    是其他普通的配置类

    到上面,整个分析就结束了。

    整个过程涉及到的各种递归调用等等都比较多,为了不至于文章显的太分散,上面分析过程中对很多细节也都进行了省略。

    由于个人能力问题,上面的分析可能存在错误或者描述不清晰的地方,欢迎大家评论指正。

    赞(0) 打赏
    未经允许不得转载:爱站程序员基地 » springboot自动扫描添加的BeanDefinition源码解析