spring事务不生效的缘由和解决方案

时间  2019-11-17
标签 spring 事务 生效 缘由 解决 方案 栏目 Spring 繁體版
原文   原文链接

前些日子一朋友在须要在目标对象中进行自我调用，且须要实施相应的事务定义，且网上的一种经过BeanPostProcessor的解决方案是存在问题的。所以专门写此篇帖子分析why。spring

1、预备知识

使用AOP 代理后的方法调用执行流程，如图所示app



也就是说咱们首先调用的是AOP代理对象而不是目标对象，首先执行事务切面，事务切面内部经过TransactionInterceptor环绕加强进行事务的加强，即进入目标方法以前开启事务，退出目标方法时提交/回滚事务。post

2、测试代码准备

Java代码  性能

  1. public interface AService {  测试

  2.     public void a();  this

  3.     public void b();  spa

  4. }  .net

  5.    

  6. @Service ()  hibernate

  7. public class AServiceImpl1 implements AService{  prototype

  8.     @Transactional(propagation = Propagation.REQUIRED)  

  9.     public void a() {  

  10.         this.b();  

  11.     }  

  12.     @Transactional(propagation = Propagation.REQUIRES_NEW)  

  13.     public void b() {  

  14.     }  

  15. }  

 

3、问题

目标对象内部的自我调用将没法实施切面中的加强，如图所示


 

此处的this指向目标对象，所以调用this.b()将不会执行b事务切面，即不会执行事务加强，所以b方法的事务定义“@Transactional(propagation = Propagation.REQUIRES_NEW)”将不会实施，即结果是b和a方法的事务定义是同样的，能够从如下日志看出：

 

 org.springframework.transaction.annotation.AnnotationTransactionAttributeSource Adding transactional method 'a' with attribute: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; ''

org.springframework.beans.factory.support.DefaultListableBeanFactory Returning cached instance of singleton bean 'txManager'

org.springframework.orm.hibernate4.HibernateTransactionManager Creating new transaction with name [com.sishuok.service.impl.AServiceImpl1.a]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; ''  -----建立a方法事务

org.springframework.orm.hibernate4.HibernateTransactionManager Opened new Session …… for Hibernate transaction  ---打开Session

……

org.springframework.transaction.support.TransactionSynchronizationManager Initializing transaction synchronization

org.springframework.transaction.interceptor.TransactionInterceptor Getting transaction for [com.sishuok.service.impl.AServiceImpl1.a]

org.springframework.transaction.interceptor.TransactionInterceptor Completing transaction for [com.sishuok.service.impl.AServiceImpl1.a] ----完成a方法事务

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering beforeCommit synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering beforeCompletion synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Initiating transaction commit

 

org.springframework.orm.hibernate4.HibernateTransactionManager Committing Hibernate transaction on Session ……---提交a方法事务

或

org.springframework.orm.hibernate4.HibernateTransactionManager Rolling back Hibernate transaction on Session ……---若是有异常将回滚a方法事务

 

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering afterCommit synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering afterCompletion synchronization

org.springframework.transaction.support.TransactionSynchronizationManager Clearing transaction synchronization

……

org.springframework.orm.hibernate4.HibernateTransactionManager Closing Hibernate Session …… after transaction     --关闭Session

 

咱们能够看到事务切面只对a方法进行了事务加强，没有对b方法进行加强。

 

3、解决方案

此处a方法中调用b方法时，只要经过AOP代理调用b方法便可走事务切面，便可以进行事务加强，以下所示：

Java代码  

  1. public void a() {  

  2. aopProxy.b();//即调用AOP代理对象的b方法便可执行事务切面进行事务加强  

  3. }  

 

判断一个Bean是不是AOP代理对象可使用以下三种方法：

AopUtils.isAopProxy(bean)        ： 是不是代理对象；

AopUtils.isCglibProxy(bean)       ： 是不是CGLIB方式的代理对象；

AopUtils.isJdkDynamicProxy(bean) ： 是不是JDK动态代理方式的代理对象；

3.1、经过ThreadLocal暴露Aop代理对象

1、开启暴露Aop代理到ThreadLocal支持（以下配置方式从spring3开始支持）

Java代码  

  1. <aop:aspectj-autoproxy expose-proxy="true"/><!—注解风格支持-->  

Java代码  

  1. <aop:config expose-proxy="true"><!—xml风格支持-->   

   

2、修改咱们的业务实现类

this.b();-----------修改成--------->((AService) AopContext.currentProxy()).b();

 

3、执行测试用例，日志以下

 

 

org.springframework.beans.factory.support.DefaultListableBeanFactory Returning cached instance of singleton bean 'txManager'

org.springframework.orm.hibernate4.HibernateTransactionManager Creating new transaction with name [com.sishuok.service.impl.AServiceImpl2.a]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; ''   -----建立a方法事务

org.springframework.orm.hibernate4.HibernateTransactionManager Opened new Session ……for Hibernate transaction  --打开a Session

org.springframework.orm.hibernate4.HibernateTransactionManager Preparing JDBC Connection of Hibernate Session ……

org.springframework.orm.hibernate4.HibernateTransactionManager Exposing Hibernate transaction as JDBC transaction ……

……

org.springframework.transaction.support.TransactionSynchronizationManager Initializing transaction synchronization

org.springframework.transaction.interceptor.TransactionInterceptor Getting transaction for [com.sishuok.service.impl.AServiceImpl2.a]

 

org.springframework.transaction.annotation.AnnotationTransactionAttributeSource Adding transactional method 'b' with attribute: PROPAGATION_REQUIRES_NEW,ISOLATION_DEFAULT; ''

……

org.springframework.orm.hibernate4.HibernateTransactionManager Suspending current transaction, creating new transaction with name [com.sishuok.service.impl.AServiceImpl2.b]  -----建立b方法事务（并暂停a方法事务）

……

org.springframework.orm.hibernate4.HibernateTransactionManager Opened new Session  for Hibernate transaction  ---打开b Session

……

org.springframework.transaction.support.TransactionSynchronizationManager Initializing transaction synchronization

org.springframework.transaction.interceptor.TransactionInterceptor Getting transaction for [com.sishuok.service.impl.AServiceImpl2.b]

org.springframework.transaction.interceptor.TransactionInterceptor Completing transaction for [com.sishuok.service.impl.AServiceImpl2.b] ----完成b方法事务

 

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering beforeCommit synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering beforeCompletion synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Initiating transaction commit

org.springframework.orm.hibernate4.HibernateTransactionManager Committing Hibernate transaction on Session …… ---提交b方法事务

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering afterCommit synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering afterCompletion synchronization

org.springframework.transaction.support.TransactionSynchronizationManager Clearing transaction synchronization

……

org.springframework.orm.hibernate4.HibernateTransactionManager Closing Hibernate Session …… after transaction  --关闭 b Session

 

-----到此b方法事务完毕

 

org.springframework.orm.hibernate4.HibernateTransactionManager Resuming suspended transaction after completion of inner transaction ---恢复a方法事务

……

org.springframework.transaction.support.TransactionSynchronizationManager Initializing transaction synchronization

org.springframework.transaction.interceptor.TransactionInterceptor Completing transaction for [com.sishuok.service.impl.AServiceImpl2.a] ----完成a方法事务

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering beforeCommit synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering beforeCompletion synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Initiating transaction commit

org.springframework.orm.hibernate4.HibernateTransactionManager Committing Hibernate transaction on Session ……---提交a方法事务

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering afterCommit synchronization

org.springframework.orm.hibernate4.HibernateTransactionManager Triggering afterCompletion synchronization

org.springframework.transaction.support.TransactionSynchronizationManager Clearing transaction synchronization

……

org.springframework.orm.hibernate4.HibernateTransactionManager Closing Hibernate Session …… after transaction  --关闭 a Session

 

 

 

此处咱们能够看到b方法的事务起做用了。

 

以上方式是解决目标对象内部方法自我调用并实施事务的最简单的解决方案。

 

4、实现原理分析

4.一、在进入代理对象以后经过AopContext.serCurrentProxy(proxy)暴露当前代理对象到ThreadLocal，并保存上次ThreadLocal绑定的代理对象为oldProxy；

4.二、接下来咱们能够经过 AopContext.currentProxy() 获取当前代理对象；

4.三、在退出代理对象以前要从新将ThreadLocal绑定的代理对象设置为上一次的代理对象，即AopContext.serCurrentProxy(oldProxy)。

 

有些人不喜欢这种方式，说经过ThreadLocal暴露有性能问题，其实这个不须要考虑，由于事务相关的（Session和Connection）内部也是经过SessionHolder和ConnectionHolder暴露到ThreadLocal实现的。

 

不过自我调用这种场景确实只有不多状况遇到，所以不用这种方式咱们也能够经过以下方式实现。

3.2、经过初始化方法在目标对象中注入代理对象

Java代码  

  1. @Service   

  2. public class AServiceImpl3 implements AService{  

  3.     @Autowired  //①  注入上下文  

  4.     private ApplicationContext context;  

  5.       

  6.     private AService proxySelf; //②  表示代理对象，不是目标对象  

  7.     @PostConstruct  //③ 初始化方法  

  8.     private void setSelf() {  

  9.         //从上下文获取代理对象（若是经过proxtSelf=this是不对的，this是目标对象）  

  10.         //此种方法不适合于prototype Bean，由于每次getBean返回一个新的Bean  

  11.         proxySelf = context.getBean(AService.class);   

  12.     }  

  13.     @Transactional(propagation = Propagation.REQUIRED)  

  14.     public void a() {  

  15.        proxySelf.b(); //④ 调用代理对象的方法 这样能够执行事务切面  

  16.     }  

  17.     @Transactional(propagation = Propagation.REQUIRES_NEW)  

  18.     public void b() {  

  19.     }  

  20. }  

 

此处日志就不分析，和3.1相似。此种方式不是很灵活，全部须要自我调用的实现类必须重复实现代码。

3.3、经过BeanPostProcessor 在目标对象中注入代理对象

此种解决方案能够参考http://fyting.iteye.com/blog/109236。

 

BeanPostProcessor 的介绍和使用敬请等待个人下一篇分析帖。

 

1、定义BeanPostProcessor 须要使用的标识接口

 

Java代码  

  1. public interface BeanSelfAware {  

  2.     void setSelf(Object proxyBean);  

  3. }  

 即咱们自定义的BeanPostProcessor （InjectBeanSelfProcessor）若是发现咱们的Bean是实现了该标识接口就调用setSelf注入代理对象。

 

2、Bean实现

Java代码  

  1. @Service  

  2. public class AServiceImpl4 implements AService, BeanSelfAware {//此处省略接口定义  

  3.     private AService proxySelf;  

  4.     public void setSelf(Object proxyBean) { //经过InjectBeanSelfProcessor注入本身（目标对象）的AOP代理对象 

  5.         this.proxySelf = (AService) proxyBean;  

  6.     }  

  7.     @Transactional(propagation = Propagation.REQUIRED)  

  8.     public void a() {  

  9.         proxySelf.b();//调用代理对象的方法 这样能够执行事务切面  

  10.     }  

  11.     @Transactional(propagation = Propagation.REQUIRES_NEW)  

  12.     public void b() {  

  13.     }  

  14. }   

实现BeanSelfAware标识接口的setSelf将代理对象注入，而且经过“proxySelf.b()”这样能够实施b方法的事务定义。

 

3、InjectBeanSelfProcessor实现

 

Java代码  

  1. @Component  

  2. public class InjectBeanSelfProcessor implements BeanPostProcessor {  

  3.     public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {  

  4.         return bean;  

  5.     }  

  6.     public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {

  7.         if(bean instanceof BeanSelfAware) {//若是Bean实现了BeanSelfAware标识接口，就将代理对象注入  

  8.             ((BeanSelfAware) bean).setSelf(bean); //即便是prototype Bean也可使用此种方式  

  9.         }  

  10.         return bean;  

  11.     }  

  12. }  

 

postProcessAfterInitialization根据目标对象是否实现BeanSelfAware标识接口，经过setSelf(bean)将代理对象（bean）注入到目标对象中，从而能够完成目标对象内部的自我调用。

 

关于BeanPostProcessor的执行流程等请必定参考个人这篇帖子，不然没法继续往下执行。

 

4、InjectBeanSelfProcessor的问题

（1、场景：经过InjectBeanSelfProcessor进行注入代理对象且循环依赖场景下会产生前者没法经过setSelf设置代理对象的问题。 循环依赖是应该避免的，可是实际工做中不可避免会有人使用这种注入，毕竟没有强制性。

 

（2、用例

（2.1、定义BeanPostProcessor 须要使用的标识接口

和3.1中同样此处再也不重复。

 

（2.2、Bean实现

 

Java代码  

  1. @Service  

  2. public class AServiceImpl implements AService, BeanSelfAware {//此处省略Aservice接口定义  

  3.     @Autowired  

  4.     private BService bService;   //①  经过@Autowired方式注入BService  

  5.     private AService self;       //②  注入本身的AOP代理对象  

  6.     public void setSelf(Object proxyBean) {  

  7.         this.self = (AService) proxyBean;  //③ 经过InjectBeanSelfProcessor注入本身（目标对象）的AOP代理对象

  8.         System.out.println("AService=="+ AopUtils.isAopProxy(this.self)); //若是输出true标识AOP代理对象注入成功  

  9.     }  

  10.     @Transactional(propagation = Propagation.REQUIRED)  

  11.     public void a() {  

  12.         self.b();  

  13.     }  

  14.     @Transactional(propagation = Propagation.REQUIRES_NEW)  

  15.     public void b() {  

  16.     }  

  17. }  

  

 

Java代码  

  1. @Service  

  2. public class BServiceImpl implements BService, BeanSelfAware {//此处省略Aservice接口定义  

  3.     @Autowired  

  4.     private AService aService;  //①  经过@Autowired方式注入AService  

  5.     private BService self;      //②  注入本身的AOP代理对象  

  6.     public void setSelf(Object proxyBean) {  //③ 经过InjectBeanSelfProcessor注入本身（目标对象）的AOP代理对象  

  7.         this.self = (BService) proxyBean;  

  8.         System.out.println("BService=" + AopUtils.isAopProxy(this.self)); //若是输出true标识AOP代理对象注入成功  

  9.     }  

  10.     @Transactional(propagation = Propagation.REQUIRED)  

  11.     public void a() {  

  12.         self.b();  

  13.     }  

  14.     @Transactional(propagation = Propagation.REQUIRES_NEW)  

  15.     public void b() {  

  16.     }  

  17. }  

此处A依赖B，B依赖A，即构成循环依赖，此处不探讨循环依赖的设计问题（实际工做应该避免循环依赖），只探讨为何循环依赖会出现注入代理对象失败的问题。

 

循环依赖请参考个人博文【http://jinnianshilongnian.iteye.com/blog/1415278】。

依赖的初始化和销毁顺序请参考个人博文【http://jinnianshilongnian.iteye.com/blog/1415461】。

 

（2.3、InjectBeanSelfProcessor实现

和以前3.3中同样 此处再也不重复。

 

（2.4、测试用例

 

Java代码  

  1. @RunWith(value = SpringJUnit4ClassRunner.class)  

  2. @ContextConfiguration(value = {"classpath:spring-config.xml"})  

  3. public class SelfInjectTest {  

  4.     @Autowired  

  5.     AService aService;  

  6.     @Autowired  

  7.     BService bService;  

  8.     @Test  

  9.     public void test() {  

  10.     }  

  11. }  

  

执行如上测试用例会输出：

BService=true

AService==false

即BService经过InjectBeanSelfProcessor注入代理对象成功，而AService却失败了（实际是注入了目标对象），以下是debug获得的信息：

 


 

 

（2. 5、这是为何呢，怎么在循环依赖会出现这种状况？

 

敬请期待个人下一篇分析帖。

3.4、改进版的InjectBeanSelfProcessor的解决方案

Java代码  

  1. @Component  

  2. public class InjectBeanSelfProcessor2 implements BeanPostProcessor, ApplicationContextAware {  

  3.     private ApplicationContext context;  

  4.     //① 注入ApplicationContext  

  5.     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {  

  6.         this.context = applicationContext;  

  7.     }  

  8.     public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {

  9.         if(!(bean instanceof BeanSelfAware)) { //② 若是Bean没有实现BeanSelfAware标识接口 跳过  

  10.             return bean;  

  11.         }  

  12.         if(AopUtils.isAopProxy(bean)) { //③ 若是当前对象是AOP代理对象，直接注入  

  13.             ((BeanSelfAware) bean).setSelf(bean);  

  14.         } else {  

  15.             //④ 若是当前对象不是AOP代理，则经过context.getBean(beanName)获取代理对象并注入  

  16.             //此种方式不适合解决prototype Bean的代理对象注入  

  17.             ((BeanSelfAware)bean).setSelf(context.getBean(beanName));  

  18.         }  

  19.         return bean;  

  20.     }  

  21.     public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {  

  22.         return bean;  

  23.     }  

  24. }  

 

5、总结

纵观其上：

【3.1 经过ThreadLocal暴露Aop代理对象】适合解决全部场景（不论是singleton Bean仍是prototype Bean）的AOP代理获取问题（即能解决目标对象的自我调用问题）；

 

【3.2 经过初始化方法在目标对象中注入代理对象】 和【3.4 改进版的InjectBeanSelfProcessor的解决方案】能解决普通（无循环依赖）的AOP代理对象注入问题，并且也能解决【3.3】中提到的循环依赖（应该是singleton之间的循环依赖）形成的目标对象没法注入AOP代理对象问题，但该解决方案不适合解决循环依赖中包含prototype Bean的自我调用问题；

 

【3.3 经过BeanPostProcessor 在目标对象中注入代理对象】：只能解决 普通（无循环依赖）的 的Bean注入AOP代理，没法解决循环依赖的AOP代理对象注入问题，即没法解决目标对象的自我调用问题。

 

 

 

jingnianshilongnian 写道


spring容许的循环依赖（只考虑单例和原型Bean）：
A----B
B----A
只有在A和B都不为原型是容许的，即若是A和B都是prototype则会报错（没法进行原型Bean的循环依赖）。
A（单例）---B（单例） 或 A（原型）---B（单例） 这是能够的，但 A（原型）---B（原型）或 A（原型）---B（单例Lazy）【且context.getBean("A")】时 这是不容许的。

1、A（原型）---B（原型） A（原型）---B（单例Lazy）【且context.getBean("A")】 会报：
Error creating bean with name 'BServiceImpl': Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire field: private com.sishuok.issue.AService com.sishuok.issue.impl.BServiceImpl.aService; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'AServiceImpl': Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire field: private com.sishuok.issue.BService com.sishuok.issue.impl.AServiceImpl.bService; nested exception is org.springframework.beans.factory.BeanCurrentlyInCreationException: Error creating bean with name 'BServiceImpl': Requested bean is currently in creation: [color=red]Is there an unresolvable circular reference[/color]?

2、A（原型）---B（单例） 和 A（单例）---B（单例）
这种方式 使用个人 【3.3 经过BeanPostProcessor 在目标对象中注入代理对象】 是没有问题的。

所以【 3.4 改进版的InjectBeanSelfProcessor的解决方案 】 能够做为最后的解决方案。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程