流程图解Spring Framework(五) Spring BeanFactoryPostProcessor如何工作的?

本文主要是介绍流程图解Spring Framework(五) Spring BeanFactoryPostProcessor如何工作的?,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

BeanPostProcessor这个概念可以认为是在spring声明周期中留下的一个钩子,这个钩子是在所有的BeanDefinition被扫描完成之后这个阶段的。我们可以在这里做很多事情,Spring框架里面很多特性也利用了这里,比如属性注入

具体在 查看详细信息

BeanFactoryPostProcessor的定义

在Spring框架设计之中,我们可以看到优秀的设计之处,最为精妙的就是扩展点的设置,这样使我们对Spring的扩展,很多时候只需要继承一个类,把它注册为一个Bean即可。

BeanFactoryPostProcessor从字面的意思上是BeanFactory的后置处理器。也可以认为是在spring生命周期中留下的一个钩子,这个钩子是在所有的BeanDefinition被扫描完成之后这个阶段的。但是在Spring中是这样描述这个扩展点的作用的,

Allows for custom modification of an application context’s bean definitions,
adapting the bean property values of the context’s underlying bean factory`

翻译过来大致是下面个意思

这个扩展点允许修改应用程序上下文(ApplicationContext)中的BeanDefinition,以及bean的属性值。

BeanFactoryPostProcessor 的执行优先级

因为BeanFactoryPostProcessor是一个扩展点,所以当有多个Bean实现这个扩展点的时候,必回存在一个执行顺序的问题,那么Spring是如何设计的呢?

`

1.执行BeanDefinitionRegistryPostProcessor接口的后置处理器

  • 执行通过配置的BeanDefinitionRegistry后置处理器,执行顺序是PriorityOrdered(排序是按照从小到大排)-> Ordered -> 普通的

  • 执行硬编码的BeanDefinitionRegistryPostProcessor

2.执行普通的BeanFactoryPostProcessor

  • 执行硬编码的后置处理器

  • 执行通过配置注册的处理器,执行顺序是PriorityOrdered(排序是按照从小到大排)->Ordered->普通的

在这一节可以看到后置处理器的执行顺序,应该大家都有一个疑惑,这么优秀的东西是如何实现的呢?
不仅大胆的想想,无非就是会把所有的实现这个扩展点的Bean都找出来,然后排序,最后执行,那么Spring是不是这样做的呢?

BeanFactoryPostProcessor的源码阅读

接口定义

在Spring框架中的接口定义如下

public interface BeanFactoryPostProcessor {// 上下文中的BeanFactoryvoid postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException;}

执行逻辑

Spring容器的启动入口

AbstractApplicationContext#refresh 的第三步invokeBeanFactoryPostProcessors

public void refresh() throws BeansException, IllegalStateException {synchronized (this.startupShutdownMonitor) {prepareRefresh();ConfigurableListableBeanFactory beanFactory = obtainFreshBeanFactory();prepareBeanFactory(beanFactory);try {postProcessBeanFactory(beanFactory);// 执行上下文中注册的Bean工厂后置处理器invokeBeanFactoryPostProcessors(beanFactory);...}}
public static void invokeBeanFactoryPostProcessors(ConfigurableListableBeanFactory beanFactory, List<BeanFactoryPostProcessor> beanFactoryPostProcessors) {//// 1. 首先执行 BeanDefinitionRegistryPostProcessors (优秀的BeanFactoryPostProcessor)//Set<String> processedBeans = new HashSet<String>();// 1.0 如果beanFactory是BeanDefinitionRegistry类型的,也就是说BeanFactory中允许对BeanDefinition进行增删改的操作if (beanFactory instanceof BeanDefinitionRegistry) {BeanDefinitionRegistry registry = (BeanDefinitionRegistry) beanFactory;// 1.1 先执行硬编码的BeanDefinitionRegistryPostProcessorList<BeanFactoryPostProcessor> regularPostProcessors = new LinkedList<BeanFactoryPostProcessor>();List<BeanDefinitionRegistryPostProcessor> registryPostProcessors =new LinkedList<BeanDefinitionRegistryPostProcessor>();for (BeanFactoryPostProcessor postProcessor : beanFactoryPostProcessors) {if (postProcessor instanceof BeanDefinitionRegistryPostProcessor) {BeanDefinitionRegistryPostProcessor registryPostProcessor =(BeanDefinitionRegistryPostProcessor) postProcessor;registryPostProcessor.postProcessBeanDefinitionRegistry(registry);registryPostProcessors.add(registryPostProcessor);}else {regularPostProcessors.add(postProcessor);}}String[] postProcessorNames =beanFactory.getBeanNamesForType(BeanDefinitionRegistryPostProcessor.class, true, false);// 1.2 首先执行实现PriorityOrdered接口的BeanDefinitionRegistryPostProcessorList<BeanDefinitionRegistryPostProcessor> priorityOrderedPostProcessors = new ArrayList<BeanDefinitionRegistryPostProcessor>();for (String ppName : postProcessorNames) {if (beanFactory.isTypeMatch(ppName, PriorityOrdered.class)) {priorityOrderedPostProcessors.add(beanFactory.getBean(ppName, BeanDefinitionRegistryPostProcessor.class));processedBeans.add(ppName);}}sortPostProcessors(beanFactory, priorityOrderedPostProcessors);registryPostProcessors.addAll(priorityOrderedPostProcessors);invokeBeanDefinitionRegistryPostProcessors(priorityOrderedPostProcessors, registry);// 1.3 接下来执行实现Ordered接口的BeanDefinitionRegistryPostProcessorspostProcessorNames = beanFactory.getBeanNamesForType(BeanDefinitionRegistryPostProcessor.class, true, false);List<BeanDefinitionRegistryPostProcessor> orderedPostProcessors = new ArrayList<BeanDefinitionRegistryPostProcessor>();for (String ppName : postProcessorNames) {if (!processedBeans.contains(ppName) && beanFactory.isTypeMatch(ppName, Ordered.class)) {orderedPostProcessors.add(beanFactory.getBean(ppName, BeanDefinitionRegistryPostProcessor.class));processedBeans.add(ppName);}}// 排序sortPostProcessors(beanFactory, orderedPostProcessors);registryPostProcessors.addAll(orderedPostProcessors);invokeBeanDefinitionRegistryPostProcessors(orderedPostProcessors, registry);//  1.4 执行其它的硬编码的的BeanDefinitionRegistryPostProcessorsboolean reiterate = true;while (reiterate) {reiterate = false;postProcessorNames = beanFactory.getBeanNamesForType(BeanDefinitionRegistryPostProcessor.class, true, false);for (String ppName : postProcessorNames) {if (!processedBeans.contains(ppName)) {BeanDefinitionRegistryPostProcessor pp = beanFactory.getBean(ppName, BeanDefinitionRegistryPostProcessor.class);registryPostProcessors.add(pp);processedBeans.add(ppName);pp.postProcessBeanDefinitionRegistry(registry);reiterate = true;}}}// 执行invokeBeanFactoryPostProcessors(registryPostProcessors, beanFactory);invokeBeanFactoryPostProcessors(regularPostProcessors, beanFactory);}else {// Invoke factory processors registered with the context instance.invokeBeanFactoryPostProcessors(beanFactoryPostProcessors, beanFactory);}//// 2. 执行 BeanFactoryPostProcessor //String[] postProcessorNames =beanFactory.getBeanNamesForType(BeanFactoryPostProcessor.class, true, false);// 2.1 将后置处理器根据不同类型(PriorityOrdered、Ordered、其它)分组List<BeanFactoryPostProcessor> priorityOrderedPostProcessors = new ArrayList<BeanFactoryPostProcessor>();List<String> orderedPostProcessorNames = new ArrayList<String>();List<String> nonOrderedPostProcessorNames = new ArrayList<String>();for (String ppName : postProcessorNames) {if (processedBeans.contains(ppName)) {// skip - already processed in first phase above}else if (beanFactory.isTypeMatch(ppName, PriorityOrdered.class)) {priorityOrderedPostProcessors.add(beanFactory.getBean(ppName, BeanFactoryPostProcessor.class));}else if (beanFactory.isTypeMatch(ppName, Ordered.class)) {orderedPostProcessorNames.add(ppName);}else {nonOrderedPostProcessorNames.add(ppName);}}// 2.2 首先执行优先级Order类型的后置处理器sortPostProcessors(beanFactory, priorityOrderedPostProcessors);invokeBeanFactoryPostProcessors(priorityOrderedPostProcessors, beanFactory);// 2.3 执行带有Order接口的后置处理器List<BeanFactoryPostProcessor> orderedPostProcessors = new ArrayList<BeanFactoryPostProcessor>();for (String postProcessorName : orderedPostProcessorNames) {orderedPostProcessors.add(beanFactory.getBean(postProcessorName, BeanFactoryPostProcessor.class));}sortPostProcessors(beanFactory, orderedPostProcessors);invokeBeanFactoryPostProcessors(orderedPostProcessors, beanFactory);// 2.4 执行其它的所有后置处理器List<BeanFactoryPostProcessor> nonOrderedPostProcessors = new ArrayList<BeanFactoryPostProcessor>();for (String postProcessorName : nonOrderedPostProcessorNames) {nonOrderedPostProcessors.add(beanFactory.getBean(postProcessorName, BeanFactoryPostProcessor.class));}invokeBeanFactoryPostProcessors(nonOrderedPostProcessors, beanFactory);// 清空元数据cache,因为beandefine有可能会变beanFactory.clearMetadataCache();}

BeanFactoryPostProcessor 在Spring中的应用

在Spring中,有很多的框架类实现了这个类并且做了一些事情。。
在这里插入图片描述

上图是一个只依赖spring-boot-starter-web的空工程中所有的BeanFactoryPostProcessor实现,可以看到有以下扩展点

  • PropertyResourceConfigurer。配合上PlaceholderResolvingStringValueResolver,为@Value注解提供支持
  • BeanDefinitionRegistryPostProcessor,这个比如Dubbo中的Reference和Service就是通过这个接口在Spring容器中注册为Bean 的,比较适用于一些框架添加自定义的Bean的场景。
  • CustomScopeConfigurer(自定义的Scope处理)
  • ServletComponentRegisteringPostProcessor(自动扫描Servlet的三剑客)
  • DeprecatedBeanWarner(在Bean上面添加一个过期的标志,有意思)
  • AbstractDependsOnBeanFactoryPostProcessor(用于动态声明特定类型的所有bean应该依赖于一个或多个特定bean。,应用场景比如在一些框架上,有一些Bean进行初始化之前必须等待一些连接类Bean准备好,如这里面的MongoClient,MongoClientFactoryBean)
  • CustomAutowireConfigurer,自定义Qualifier类型,和@Qualifier一个意思
  • ConfigurationBeanFactoryMetaData 在bean工厂初始化期间记住Bean定义元数据的一个工具类。保存了工厂方法名称和工厂Bean的名称,可以后续根据beanName

BeanFactoryPostProcessor 小例子

  1. 使用BeanFactoryPostProcessor注册一个bean
@Component
public class RegisteBeanBeanDefinitionRegistry implements BeanDefinitionRegistryPostProcessor,Ordered {@Overridepublic void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException {RootBeanDefinition rbd = new RootBeanDefinition();rbd.setTargetType(User.class);rbd.setBeanClass(User.class);registry.registerBeanDefinition("user-wuhulala", rbd);}@Overridepublic int getOrder() {return 0;}@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {// do nothing}
}
  1. 使用BeanFactoryPostProcessor丰富Bean的属性
public class ModifyBeanBeanFactoryPostProcessor implements BeanFactoryPostProcessor,Ordered {@Overridepublic int getOrder() {return 0;}@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {RootBeanDefinition bd = (RootBeanDefinition) beanFactory.getBeanDefinition("user-wuhulala");MutablePropertyValues values = new MutablePropertyValues();values.addPropertyValue("name", "wuhulala");values.addPropertyValue("age", 21);Address address = new Address();address.setName("浙江省");values.addPropertyValue("address", address);bd.setPropertyValues(values);}
}

使用BeanFactoryPostProcessor注意点

  1. 如果使用BeanDefinitionRegistry接口,那么应该是对当前IOC容器的Bean的一种补充或删除。
  2. BeanFactoryPostProcessor可以操作BeanDefinition,但永远不要与bean实例交互。也就是不要在这里进行Bean的实例化。 因为在这里实例化的话会过早,违反了容器的设计规则并有可能会导致意外的副作用。比如这里初始化的Bean依赖于其它的Bean,就会导致这个链路上的Bean都进行了初始化,从而导致它依赖Bean没有被BeanFactoryPostProcessor处理过对应的BeanDefinition。如果需要bean实例交互,可以实现另一个扩展点 BeanPostProcessor。
  3. 在BeanFactoryPostProcessor不要进行Bean的注册。

聊聊设计

Spring扩展点在Spring核心中是很重要的概念,spring本身就内置了很多实现。如果我们需要扩展Spring的功能,他们是很好的方式。并且它们可以像插件一样很好的工作。

在我们日常进行程序的设计编码时候,当一处进行多次的修改(添加、删除、修改细节)的时候,我们也可以尝试着抽取出一个扩展点,这样会使我们的程序变得极为简单。

比如我最近在做的一个项目流程,其实在项目新增之前和之后都需要进行很多的逻辑处理,比如调用远程服务、参数校验、后置处理,并且需求变动很频繁,那么现在依葫芦画瓢,把项目流程分为新增前、新增、新增后三个逻辑,抽象出preAddProcessor/postAddProcessor两个接口,最后用一段通用逻辑进行拼接,如有兴趣,可私聊。

这篇关于流程图解Spring Framework(五) Spring BeanFactoryPostProcessor如何工作的?的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1113919

相关文章

JavaScript中的isTrusted属性及其应用场景详解

《JavaScript中的isTrusted属性及其应用场景详解》在现代Web开发中,JavaScript是构建交互式应用的核心语言,随着前端技术的不断发展,开发者需要处理越来越多的复杂场景,例如事件... 目录引言一、问题背景二、isTrusted 属性的来源与作用1. isTrusted 的定义2. 为

Java循环创建对象内存溢出的解决方法

《Java循环创建对象内存溢出的解决方法》在Java中,如果在循环中不当地创建大量对象而不及时释放内存,很容易导致内存溢出(OutOfMemoryError),所以本文给大家介绍了Java循环创建对象... 目录问题1. 解决方案2. 示例代码2.1 原始版本(可能导致内存溢出)2.2 修改后的版本问题在

Java CompletableFuture如何实现超时功能

《JavaCompletableFuture如何实现超时功能》:本文主要介绍实现超时功能的基本思路以及CompletableFuture(之后简称CF)是如何通过代码实现超时功能的,需要的... 目录基本思路CompletableFuture 的实现1. 基本实现流程2. 静态条件分析3. 内存泄露 bug

Java中Object类的常用方法小结

《Java中Object类的常用方法小结》JavaObject类是所有类的父类,位于java.lang包中,本文为大家整理了一些Object类的常用方法,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. public boolean equals(Object obj)2. public int ha

SpringBoot项目中Maven剔除无用Jar引用的最佳实践

《SpringBoot项目中Maven剔除无用Jar引用的最佳实践》在SpringBoot项目开发中,Maven是最常用的构建工具之一,通过Maven,我们可以轻松地管理项目所需的依赖,而,... 目录1、引言2、Maven 依赖管理的基础概念2.1 什么是 Maven 依赖2.2 Maven 的依赖传递机

SpringBoot实现动态插拔的AOP的完整案例

《SpringBoot实现动态插拔的AOP的完整案例》在现代软件开发中,面向切面编程(AOP)是一种非常重要的技术,能够有效实现日志记录、安全控制、性能监控等横切关注点的分离,在传统的AOP实现中,切... 目录引言一、AOP 概述1.1 什么是 AOP1.2 AOP 的典型应用场景1.3 为什么需要动态插

Java实现Excel与HTML互转

《Java实现Excel与HTML互转》Excel是一种电子表格格式,而HTM则是一种用于创建网页的标记语言,虽然两者在用途上存在差异,但有时我们需要将数据从一种格式转换为另一种格式,下面我们就来看看... Excel是一种电子表格格式,广泛用于数据处理和分析,而HTM则是一种用于创建网页的标记语言。虽然两

java图像识别工具类(ImageRecognitionUtils)使用实例详解

《java图像识别工具类(ImageRecognitionUtils)使用实例详解》:本文主要介绍如何在Java中使用OpenCV进行图像识别,包括图像加载、预处理、分类、人脸检测和特征提取等步骤... 目录前言1. 图像识别的背景与作用2. 设计目标3. 项目依赖4. 设计与实现 ImageRecogni

Java中Springboot集成Kafka实现消息发送和接收功能

《Java中Springboot集成Kafka实现消息发送和接收功能》Kafka是一个高吞吐量的分布式发布-订阅消息系统,主要用于处理大规模数据流,它由生产者、消费者、主题、分区和代理等组件构成,Ka... 目录一、Kafka 简介二、Kafka 功能三、POM依赖四、配置文件五、生产者六、消费者一、Kaf

Java访问修饰符public、private、protected及默认访问权限详解

《Java访问修饰符public、private、protected及默认访问权限详解》:本文主要介绍Java访问修饰符public、private、protected及默认访问权限的相关资料,每... 目录前言1. public 访问修饰符特点:示例:适用场景:2. private 访问修饰符特点:示例: