扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章主要讲解了“Spring Boot配置类加载流程示例”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Spring Boot配置类加载流程示例”吧!
成都创新互联公司是一家专业提供桐庐企业网站建设,专注与成都网站制作、成都做网站、H5开发、小程序制作等业务。10年已为桐庐众多企业、政府机构等服务。创新互联专业的建站公司优惠进行中。
本文基于Spring Boot 1.4.1.RELEASE版本
启动代码如下
@SpringBootApplication public class SampleApplication { public static void main(String[] args) throws Exception { SpringApplication.run(SampleApplication.class, args); } }
然后开始分析流程,由于Spring细节众多,所以我们只关注重点就行了,不然容易迷失在其中
//ConfigurationClassPostProcessor.java //第273行 public void processConfigBeanDefinitions(BeanDefinitionRegistry registry) { ListconfigCandidates = new ArrayList (); String[] candidateNames = registry.getBeanDefinitionNames(); //遍历已经注册的所有bean for (String beanName : candidateNames) { BeanDefinition beanDef = registry.getBeanDefinition(beanName); //判断这个bean是不是已经被加载过的配置类 if (ConfigurationClassUtils.isFullConfigurationClass(beanDef) || ConfigurationClassUtils.isLiteConfigurationClass(beanDef)) { if (logger.isDebugEnabled()) { logger.debug("Bean definition has already been processed as a configuration class: " + beanDef); } } //如果没加载过,判断一下是不是配置类 //这个判断逻辑很简单,有兴趣的朋友可以自己了解一下 //因为是工具类,其实不看也不影响大局,注意这里check完之后,上边的校验就是true了 else if (ConfigurationClassUtils.checkConfigurationClassCandidate(beanDef, this.metadataReaderFactory)) { configCandidates.add(new BeanDefinitionHolder(beanDef, beanName)); } } if (configCandidates.isEmpty()) { return; } //这段代码的功能是将配置类按照Order排序,但其实没有用, //因为此时的configCandidates列表中只有一个元素,就是SampleApplication Collections.sort(configCandidates, new Comparator () { @Override public int compare(BeanDefinitionHolder bd1, BeanDefinitionHolder bd2) { int i1 = ConfigurationClassUtils.getOrder(bd1.getBeanDefinition()); int i2 = ConfigurationClassUtils.getOrder(bd2.getBeanDefinition()); return (i1 < i2) ? -1 : (i1 > i2) ? 1 : 0; } }); //省略部分代码 //这里就是配置解析的关键 parser.parse(candidates); //省略部分代码 }
接下来看ConfigurationClassParser这个类
//ConfigurationClassParser.java //第166行 public void parse(SetconfigCandidates) { this.deferredImportSelectors = new LinkedList (); //遍历所有的配置类,根据类型调用不同的parse方法 //这里分成的三种类型各代表什么,暂时不太清楚 for (BeanDefinitionHolder holder : configCandidates) { BeanDefinition bd = holder.getBeanDefinition(); try { if (bd instanceof AnnotatedBeanDefinition) { parse(((AnnotatedBeanDefinition) bd).getMetadata(), holder.getBeanName()); } else if (bd instanceof AbstractBeanDefinition && ((AbstractBeanDefinition) bd).hasBeanClass()) { parse(((AbstractBeanDefinition) bd).getBeanClass(), holder.getBeanName()); } else { parse(bd.getBeanClassName(), holder.getBeanName()); } } catch (BeanDefinitionStoreException ex) { throw ex; } catch (Throwable ex) { throw new BeanDefinitionStoreException( "Failed to parse configuration class [" + bd.getBeanClassName() + "]", ex); } } //省略部分代码 }
不同的parse方法会将各种参数组装成ConfigurationClass对象,传给processConfigurationClass()
//ConfigurationClassParser.java //第208行 protected void processConfigurationClass(ConfigurationClass configClass) throws IOException { //判断当前要解析的bean是否符合解析的条件 if (this.conditionEvaluator.shouldSkip(configClass.getMetadata(), ConfigurationPhase.PARSE_CONFIGURATION)) { return; } ConfigurationClass existingClass = this.configurationClasses.get(configClass); if (existingClass != null) { if (configClass.isImported()) { if (existingClass.isImported()) { existingClass.mergeImportedBy(configClass); } return; } else { this.configurationClasses.remove(configClass); for (Iteratorit = this.knownSuperclasses.values().iterator(); it.hasNext(); ) { if (configClass.equals(it.next())) { it.remove(); } } } } //省略部分代码 } //ConditionEvaluator.java //第73行 //AnnotatedTypeMetadata:类上的注解信息 //ConfigurationPhase:PARSE_CONFIGURATION-在解析配置时校验;REGISTER_BEAN-在注册bean时校验 public boolean shouldSkip(AnnotatedTypeMetadata metadata, ConfigurationPhase phase) { //如果没有配置条件,直接返回 if (metadata == null || !metadata.isAnnotated(Conditional.class.getName())) { return false; } //如果不指定phase,配置类使用PARSE_CONFIGURATION,其他使用REGISTER_BEAN if (phase == null) { if (metadata instanceof AnnotationMetadata && ConfigurationClassUtils.isConfigurationCandidate((AnnotationMetadata) metadata)) { return shouldSkip(metadata, ConfigurationPhase.PARSE_CONFIGURATION); } return shouldSkip(metadata, ConfigurationPhase.REGISTER_BEAN); } //获取Condition并判断条件 List conditions = new ArrayList (); for (String[] conditionClasses : getConditionClasses(metadata)) { for (String conditionClass : conditionClasses) { Condition condition = getCondition(conditionClass, this.context.getClassLoader()); conditions.add(condition); } } AnnotationAwareOrderComparator.sort(conditions); for (Condition condition : conditions) { ConfigurationPhase requiredPhase = null; if (condition instanceof ConfigurationCondition) { requiredPhase = ((ConfigurationCondition) condition).getConfigurationPhase(); } if (requiredPhase == null || requiredPhase == phase) { if (!condition.matches(this.context, metadata)) { return true; } } } return false; }
开始解析配置类之前,会先判断当前类是否符合条件以及是否已经解析过,然后才会进入解析流程
//ConfigurationClassParser.java //第208行 protected void processConfigurationClass(ConfigurationClass configClass) throws IOException { //省略部分代码 //递归处理配置类和它的父类 SourceClass sourceClass = asSourceClass(configClass); do { sourceClass = doProcessConfigurationClass(configClass, sourceClass); } while (sourceClass != null); this.configurationClasses.put(configClass, configClass); }
解析的流程有点多,我们分段处理
1、处理嵌套(内部)的配置类
//ConfigurationClassParser.java //第252行 protected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { //先递归处理嵌套(内部)的配置类 processMemberClasses(configClass, sourceClass); //省略部分代码 } //ConfigurationClassParser.java //第326行 private void processMemberClasses(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { for (SourceClass memberClass : sourceClass.getMemberClasses()) { if (ConfigurationClassUtils.isConfigurationCandidate(memberClass.getMetadata()) && !memberClass.getMetadata().getClassName().equals(configClass.getMetadata().getClassName())) { if (this.importStack.contains(configClass)) { this.problemReporter.error(new CircularImportProblem(configClass, this.importStack)); } else { this.importStack.push(configClass); try { //回到最开始解析的地方,递归处理 processConfigurationClass(memberClass.asConfigClass(configClass)); } finally { this.importStack.pop(); } } } } }
2、处理@PropertySource注解
//ConfigurationClassParser.java //第252行 protected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { //省略部分代码 for (AnnotationAttributes propertySource : AnnotationConfigUtils.attributesForRepeatable( sourceClass.getMetadata(), PropertySources.class, org.springframework.context.annotation.PropertySource.class)) { if (this.environment instanceof ConfigurableEnvironment) { //解析properties配置文件并放到Spring环境中 processPropertySource(propertySource); } else { logger.warn("Ignoring @PropertySource annotation on [" + sourceClass.getMetadata().getClassName() + "]. Reason: Environment must implement ConfigurableEnvironment"); } } //省略部分代码 }
3、处理@ComponentScan注解
//ConfigurationClassParser.java //第252行 protected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { //省略部分代码 //获取所有的@ComponentScan注解 SetcomponentScans = AnnotationConfigUtils.attributesForRepeatable( sourceClass.getMetadata(), ComponentScans.class, ComponentScan.class); if (!componentScans.isEmpty() && !this.conditionEvaluator.shouldSkip(sourceClass.getMetadata(), ConfigurationPhase.REGISTER_BEAN)) { for (AnnotationAttributes componentScan : componentScans) { //根据@ComponentScan注解获取bean Set scannedBeanDefinitions = this.componentScanParser.parse(componentScan, sourceClass.getMetadata().getClassName()); for (BeanDefinitionHolder holder : scannedBeanDefinitions) { //判断扫描的bean中是否有配置类,有的话继续递归解析 if (ConfigurationClassUtils.checkConfigurationClassCandidate(holder.getBeanDefinition(), this.metadataReaderFactory)) { parse(holder.getBeanDefinition().getBeanClassName(), holder.getBeanName()); } } } } //省略部分代码 }
4、处理@Import注解,@Import作用是导入Java配置类
Spring Boot的@EnableAutoConfiguration注解也会在这里处理,所以如果你的自动配置类被@ComponentScan注解扫描到了,只会被当做普通的配置类,自动配置排序相关的注解(@AutoConfigureAfter等等)都是无效的
//ConfigurationClassParser.java //第252行 protected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { //省略部分代码 processImports(configClass, sourceClass, getImports(sourceClass), true); //省略部分代码 } //ConfigurationClassParser.java //第441行 private SetgetImports(SourceClass sourceClass) throws IOException { Set imports = new LinkedHashSet (); Set visited = new LinkedHashSet (); collectImports(sourceClass, imports, visited); return imports; } //ConfigurationClassParser.java //第461行 private void collectImports(SourceClass sourceClass, Set imports, Set visited) throws IOException { //visited保存所有处理过的类,防止重复处理 if (visited.add(sourceClass)) { //取sourceClass上的所有@Import注解,包括其他注解中的@Import注解 for (SourceClass annotation : sourceClass.getAnnotations()) { String annName = annotation.getMetadata().getClassName(); //这里不太懂为啥判断java开头 if (!annName.startsWith("java") && !annName.equals(Import.class.getName())) { collectImports(annotation, imports, visited); } } imports.addAll(sourceClass.getAnnotationAttributes(Import.class.getName(), "value")); } } //ConfigurationClassParser.java //第494行 private void processImports(ConfigurationClass configClass, SourceClass currentSourceClass, Collection importCandidates, boolean checkForCircularImports) throws IOException { if (importCandidates.isEmpty()) { return; } //校验是否存在循环依赖 if (checkForCircularImports && isChainedImportOnStack(configClass)) { this.problemReporter.error(new CircularImportProblem(configClass, this.importStack)); } else { this.importStack.push(configClass); try { for (SourceClass candidate : importCandidates) { if (candidate.isAssignable(ImportSelector.class)) { Class> candidateClass = candidate.loadClass(); ImportSelector selector = BeanUtils.instantiateClass(candidateClass, ImportSelector.class); ParserStrategyUtils.invokeAwareMethods( selector, this.environment, this.resourceLoader, this.registry); //如果是DeferredImportSelector接口,先暂存起来,在ConfigurationClassParser.parse(Set )方法的最后处理(即其他配置类加载完之后) if (this.deferredImportSelectors != null && selector instanceof DeferredImportSelector) { this.deferredImportSelectors.add( new DeferredImportSelectorHolder(configClass, (DeferredImportSelector) selector)); } //普通的ImportSelector接口直接递归处理 else { String[] importClassNames = selector.selectImports(currentSourceClass.getMetadata()); Collection importSourceClasses = asSourceClasses(importClassNames); processImports(configClass, currentSourceClass, importSourceClasses, false); } } //ImportBeanDefinitionRegistrar接口在ConfigurationClassParser.parse(Set )方法执行完毕后处理(即所有配置类加载完之后) else if (candidate.isAssignable(ImportBeanDefinitionRegistrar.class)) { Class> candidateClass = candidate.loadClass(); ImportBeanDefinitionRegistrar registrar = BeanUtils.instantiateClass(candidateClass, ImportBeanDefinitionRegistrar.class); ParserStrategyUtils.invokeAwareMethods( registrar, this.environment, this.resourceLoader, this.registry); configClass.addImportBeanDefinitionRegistrar(registrar, currentSourceClass.getMetadata()); } //既不是ImportSelector也不是ImportBeanDefinitionRegistrar,当做普通的@Configuration类处理 else { this.importStack.registerImport( currentSourceClass.getMetadata(), candidate.getMetadata().getClassName()); processConfigurationClass(candidate.asConfigClass(configClass)); } } } 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(); } } }
5、处理@ImportResource注解,@ImportResource作用是导入XML配置
//ConfigurationClassParser.java //第252行 protected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { //省略部分代码 if (sourceClass.getMetadata().isAnnotated(ImportResource.class.getName())) { AnnotationAttributes importResource = AnnotationConfigUtils.attributesFor(sourceClass.getMetadata(), ImportResource.class); String[] resources = importResource.getStringArray("locations"); Class extends BeanDefinitionReader> readerClass = importResource.getClass("reader"); for (String resource : resources) { String resolvedResource = this.environment.resolveRequiredPlaceholders(resource); //xml配置文件跟ImportBeanDefinitionRegistrar接口一样,也会暂存起来 //在ConfigurationClassParser.parse(Set)方法执行完毕后处理(即所有配置类加载完之后) configClass.addImportedResource(resolvedResource, readerClass); } } //省略部分代码 }
6、处理单独的@Bean方法
//ConfigurationClassParser.java //第252行 protected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { //省略部分代码 SetbeanMethods = sourceClass.getMetadata().getAnnotatedMethods(Bean.class.getName()); for (MethodMetadata methodMetadata : beanMethods) { //暂存起来,在ConfigurationClassParser.parse(Set )方法执行完毕后处理(即所有配置类加载完之后) configClass.addBeanMethod(new BeanMethod(methodMetadata, configClass)); } //省略部分代码 }
7、处理实现的接口中的default方法
//ConfigurationClassParser.java //第252行 protected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { //省略部分代码 processInterfaces(configClass, sourceClass); //省略部分代码 } //ConfigurationClassParser.java //第349行 private void processInterfaces(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { for (SourceClass ifc : sourceClass.getInterfaces()) { SetbeanMethods = ifc.getMetadata().getAnnotatedMethods(Bean.class.getName()); for (MethodMetadata methodMetadata : beanMethods) { if (!methodMetadata.isAbstract()) { //暂存起来,在ConfigurationClassParser.parse(Set )方法执行完毕后处理(即所有配置类加载完之后) configClass.addBeanMethod(new BeanMethod(methodMetadata, configClass)); } } //递归处理 processInterfaces(configClass, ifc); } }
8、处理父类中的方法
//ConfigurationClassParser.java //第252行 protected final SourceClass doProcessConfigurationClass(ConfigurationClass configClass, SourceClass sourceClass) throws IOException { //省略部分代码 if (sourceClass.getMetadata().hasSuperClass()) { String superclass = sourceClass.getMetadata().getSuperClassName(); if (!superclass.startsWith("java") && !this.knownSuperclasses.containsKey(superclass)) { this.knownSuperclasses.put(superclass, configClass); //如果存在符合条件的父类,返回它,然后继续解析 //doProcessConfigurationClass方法被调用的地方是一个while循环,只要不为null就会一直调用 return sourceClass.getSuperClass(); } } //省略部分代码 }
9、处理之前暂存的DeferredImportSelector接口
//ConfigurationClassParser.java //第166行 public void parse(SetconfigCandidates) { //省略部分代码 processDeferredImportSelectors(); } //ConfigurationClassParser.java //第473行 private void processDeferredImportSelectors() { List deferredImports = this.deferredImportSelectors; this.deferredImportSelectors = null; Collections.sort(deferredImports, DEFERRED_IMPORT_COMPARATOR); for (DeferredImportSelectorHolder deferredImport : deferredImports) { ConfigurationClass configClass = deferredImport.getConfigurationClass(); try { String[] imports = deferredImport.getImportSelector().selectImports(configClass.getMetadata()); processImports(configClass, asSourceClass(configClass), asSourceClasses(imports), false); } catch (BeanDefinitionStoreException ex) { throw ex; } catch (Throwable ex) { throw new BeanDefinitionStoreException("Failed to process import candidates for configuration class [" + configClass.getMetadata().getClassName() + "]", ex); } } }
10、加载xml配置文件、ImportBeanDefinitionRegistrar接口实现类以及标注了@Bean的方法
//ConfigurationClassPostProcessor.java //第273行 public void processConfigBeanDefinitions(BeanDefinitionRegistry registry) { //省略部分代码 this.reader.loadBeanDefinitions(configClasses); //省略部分代码 } //ConfigurationClassBeanDefinitionReader.java //第113行 public void loadBeanDefinitions(SetconfigurationModel) { TrackedConditionEvaluator trackedConditionEvaluator = new TrackedConditionEvaluator(); for (ConfigurationClass configClass : configurationModel) { loadBeanDefinitionsForConfigurationClass(configClass, trackedConditionEvaluator); } } //ConfigurationClassBeanDefinitionReader.java //第124行 private void loadBeanDefinitionsForConfigurationClass(ConfigurationClass configClass, TrackedConditionEvaluator trackedConditionEvaluator) { //省略部分代码 if (configClass.isImported()) { //将配置类自己也注册成一个bean registerBeanDefinitionForImportedConfigurationClass(configClass); } for (BeanMethod beanMethod : configClass.getBeanMethods()) { //将标记了@Bean的方法加载成bean loadBeanDefinitionsForBeanMethod(beanMethod); } //加载XML配置文件 loadBeanDefinitionsFromImportedResources(configClass.getImportedResources()); //加载ImportBeanDefinitionRegistrar接口的实现 loadBeanDefinitionsFromRegistrars(configClass.getImportBeanDefinitionRegistrars()); }
感谢各位的阅读,以上就是“Spring Boot配置类加载流程示例”的内容了,经过本文的学习后,相信大家对Spring Boot配置类加载流程示例这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流