解释
InitializingBean:自己被初始化之后进行调用,针对的对象是实现该接口的bean,必须实现方法afterPropertiesSet
BeanPostProcessor:接口,有两个可以复写的方法(接口有默认实现),针对的对象是所有的bean,可以在内部过滤自己需要处理的bean,两个方法
-
postProcessBeforeInitialization
:某个bean在初始化之前会进行调用,初始化意思为填充了bean的属性值,但是还未调用InitializingBean 的afterPropertiesSet方法 -
postProcessAfterInitialization
:某个bean在初始化之后进行调用
思考来源
在查看阿里的分布式事务解决方案Seata源码时,发现如果项目中使用了openfegin,seata会向ioc容器中添加一个SeataFeignContext的bean,但是openfegin自己也向容器中添加了一个FeignContext的实例bean,这也就是seata巧妙的地方,使用BeanPostProcessor实现了对FeignContext的一个包装,应该也属于静态代理吧,SeataFeignContext继承自FeignContext并且实现了seata自己的逻辑,然后使用SeataContextBeanPostProcessor将openfegin自己添加的FeignContext类型转换为了SeataFeignContext
@Override
public Object postProcessBeforeInitialization(Object bean, String beanName)
throws BeansException {
// 当要向容器中注册FeignContext时会判断是否是SeataFeignContext,如果不是SeataFeignContext类型,说明他是openfegin自己注册的,我们给他包装为SeataFeignContext类型
if (bean instanceof FeignContext && !(bean instanceof SeataFeignContext)) {
return new SeataFeignContext(getSeataFeignObjectWrapper(),
(FeignContext) bean);
}
return bean;
}
尝试(使用BeanPostprocessor实现静态代理)
结合上一篇文章SpringBoot之@Import注解(Registrar使用)最后,向容器中添加一个用户Wangwu(name='王五',age=100)
@AllArgsConstructor
@Data
public class Wangwu {
private String name;
private int age;
}
新建一个代理类WangwuProxy,并在调用其get方法时打印一些日志,并且将年龄+100
@Slf4j
public class WangwuProxy extends Wangwu {
public WangwuProxy(String name, int age) {
super(name, age);
}
@Override
public int getAge() {
log.error("调用了王五的getAge(),将其年龄+100");
return super.getAge()+100;
}
@Override
public String getName() {
log.error("调用了王五的getName()");
return super.getName();
}
}
新建一个WangwuPostProcessor,并且实现接口BeanPostProcessor和InitializingBean(实现afterPropertiesSet()方法打印日志)
@Component
@Slf4j
public class WangwuPostProcessor implements BeanPostProcessor, InitializingBean {
/**
* 当某个bean初始化之前调用该方法,可以修改bean的一些属性
* @param bean
* @param beanName
* @return
* @throws BeansException
*/
@Override
public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
if (bean instanceof Wangwu&&!(bean instanceof WangwuProxy)){
// 如果是Wangwu的实例,进行包装一下
return new WangwuProxy(((Wangwu) bean).getName(),((Wangwu) bean).getAge());
}
return bean;
}
/**
* 当某个bean初始化结束之后就会调用该方法,还可以修改bean的一些信息
* @param bean
* @param beanName
* @return
* @throws BeansException
*/
@Override
public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
if (bean instanceof Wangwu){
// 经过postProcessBeforeInitialization方法之后,wangwu这个bean已经是WangwuProxy这个类的一个实例了
log.error("wangwu instance WangwuProxy =="+(bean instanceof WangwuProxy));
log.error("wangwu instance age is "+((Wangwu) bean).getAge());
}
return BeanPostProcessor.super.postProcessAfterInitialization(bean, beanName);
}
@Override
public void afterPropertiesSet() throws Exception {
log.error("成功注册WangwuPostProcessor");
}
}
- 实现afterPropertiesSet()方法,打印日志
- 类似seata处理,我们将Wangwu这个实例修改为了WangwuProxy
- 初始化之后对wangwu进行打印,最后可以看到wangwu这个bean已经是WangwuProxy的一个实例
输出结果:
2021-09-03 16:20:30.832 ERROR 62484 --- [main] c.e.j.s.processor.WangwuPostProcessor : 成功注册WangwuPostProcessor
2021-09-03 16:20:33.156 ERROR 62484 --- [main] c.e.j.s.processor.WangwuPostProcessor : wangwu instance WangwuProxy ==true
2021-09-03 16:20:33.156 ERROR 62484 --- [main] c.e.jpa.scanner.processor.WangwuProxy : 调用了王五的getAge(),将其年龄+100
2021-09-03 16:20:33.156 ERROR 62484 --- [main] c.e.j.s.processor.WangwuPostProcessor : wangwu instance age is 200