这篇文章主要介绍Spring BPP中怎样创建动态代理Bean,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
v一、前言
本文章所讲并没有基于Aspectj,而是直接通过Cglib以及ProxyFactoryBean去创建代理Bean。通过下面的例子,可以看出Cglib方式创建的代理Bean和ProxyFactoryBean创建的代理Bean的区别。
v二、基本测试代码
测试实体类,在BPP中创建BppTestDepBean类型的代理Bean。
@Component public static class BppTestBean { @Autowired private BppTestDepBean depBean; public void test1() { depBean.testDep(); } public void test2() { depBean.testDep(); } @TestMethod public void test3() { depBean.testDep(); } } @Component public static class BppTestDepBean { public void testDep() { System.out.println("HEHE"); } } @Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface TestMethod { }
测试类
@RunWith(SpringRunner.class) @SpringBootTest public class BppTest { @Autowired private BppTestBean bppTestBean; @Test public void test() { bppTestBean.test1(); bppTestBean.test2(); bppTestBean.test3(); } }
v三、使用Cglib创建代理Bean
public class ProxyBpp1 implements BeanPostProcessor { private static final Logger LOGGER = LoggerFactory.getLogger(ProxyBpp1.class); @Override public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException { if (bean instanceof BppTestBean) { Enhancer enhancer = new Enhancer(); enhancer.setSuperclass(bean.getClass()); //标识Spring-generated proxies enhancer.setInterfaces(new Class[]{SpringProxy.class}); //设置增强 enhancer.setCallback((MethodInterceptor) (target, method, args, methodProxy) -> { if ("test1".equals(method.getName())) { LOGGER.info("ProxyBpp1 开始执行..."); Object result = methodProxy.invokeSuper(target, args); LOGGER.info("ProxyBpp1 结束执行..."); return result; } return method.invoke(target, args); }); return enhancer.create(); } return bean; } }
主要是代理 BppTestBean的test1方法。其实这种方式创建的代理Bean使用问题的,@Autowired字段没有注入进来,所以会有出现NPE。methodProxy.invokeSuper(target, args)
,这一行代码是有问题的,targe是代理类对象,而真实的对象是postProcessBeforeInitialization(Object bean, String beanName)
中的bean对象,此时bean对象@Autowired字段已经注入了。所以可以将methodProxy.invokeSuper(target, args)
修改为method.invoke(bean, args)
解决无法注入@Autowired字段的问题。
v四、使用ProxyFactoryBean创建代理Bean
public class ProxyBpp2 implements BeanPostProcessor { private static final Logger LOGGER = LoggerFactory.getLogger(ProxyBpp2.class); @Override public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException { if (bean instanceof BppTestBean) { ProxyFactoryBean pfb = new ProxyFactoryBean(); pfb.setTarget(bean); pfb.setAutodetectInterfaces(false); NameMatchMethodPointcutAdvisor advisor = new NameMatchMethodPointcutAdvisor(); advisor.addMethodName("test1"); advisor.setAdvice((MethodInterceptor) invocation -> { LOGGER.info("ProxyBpp2 开始执行..."); Object result = invocation.getMethod().invoke(invocation.getThis(), invocation.getArguments()); LOGGER.info("ProxyBpp2 结束执行..."); return result; }); pfb.addAdvisor(advisor); return pfb.getObject(); } return bean; } }
使用ProxyFactoryBean创建代理Bean的时候,一定要一个targe对象的。Advisor在切入的时候,会逐个执行Advice。invocation.getThis()
就是在通过ProxyFactoryBean创建代理Bean的时候传入的target对象。由于target对象就是postProcessBeforeInitialization(Object bean, String beanName)
中的bean对象,所以@Autowired字段也已经注入进来了。
v五、@Autowired注解何时被处理
想必大家都知道@Autowired字段的处理也是通过一个BPP,不过这个BPP比我们平常使用的要高级一些,它就是InstantiationAwareBeanPostProcessor。这个BPP可以实现Bean的创建、属性的注入和解析(比如@Autowired、@Value、@Resource等等),大家可以参考一下CommonAnnotationBeanPostProcessor(处理JSR-250相关注解),AutowiredAnnotationBeanPostProcessor(处理@Autowired、@Value、@Inject相关注解)。
InstantiationAwareBeanPostProcessor中有一个如下的方法,AutowiredAnnotationBeanPostProcessor就是覆盖这个方法实现了带有相关注解属性的自动注入。
@Nullable default PropertyValues postProcessProperties(PropertyValues pvs, Object bean, String beanName) throws BeansException { return null; }
@Override public PropertyValues postProcessProperties(PropertyValues pvs, Object bean, String beanName) { InjectionMetadata metadata = findAutowiringMetadata(beanName, bean.getClass(), pvs); try { metadata.inject(bean, beanName, pvs); } catch (BeanCreationException ex) { throw ex; } catch (Throwable ex) { throw new BeanCreationException(beanName, "Injection of autowired dependencies failed", ex); } return pvs; }
InstantiationAwareBeanPostProcessor的postProcessProperties方法实在Spring AbstractAutowireCapableBeanFactory的populateBean方法中被调用。在AbstractAutowireCapableBeanFactory的doCreateBan中有如下代码。
// Initialize the bean instance. Object exposedObject = bean;# try { populateBean(beanName, mbd, instanceWrapper); exposedObject = initializeBean(beanName, exposedObject, mbd); }
也就是先进行了Bean的属性填充,然后进行Bean的初始化工作。initializeBean方法中主要做了四件事。
1、invokeAwareMethods
2、applyBeanPostProcessorsBeforeInitialization
3、invokeInitMethods
4、applyBeanPostProcessorsAfterInitialization
其中2和4就是分别调用的普通的BPP中的postProcessBeforeInitialization方法和postProcessAfterInitialization方法。
这就是为什么在BPP中创建代理Bean的时候,对应的目标Bean相关的@Autowired字段已经注入的原因了。
v六、InstantiationAwareBeanPostProcessor方式创建动态代理Bean
InstantiationAwareBeanPostProcessor接口中有个postProcessBeforeInstantiation方法,可以让我们自己去实例化Bean。通过查看AbstractAutowireCapableBeanFactory,方法调用:createBean方法 -> resolveBeforeInstantiation方法 -> applyBeanPostProcessorsBeforeInstantiation方法 ->InstantiationAwareBeanPostProcessor#postProcessBeforeInstantiation方法,如果最终返回一个非null的实例,那么就不会再执行doCreateBean方法。这就意味着不会有Bean属性的填充和初始化的流程了,但是可以借助AbstractAutowireCapableBeanFactory帮助我们实现。
public <T> T postProcess(T object) { if (object == null) { return null; } T result; try { // 使用容器autowireBeanFactory标准依赖注入方法autowireBean()处理 object对象的依赖注入 this.autowireBeanFactory.autowireBean(object); // 使用容器autowireBeanFactory标准初始化方法initializeBean()初始化对象 object result = (T) this.autowireBeanFactory.initializeBean(object, object.toString()); } catch (RuntimeException e) { Class<?> type = object.getClass(); throw new RuntimeException( "Could not postProcess " + object + " of type " + type, e); } return result; }
上图代码,可以帮组我们实现非Spring容器Bean自动注入和初始化的功能。使用过Spring security同学都知道,内部也是用了这个方式解决对象中的属性注入问题。如果你阅读了Spring security的源码,你会发现很多对象,比如WebSecurity、ProviderManager、各个安全Filter等,这些对象的创建并不是通过bean定义的形式被容器发现和注册进入spring容器的,而是直接new出来的。Spring security提供的AutowireBeanFactoryObjectPostProcessor这个工具类可以使这些对象具有容器bean同样的生命周期,也能注入相应的依赖,从而进入准备好被使用的状态。
使用Cglib在InstantiationAwareBeanPostProcessor 中创建动态代理Bean。
public class ProxyBpp3 implements InstantiationAwareBeanPostProcessor { private static final Logger LOGGER = LoggerFactory.getLogger(ProxyBpp3.class); private final AutowireCapableBeanFactory autowireBeanFactory; ProxyBpp3(AutowireCapableBeanFactory autowireBeanFactory) { this.autowireBeanFactory = autowireBeanFactory; } @Override public Object postProcessBeforeInstantiation(Class<?> beanClass, String beanName) throws BeansException { if (beanClass.equals(BppConfig.BppTestBean.class)) { Enhancer enhancer = new Enhancer(); enhancer.setSuperclass(beanClass); //标识Spring-generated proxies enhancer.setInterfaces(new Class[]{SpringProxy.class}); //设置增强 enhancer.setCallback((MethodInterceptor) (target, method, args, methodProxy) -> { if ("test1".equals(method.getName())) { LOGGER.info("ProxyBpp3 开始执行..."); Object result = methodProxy.invokeSuper(target, args); LOGGER.info("ProxyBpp3 结束执行..."); return result; } return methodProxy.invokeSuper(target, args); }); return this.postProcess(enhancer.create()); } return null; } ... }
使用ProxyFactoryBean在InstantiationAwareBeanPostProcessor 中创建动态代理Bean。
public class ProxyBpp4 implements InstantiationAwareBeanPostProcessor { private static final Logger LOGGER = LoggerFactory.getLogger(ProxyBpp4.class); private final AutowireCapableBeanFactory autowireBeanFactory; ProxyBpp4(AutowireCapableBeanFactory autowireBeanFactory) { this.autowireBeanFactory = autowireBeanFactory; } @Override public Object postProcessBeforeInstantiation(Class<?> beanClass, String beanName) throws BeansException { if (beanClass.equals(BppConfig.BppTestBean.class)) { ProxyFactoryBean pfb = new ProxyFactoryBean(); pfb.setTarget(this.postProcess(BeanUtils.instantiateClass(beanClass))); pfb.setAutodetectInterfaces(false); NameMatchMethodPointcutAdvisor advisor = new NameMatchMethodPointcutAdvisor(); advisor.addMethodName("test1"); advisor.setAdvice((MethodInterceptor) invocation -> { LOGGER.info("ProxyBpp4 开始执行..."); Object result = invocation.getMethod().invoke(invocation.getThis(), invocation.getArguments()); LOGGER.info("ProxyBpp4 结束执行..."); return result; }); pfb.addAdvisor(advisor); return pfb.getObject(); } return null; } ... }
上述向两种方式,注意,实例化bean后主动通过postProcess方法借助AbstractAutowireCapableBeanFactory完成对象相关属性的注入以及对象的初始化流程。
以上是“Spring BPP中怎样创建动态代理Bean”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注亿速云行业资讯频道!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。