Spring 中 BeanFactoryPostProcessor 接口的作用
admin
2024-03-25 15:08:01
0

BeanFactoryPostProcessor 作用

BeanFactoryPostProcessor 和该子类 BeanDefinitionRegistryPostProcessor 作用于 BeanDefinition 解析之后,Bean 实例化之前,所以我们可以在 BeanDefinition 定义好了之后做一些修改,从而影响 Bean 的实例化。

源码如下

BeanFactoryPostProcessor 类定义的方法中我们可以获取到 BeanFactory,有了这个工厂自然而然就可以干很多事情啦,比如去修改它的默认配置:

// 对 bean 工厂的进一步后置增强,这个接口会暴露出工厂,有了工厂自然而然就可以干很多事情啦
@FunctionalInterface
public interface BeanFactoryPostProcessor {void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException;}

比如我们去修改 BeanFactory 中的两个默认属性:是否允许循环依赖,是否允许 BeanDefinition 覆盖(当我们注解和 xml 同时存在并且 beanName 还是相同,是否支持 BeanDefinition 的覆盖)

@Component
public class MyConfigurationPostProcessor implements BeanDefinitionRegistryPostProcessor {@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {if (beanFactory instanceof DefaultListableBeanFactory) {DefaultListableBeanFactory defaultListableBeanFactory = (DefaultListableBeanFactory) beanFactory;defaultListableBeanFactory.setAllowCircularReferences(false);defaultListableBeanFactory.setAllowBeanDefinitionOverriding(false);}}
}

BeanDefinitionRegistryPostProcessor 类继承了 BeanFactoryPostProcessor 类,扩展了方法,让我们可以更轻松的获取到 BeanDefinitionRegistry 注册器,这样我们就可以利用这个类去额外注册一些其他的 BeanDefinition,也可以对 BeanDefinition 做一些删除、修改等操作

public interface BeanDefinitionRegistryPostProcessor extends BeanFactoryPostProcessor {void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException;
}

比如我们现在有一个实体类,但是没有标注 @Component 注解,那么肯定是不能被 @ComponentScan 扫描到的,此时我们可以通过这个方法就可以手动讲该实体交给 Spring 管理。

实体类如下:

public class ProcessorEntity {private String name = "ABC";public String getName() {return name;}public void setName(String name) {this.name = name;}
}

注意实体类没有标注 @Component 注解,并且属性默认值是 ABC,然后通过 BeanDefinitionRegistryPostProcessor 进行注册该实体类,并且还要修改属性的默认值,修改成"小明",如下:

@Component
public class MyConfigurationPostProcessor1 implements BeanDefinitionRegistryPostProcessor {@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {System.out.println("MyConfigurationPostProcessor1---postProcessBeanFactory");}@Overridepublic void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException {System.out.println("MyConfigurationPostProcessor1---postProcessBeanDefinitionRegistry");GenericBeanDefinition genericBeanDefinition = new GenericBeanDefinition();genericBeanDefinition.setBeanClass(ProcessorEntity.class);MutablePropertyValues propertyValues = genericBeanDefinition.getPropertyValues();// 修改 ProcessorEntity 类中 name 属性默认值propertyValues.addPropertyValue("name","小明");// 然后再将 BeanDefinition 注册到 BeanFactory 容器中registry.registerBeanDefinition("processorEntity",genericBeanDefinition);}
}

测试类如下:


public class TestBeanScanner {public static void main(String[] args) {ApplicationContext context = new AnnotationConfigApplicationContext(ScannerConfig.class);ProcessorEntity processorEntity = context.getBean("processorEntity", ProcessorEntity.class);System.out.println("processorEntity = " + processorEntity+",name="+processorEntity.getName());}
}

输出结果如下:

MyConfigurationPostProcessor1---postProcessBeanDefinitionRegistry
MyConfigurationPostProcessor1---postProcessBeanFactory
processorEntity = com.gwm.bean221207.processors.ProcessorEntity@346d61be,name=小明

发现也是可以获取到 ProcessorEntity 类的实例。

然后我们继续利用这个方法,来扫描我们自定义注解修饰的类。

自定义注解如下:

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MyServiceAnno {String value() default "";
}

实体类如下:

@MyServiceAnno
public class TestAnnoService {private String userName = "张老三";public String getUserName() {return userName;}public void setUserName(String userName) {this.userName = userName;}
}

然后借助 Spring 的包扫描器 ClassPathBeanDefinitionScanner 进行扫描,此时我们的 MyConfigurationPostProcessor1 就有点类似于简化版的 ConfigurationClassPostProcessor 后置处理器,都是在 postProcessBeanDefinitionRegistry() 方法中进行操作的,都实现了接口 BeanDefinitionRegistryPostProcessor ,只不过 Spring 提供内置的扫描功能比较全面,我们做的比较简陋而已,就只模拟扫描自定义注解,代码如下:

@Component
public class MyConfigurationPostProcessor1 implements BeanDefinitionRegistryPostProcessor {@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {System.out.println("MyConfigurationPostProcessor1---postProcessBeanFactory");}@Overridepublic void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException {System.out.println("MyConfigurationPostProcessor1---postProcessBeanDefinitionRegistry");GenericBeanDefinition genericBeanDefinition = new GenericBeanDefinition();genericBeanDefinition.setBeanClass(ProcessorEntity.class);MutablePropertyValues propertyValues = genericBeanDefinition.getPropertyValues();// 修改 ProcessorEntity 类中 name 属性默认值propertyValues.addPropertyValue("name","小明");// 然后再将 BeanDefinition 注册到 BeanFactory 容器中registry.registerBeanDefinition("processorEntity",genericBeanDefinition);// 直接把 Spring 的类路径扫描器拿过来用用ClassPathBeanDefinitionScanner scanner = new ClassPathBeanDefinitionScanner(registry);// 添加过滤条件:自定义的注解修饰的类scanner.addIncludeFilter(new AnnotationTypeFilter(MyServiceAnno.class));// 开始自动扫描然后封装 ScannedBeanDefinition,然后注册到容器scanner.scan("com.gwm.anno");}
}

输出结果如下:

MyConfigurationPostProcessor1---postProcessBeanDefinitionRegistry
MyConfigurationPostProcessor1---postProcessBeanFactory
testAnnoService = com.gwm.anno.TestAnnoService@747edf66,userName=张老三
processorEntity = com.gwm.bean221207.processors.ProcessorEntity@346d61be,name=小明

那么以上两个接口中的方法在哪里被调用呢,这里举例说明其中的一处调用。为了更好地展示效果,这里直接我们直接输出日志。

定义两个 Processor 都实现 BeanDefinitionRegistryPostProcessor 接口,代码如下:

@Component
public class MyConfigurationPostProcessor1 implements BeanDefinitionRegistryPostProcessor {@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {System.out.println("MyConfigurationPostProcessor1---postProcessBeanFactory");}@Overridepublic void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException {System.out.println("MyConfigurationPostProcessor1---postProcessBeanDefinitionRegistry");}
}
@Component
public class MyConfigurationPostProcessor2 implements BeanDefinitionRegistryPostProcessor {@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {System.out.println("MyConfigurationPostProcessor2---postProcessBeanFactory");}@Overridepublic void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException {System.out.println("MyConfigurationPostProcessor2---postProcessBeanDefinitionRegistry");}
}

输出结果:

MyConfigurationPostProcessor2---postProcessBeanDefinitionRegistry
MyConfigurationPostProcessor1---postProcessBeanDefinitionRegistry
MyConfigurationPostProcessor2---postProcessBeanFactory
MyConfigurationPostProcessor1---postProcessBeanFactory

debug 跟踪源码,发现调用的地方在下面这段代码中,源码如下:

public static void invokeBeanFactoryPostProcessors(ConfigurableListableBeanFactory beanFactory, List beanFactoryPostProcessors) {// 因为第一过来的时候 TODO beanFactoryPostProcessors 这个变量不知道什么时候才会传入值,目前看是空集合,有待调试Set processedBeans = new HashSet<>();// beanFactory 实现了 BeanDefinitionRegistry 注册接口,所以这里条件成立if (beanFactory instanceof BeanDefinitionRegistry) {BeanDefinitionRegistry registry = (BeanDefinitionRegistry) beanFactory;List regularPostProcessors = new ArrayList<>();List registryProcessors = new ArrayList<>();for (BeanFactoryPostProcessor postProcessor : beanFactoryPostProcessors) {if (postProcessor instanceof BeanDefinitionRegistryPostProcessor) {BeanDefinitionRegistryPostProcessor registryProcessor =(BeanDefinitionRegistryPostProcessor) postProcessor;registryProcessor.postProcessBeanDefinitionRegistry(registry);registryProcessors.add(registryProcessor);}else {regularPostProcessors.add(postProcessor);}}List currentRegistryProcessors = new ArrayList<>();/*** 获取所有实现了 BeanDefinitionRegistryPostProcessor 接口的子类* 并且判断是否还实现了 PriorityOrdered 权重接口,如果实现了则优先回调该类的 postProcessBeanDefinitionRegistry() 方法* 目前看如果是以注解方式启动,Spring 其中有一个内置类实现了该接口,就是 ConfigurationClassPostProcessor 该配置类是在* 外面的 this() 构造函数中直接把 BeanDefinition 注册到了 BeanDefinitionMap 容器中,其中还有 @AutowiredPostProcessor* 所以这里优先调用的是这个扫描后置处理类的方法,然后去调用 doScan() 扫描其他组件* 所以下面如果在重新调用这个 getBeanNamesForType() 方法,可能就会多出很多的子类了* 因为 ConfigurationClassPostProcessor 后之类已经把所有的类扫描进来了*/String[] postProcessorNames =beanFactory.getBeanNamesForType(BeanDefinitionRegistryPostProcessor.class, true, false);for (String ppName : postProcessorNames) {// 是否实现了 PriorityOrdered 排序接口if (beanFactory.isTypeMatch(ppName, PriorityOrdered.class)) {// 调用 getBean() 直接实例化这个子类currentRegistryProcessors.add(beanFactory.getBean(ppName, BeanDefinitionRegistryPostProcessor.class));// 记录一下当前已经执行过的 Processor,避免重复调用processedBeans.add(ppName);}}sortPostProcessors(currentRegistryProcessors, beanFactory);registryProcessors.addAll(currentRegistryProcessors);/*** 循环回调 BeanDefinitionRegistryPostProcessor 所有实现子类的方法* 目前这里看只会回调到 ConfigurationClassPostProcessor 子类中的方法* 这个类回调到 doScan() 扫描其他组件,然后注册到 BeanDefinitionMap 容器中,所以下面在执行 getBeanNamesForType()* 方法时肯定会多出很多 BeanDefinitionRegistryPostProcessor 的子类实现*/invokeBeanDefinitionRegistryPostProcessors(currentRegistryProcessors, registry, beanFactory.getApplicationStartup());currentRegistryProcessors.clear();/*** 再次去检索一下 BeanDefinitionRegistryPostProcessor 接口的实现子类,此时应该是会更多或者是一样* 此时如果我们扩展了这个接口,比较交给了 Spring 管理,那么这里肯定是能够扫描出来的* 如果还实现了 Ordered 接口的话,那么下面这段代码就会会调用方法 postProcessBeanDefinitionRegistry()*/postProcessorNames = beanFactory.getBeanNamesForType(BeanDefinitionRegistryPostProcessor.class, true, false);for (String ppName : postProcessorNames) {// 是否实现了 Ordered 排序接口if (!processedBeans.contains(ppName) && beanFactory.isTypeMatch(ppName, Ordered.class)) {// 调用 getBean() 直接实例化这个子类currentRegistryProcessors.add(beanFactory.getBean(ppName, BeanDefinitionRegistryPostProcessor.class));// 记录一下当前已经执行过的 Processor,避免重复调用processedBeans.add(ppName);}}sortPostProcessors(currentRegistryProcessors, beanFactory);registryProcessors.addAll(currentRegistryProcessors);/*** 执行过的就不会再回调了,因为 processedBeans 标记好了哪些执行过的,这里会回调我们自己扩展的 Processor 子类*/invokeBeanDefinitionRegistryPostProcessors(currentRegistryProcessors, registry, beanFactory.getApplicationStartup());currentRegistryProcessors.clear();/*** 最后,再次检索 BeanDefinitionRegistryPostProcessor,然后处理没有实现 PriorityOrdered、Ordered 接口的子类实现*/boolean reiterate = true;while (reiterate) {reiterate = false;postProcessorNames = beanFactory.getBeanNamesForType(BeanDefinitionRegistryPostProcessor.class, true, false);for (String ppName : postProcessorNames) {if (!processedBeans.contains(ppName)) {/*** 此处会通过 getBean() 去创建好这个后置处理器 Bean*/currentRegistryProcessors.add(beanFactory.getBean(ppName, BeanDefinitionRegistryPostProcessor.class));processedBeans.add(ppName);reiterate = true;}}sortPostProcessors(currentRegistryProcessors, beanFactory);registryProcessors.addAll(currentRegistryProcessors);/** 调用 postProcessBeanDefinitionRegistry() 方法 */invokeBeanDefinitionRegistryPostProcessors(currentRegistryProcessors, registry, beanFactory.getApplicationStartup());currentRegistryProcessors.clear();}/*** 上面一大段逻辑都是去调用 BeanDefinitionRegistryPostProcessor 类子类的 postProcessBeanDefinitionRegistry()* 的注册方法。* 最后在调用 BeanDefinitionRegistryPostProcessor 从父类继承过来的 postProcessBeanFactory() 方法*/invokeBeanFactoryPostProcessors(registryProcessors, beanFactory);/*** 一般这里是没有值的,无需注重* 调用从入参中传入过来的 BeanDefinitionRegistryPostProcessor 对象的方法*/invokeBeanFactoryPostProcessors(regularPostProcessors, beanFactory);}else {// TODO 这个应该是测试代码,只有一个地方调用了,就是 TestinvokeBeanFactoryPostProcessors(beanFactoryPostProcessors, beanFactory);}//=========================================================================================// 这下面的逻辑全部都是调用 BeanFactoryPostProcessor 的 postProcessBeanFactory() 方法//=========================================================================================/** 获取到所有的  BeanFactoryPostProcessor beaFactory后置处理器*/String[] postProcessorNames =beanFactory.getBeanNamesForType(BeanFactoryPostProcessor.class, true, false);List priorityOrderedPostProcessors = new ArrayList<>();List orderedPostProcessorNames = new ArrayList<>();List nonOrderedPostProcessorNames = new ArrayList<>();for (String ppName : postProcessorNames) {/*** processedBeans 如果是执行过的 bean 后置处理器,就直接跳过 skip 不再处理* 注意虽然代码会走到这些面,但是因为这里的 processedBeans 会拦截处理过的 BeanFactoryPostProcessor* 这个细节注意哟**/if (processedBeans.contains(ppName)) {// ...do nothing...}// 判断你是否实现了 PriorityOrdered 接口,实现这个接口可以将后置处理进行排序执行// 其中 Ordered 数值越小优先级越高else if (beanFactory.isTypeMatch(ppName, PriorityOrdered.class)) {priorityOrderedPostProcessors.add(beanFactory.getBean(ppName, BeanFactoryPostProcessor.class));}// 判断你是否实现了注解方式的优先级,和 PriorityOrdered 接口功能是一样的else if (beanFactory.isTypeMatch(ppName, Ordered.class)) {orderedPostProcessorNames.add(ppName);}else {// 就上述两种处理器,其他的都是普通的 bean 工厂后置处理器nonOrderedPostProcessorNames.add(ppName);}}// gwm_tag: 最先调用实现了 PriorityOrdered 接口的 beanFactoryPostProcessor 处理器// 处理器进行排序sortPostProcessors(priorityOrderedPostProcessors, beanFactory);// 开始调用实现了 PriorityOrdered 接口的 bean 工厂处理器的 postProcessBeanFactory() 方法invokeBeanFactoryPostProcessors(priorityOrderedPostProcessors, beanFactory);List orderedPostProcessors = new ArrayList<>(orderedPostProcessorNames.size());for (String postProcessorName : orderedPostProcessorNames) {orderedPostProcessors.add(beanFactory.getBean(postProcessorName, BeanFactoryPostProcessor.class));}// 处理器进行排序sortPostProcessors(orderedPostProcessors, beanFactory);// gwm_tag: 第二调用实现了 Ordered 注解的 bean 工厂后置处理器的 postProcessBeanFactory() 方法invokeBeanFactoryPostProcessors(orderedPostProcessors, beanFactory);List nonOrderedPostProcessors = new ArrayList<>(nonOrderedPostProcessorNames.size());for (String postProcessorName : nonOrderedPostProcessorNames) {nonOrderedPostProcessors.add(beanFactory.getBean(postProcessorName, BeanFactoryPostProcessor.class));}// gwm_tag: 最后才是调用普通的 bean 工厂后置处理器的 postProcessBeanFactory() 方法invokeBeanFactoryPostProcessors(nonOrderedPostProcessors, beanFactory);// 最后清空缓存就是这个 Map 而已: Map mergedBeanDefinitionHolders = new ConcurrentHashMap<>(256)beanFactory.clearMetadataCache();}

这里特别注意一点,优先级问题,因为我们平时可能扩展的 BeanFactoryPostProcessor 不止一个,所以这里就需要分优先级执行,优先级可以通过 PriorityOrdered 和 Ordered 方法定义优先级。

相关内容

热门资讯

贷款也“拼团” 银行抢单忙 购物能“拼团”,贷款也能! 近日,一场“拼团融资”的银企对接活动在省工业和信息化厅拉开帷幕。 “贷款...
逛花展、赶市集、嗨直播!202... 5月23日 “2026北京直播电商购物月” 在丰台区丽泽金融商务区·2026北京国际花展 正式拉开帷...
2026中关村毕业季|AI“吃... “上帝会掷骰子吗?” 在联想未来中心的“与智者同场”展区,一位海淀学子对着屏幕问道。 爱因斯坦微微前...
原创 今... 今日为5月23日,国际现货黄金价格在4500美元/盎司整数关口附近徘徊不前,日内最低触及4480美元...
三连亏后变为“无主”状态,农尚... 从吴亮手中接盘农尚环境(300536)不足三年后,林峰如今让出了公司控制权,上市公司进入“无主”状态...
55岁湖南女首富出手!豪掷13... 快科技5月24日消息,与马斯克、库克并肩而坐,刚参加完国宴的湖南女首富周群飞就买了家上市企业。 近日...
外资加仓A股,岂是跟风这么简单... 熬过忙碌的交易日,在周末安静时段,理清接下来布局方向。本篇为大家准备了5条要闻,涵盖市场动态、行业变...
原创 俄... 在全球能源的残酷牌桌上,手里攥着石油,腰杆子才能硬气。长期以来,中东的沙漠、俄罗斯的冰原、美国的页岩...
喜力啤酒有产品将涨价,华润啤酒... 来源:红星新闻 红星资本局5月22日消息,今日,红星资本局从雪花啤酒(厦门)有限公司、华润啤酒方面获...
原创 金... 心理预期调整刻不容缓,五月二十二日,黄金价格或将重现十五年前的历史性低迷。 近期若您密切关注着黄金市...
原创 马... 埃隆·马斯克如果能让SpaceX实现“科幻小说”级别的目标,他可能获得1万亿美元的收入。 埃隆·马斯...
涨涨涨!放开限制、可加杠杆!这... 韩国股市站在风口上! 据最新消息,为吸引更多海外资金进入股市,韩国政府计划放开限制,允许境外投资者直...
下周9家上会丨科创板首单IPO... IPO及再融资上会预告 据交易所官网审核动态信息,下周(5.25-5.29)IPO上会审核6家企业,...
富途、老虎市值蒸发1/4!或被... 来源:金融时报 5月22日,中国证监会宣布依法对Tiger Brokers (NZ) Limited...
马爸爸的好兄弟钱多多搞了杀猪盘... *此图由AI生成 作者| 史大郎&猫哥 来源| 是史大郎&大猫财经Pro 上周四,港股经纬天地大崩盘...
原创 壳... 编辑:XL 国际能源圈最近炸开了锅,壳牌这家百年石油巨头在2026年3月与委内瑞拉政府正式签署多项油...
存储热潮愈演愈烈!奖金拿到手软... 财联社5月24日讯(编辑 卞纯)在席卷全球的存储芯片热潮中,韩国“存储芯片双雄”SK海力士和三星无疑...
揽牌、合作、生态,跨境支付头部... 近日,国内头部跨境支付机构密集落地海外重要布局,一方面,连连数字、PingPong两家公司相继在中东...
原创 帮... 老铁们,周末好!我是帮主郑重。刚扫了一眼下周的财经日历,好家伙,事件一个接一个,堪称“消息面轰炸周”...
海南省住建厅与中国石化海南石油... 5月22日,中国石化海南石油分公司代表、党委书记李新强、总经理蔡文东一行赴海南省住建厅拜访交流。省住...