SpringIOC容器初始化源码解析(1)—— PostProcessor

本文阅读 4 分钟
首页 代码,Java 正文

PostProcessor本身也是一种需要注册到容器里的Bean:

  • 其里面的方法会在特定的时机被容器调用
  • 实现不改变容器或者Bean核心逻辑的情况下对Bean进行扩展
  • 对Bean进行包装,影响其行为、修改Bean的内容等

大类分为容器级别的后置处理器以及Bean级别的后置处理器:

  • BeanDefinitionRegistryPostProcessor
  • BeanFactoryPostProcessor
  • BeanPostProcessor

  允许在正常的BeanFactoryPostProcessor检测开始之前注册更多的自定义beandefinition,所以可以编写一个实现类去实现BeanDefinitionRegistryPostProcessor接口,来往容器里注册额外的BeanDefinition实例

  之前在分析资源定位、加载、解析、注册链路时,AbstractApplicationContext的refresh()方法中调用了invokeBeanFactoryPostProcessors(beanFactory);,去执行容器级别的后置处理器 img 这个接口继承了BeanFactoryPostProcessor,所以也是一种特殊的BeanFactoryPostProcessor。里面有唯一一个方法,需要在方法体里创建出BeanDefinition实例,然后通过传入的registry将BeanDefinition注册到Registry对象里。

  顺着上面的思路,可以新建一个postprocessor包,并创建一个自定义的类,实现BeanDefinitionRegistryPostProcessor。

package com.wjw.postprocessor;

import com.wjw.entity.User;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor;
import org.springframework.beans.factory.support.GenericBeanDefinition;
import org.springframework.context.annotation.Configuration;

@Configuration
public class CustomizedBeanDefinitionRegistryPostProcessor implements BeanDefinitionRegistryPostProcessor { 
   @Override
   public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException { 
      Class<?> clazz = User.class;
      // 用于创建BeanDefinition实例
      BeanDefinitionBuilder builder =BeanDefinitionBuilder.genericBeanDefinition(clazz);
      // 创建BeanDefinition实例
      GenericBeanDefinition definition = (GenericBeanDefinition) builder.getRawBeanDefinition();
      registry.registerBeanDefinition("user5", definition);
   }

   @Override
   public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException { 

   }
}

之后在程序入口尝试获取这个名为user5的bean img img 我们可以在这个后置处理器中去加载第三方bean以复用他们的能力(Mybatis)

  既然BeanDefinitionRegistryPostProcessor负责对BeanDefinition实例的自定义注册,剩下的两个后置处理的作用主要就是影响容器里的行为了。

img   该接口也是只有一个方法,该方法是在refresh()方法中的invokeBeanFactoryPostProcessors方法中被执行的。

package org.springframework.beans.factory.config;

import org.springframework.beans.BeansException;
import org.springframework.lang.Nullable;

public interface BeanPostProcessor { 

   @Nullable
   default Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException { 
      return bean;
   }

   @Nullable
   default Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException { 
      return bean;
   }

}

该接口由两个回调方法组成,对于用容器创建的bean实例,BeanPostProcessor都会在调用容器初始化之前以及在任何bean初始化回调之后,都从容器获得回调执行,对应的就是上面两个方法。

例子:

package com.wjw.postprocessor;

import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanPostProcessor;
import org.springframework.context.annotation.Configuration;

@Configuration
public class CustomizedBeanPostProcessor implements BeanPostProcessor { 
   public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException{ 
      System.out.println(beanName + "----- postProcessBeforeInitialization() ");
      return bean;
   }
   public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException{ 
      System.out.println(beanName + "----- postProcessAfterInitialization() ");
      return bean;
   }
}

img

  可以使用BeanPostProcessor的能力来实现对bean的包装,即在bean创建出来之后也就是postProcessAfterInitialization方法里对bean包装上一些通用的逻辑,比如统一去做一些耗时相关的日志统计,增强了行为之后,再将bean返回。

容器如何及时调用后置处理器中的方法来处理? 回到之前的refresh方法的invokeBeanFactoryPostProcessors方法里,进入到

PostProcessorRegistrationDelegate.invokeBeanFactoryPostProcessors(beanFactory, getBeanFactoryPostProcessors());

进行分析即可。

由于容器支持多个PostProcessor的注册,所以执行的时候要按照优先级来区分,这也是先前按照priorityOrder和Order区分的原因,在逐个执行这些postprocessor的时候,采用了设计模式里面的责任链模式

private static void invokeBeanDefinitionRegistryPostProcessors(
      Collection<? extends BeanDefinitionRegistryPostProcessor> postProcessors, BeanDefinitionRegistry registry) { 

   for (BeanDefinitionRegistryPostProcessor postProcessor : postProcessors) { 
      postProcessor.postProcessBeanDefinitionRegistry(registry);
   }
}

每个接收者都会包含对另外一个接收者的引用,如果一个对象不能处理该请求,会把相同的请求转发给下一个接收者,以此类推。

本文为互联网自动采集或经作者授权后发布,本文观点不代表立场,若侵权下架请联系我们删帖处理!文章出自:https://wangjiawei.blog.csdn.net/article/details/121002362
-- 展开阅读全文 --
安全面试之XSS(跨站脚本攻击)
« 上一篇 07-24

发表评论

成为第一个评论的人

热门文章

标签TAG

最近回复