Spring事务

1、【源码】SpringBoot事务注册原理

2、【源码】Spring Data JPA原理解析之事务注册原理

3、【源码】Spring Data JPA原理解析之事务执行原理

4、【源码】SpringBoot编程式事务使用及执行原理

5、【源码】Spring事务之传播特性的详解

6、【源码】Spring事务之事务失效及原理

前言

在前面的Spring事务序列博文中分享了Spring事务注册、事务执行原理、编程式事务使用及原理。然后，如果使用不当，依然会导致事务失效。本篇分享一下常见的Spring事务失效的场景，并分析失败的原因。

访问权限问题

Java的访问权限主要有四种：private、default（包级访问权限）、protected、public。它们用于控制类、方法和变量的访问级别，限定了对应成员的可见性。

如果在非public的方法中添加@Transactional注解事务，则事务会失效。

2.1 示例

如以下代码：

@Service
public class MemberStatisticsService {@Resourceprivate MemberStatisticsRepository memberStatisticsRepository;@Transactionalprivate int addStatistics(MemberStatisticsEntity entity) {// 省略其他int rs = memberStatisticsRepository.save(entity);return rs ? 1 : 0;}}

在addStatistics()方法被调用的时候，会执行TransactionAspectSupport的invokeWithinTransaction()，在该方法中，会调用TransactionAttributeSource的getTransactionAttribute()方法，获取TransactionAttribute对象。该方法会调用AbstractFallbackTransactionAttributeSource的computeTransactionAttribute()方法，从而调用具体的事务解析器，获得TransactionAttribute对象。

2.2 原理

AbstractFallbackTransactionAttributeSource的computeTransactionAttribute()方法的源码如下：

public abstract class AbstractFallbackTransactionAttributeSourceimplements TransactionAttributeSource, EmbeddedValueResolverAware {/*** 从方法的目标方法、目标类或原方法、原方法的类中查找Transaction的属性信息，没有找到返回null*/@Nullableprotected TransactionAttribute computeTransactionAttribute(Method method, @Nullable Class<?> targetClass) {// 如果只允许公共方法才能拥有事务，则进行public判断if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {return null;}// 找到具体的方法。如果当前方法是一个接口方法，需要找到目标类中的实现。如果targetClass为null，那么该方法不会改变Method specificMethod = AopUtils.getMostSpecificMethod(method, targetClass);// 查找方法的Transaction属性，抽象方法，由子类实现TransactionAttribute txAttr = findTransactionAttribute(specificMethod);if (txAttr != null) {return txAttr;}// Transaction属性可能配置在目标类中txAttr = findTransactionAttribute(specificMethod.getDeclaringClass());if (txAttr != null && ClassUtils.isUserLevelMethod(method)) {return txAttr;}// 如果找到的目标方法和当前方法不同，即当前方法为接口方法或被重写的方法if (specificMethod != method) {// 再次从原方法中查找Transaction属性信息txAttr = findTransactionAttribute(method);if (txAttr != null) {return txAttr;}// 如果还没有找到，从原方法的定义类中查找Transaction属性信息txAttr = findTransactionAttribute(method.getDeclaringClass());if (txAttr != null && ClassUtils.isUserLevelMethod(method)) {return txAttr;}}return null;}}

在computeTransactionAttribute()方法中，会先判断对应的方法是否为public，如果不是，直接返回null，在TransactionAspectSupport.createTransactionIfNecessary()方法中就不会开启事务。

源码如下：

public abstract class TransactionAspectSupport implements BeanFactoryAware, InitializingBean {/*** 如有必要，根据给定的TransactionAttribute创建事务*/@SuppressWarnings("serial")protected TransactionInfo createTransactionIfNecessary(@Nullable PlatformTransactionManager tm,@Nullable TransactionAttribute txAttr, final String joinpointIdentification) {// If no name specified, apply method identification as transaction name.// 如果未指定名称，则将方法标识应用为事务名称if (txAttr != null && txAttr.getName() == null) {txAttr = new DelegatingTransactionAttribute(txAttr) {@Overridepublic String getName() {return joinpointIdentification;}};}TransactionStatus status = null;if (txAttr != null) {if (tm != null) {// 开启事务status = tm.getTransaction(txAttr);}else {if (logger.isDebugEnabled()) {logger.debug("Skipping transactional joinpoint [" + joinpointIdentification +"] because no transaction manager has been configured");}}}// 准备TransactionInfo对象，并返回return prepareTransactionInfo(tm, txAttr, joinpointIdentification, status);}
}

详细见：

【源码】Spring Data JPA原理解析之事务执行原理-CSDN博客

所以，如果要是@Transactional事务生效，方法必须定义为public访问权限。

无效异常

在项目中，为了规范编程，使用了自定义异常，如果使用不当，也容易导致事务失效。

1）首先自定义的异常不能直接继承Exception，因为事务默认只处理RuntineException或Error异常；

2）通过@Transactional的rollbackFor参数设置回滚异常时，指定了自定义的异常；

3.1 示例

@Slf4j
@Service
public class GoodsService {@Resourceprivate GoodsRepository goodsRepository;@Resourceprivate GoodsDetailRepository goodsDetailRepository;@Transactional(rollbackFor = BusinessException.class)public GoodsEntity save(GoodsEntity entity, GoodsDetailEntity detail) {entity.setCreateTime(new Date());try {entity = goodsRepository.save(entity);detail.setId(entity.getId());detail = goodsDetailRepository.save(detail);entity.setDetail(detail);} catch (Exception e) {throw new BusinessException(e.getMessage());}// 省略其他return entity;}
}

以上代码，如果在try-catch以外报了别的异常，那么会导致事务失效。

3.2 原理

3.2.1 TransactionAspectSupport异常回滚处理

TransactionAspectSupport的相关源码如下：

public abstract class TransactionAspectSupport implements BeanFactoryAware, InitializingBean {/*** 执行回滚*/protected void completeTransactionAfterThrowing(@Nullable TransactionInfo txInfo, Throwable ex) {if (txInfo != null && txInfo.getTransactionStatus() != null) {if (logger.isTraceEnabled()) {logger.trace("Completing transaction for [" + txInfo.getJoinpointIdentification() +"] after exception: " + ex);}// 如果满足回滚规则if (txInfo.transactionAttribute != null && txInfo.transactionAttribute.rollbackOn(ex)) {try {// 进行事务回滚txInfo.getTransactionManager().rollback(txInfo.getTransactionStatus());}catch (TransactionSystemException ex2) {logger.error("Application exception overridden by rollback exception", ex);ex2.initApplicationException(ex);throw ex2;}catch (RuntimeException | Error ex2) {logger.error("Application exception overridden by rollback exception", ex);throw ex2;}}else {// We don't roll back on this exception.// Will still roll back if TransactionStatus.isRollbackOnly() is true.try {// 如果TransactionStatus.isRollbackOnly()为true，则仍将回滚txInfo.getTransactionManager().commit(txInfo.getTransactionStatus());}catch (TransactionSystemException ex2) {logger.error("Application exception overridden by commit exception", ex);ex2.initApplicationException(ex);throw ex2;}catch (RuntimeException | Error ex2) {logger.error("Application exception overridden by commit exception", ex);throw ex2;}}}}
}

当异常导致事务回滚时，要先通过TransactionAttribute.rollbackOn()判断对应异常是否满足回滚规则，如果不满足，依然会提交事务。rollbackOn()是接口方法，实现如下：

​

对于@Transactional注解，使用的是RuleBasedTransactionAttribute，该类继承DefaultTransactionAttribute。

3.2.2 RuleBasedTransactionAttribute.rollbackOn()

对应源码如下：

 public class RuleBasedTransactionAttribute extends DefaultTransactionAttribute implements Serializable {   /*** 重写父类的方法，重写定义了是否需要回滚* @param ex* @return*/@Overridepublic boolean rollbackOn(Throwable ex) {if (logger.isTraceEnabled()) {logger.trace("Applying rules to determine whether transaction should rollback on " + ex);}RollbackRuleAttribute winner = null;// deepest为最大值，相当于不管异常有多深，只要规则中有此异常都应该回滚int deepest = Integer.MAX_VALUE;// 如果有回滚规则，从列表中查找是否有能够匹配该异常的规则if (this.rollbackRules != null) {for (RollbackRuleAttribute rule : this.rollbackRules) {int depth = rule.getDepth(ex);if (depth >= 0 && depth < deepest) {deepest = depth;winner = rule;}}}if (logger.isTraceEnabled()) {logger.trace("Winning rollback rule is: " + winner);}// User superclass behavior (rollback on unchecked) if no rule matches.// 如果没有找到匹配的回滚规则，则返回父类的执行结果，即只回滚RuntimeException 或者 Error(比如OOM这种)if (winner == null) {logger.trace("No relevant rollback rule found: applying default rules");return super.rollbackOn(ex);}// 如果有匹配的回滚规则，则属于不需要回滚的，则返回false，即不回滚return !(winner instanceof NoRollbackRuleAttribute);}
}

DefaultTransactionAttribute.rollbackOn()源码如下：

public class DefaultTransactionAttribute extends DefaultTransactionDefinition implements TransactionAttribute {/*** 是否回滚。只回滚RuntimeException 或者 Error(比如OOM这种)*/@Overridepublic boolean rollbackOn(Throwable ex) {return (ex instanceof RuntimeException || ex instanceof Error);}
}

在RuleBasedTransactionAttribute.rollbackOn()方法中，会先判断异常信息是否在@Transactional中指定，如果没有，调用父类的rollbackOn()进行判断，父类DefaultTransactionAttribute的rollbackOn()方法，判断异常是否属于RuntimeException或Error，如果是，才会回滚事务。

业务异常捕获

不管是通过@Transactional注解实现事务还是编程式事务，都是在业务逻辑出现异常时，事务处理会捕获异常，并判断是否要进行事务回滚，然后抛出对应异常。如果业务异常自己捕获了，没有往外抛，也会导致事务失效。

4.1 事务失效示例

@Slf4j
@Service
public class GoodsService {@Resourceprivate GoodsRepository goodsRepository;@Resourceprivate GoodsDetailRepository goodsDetailRepository;@Transactionalpublic GoodsEntity save(GoodsEntity entity, GoodsDetailEntity detail) {entity.setCreateTime(new Date());try {entity = goodsRepository.save(entity);detail.setId(entity.getId());detail = goodsDetailRepository.save(detail);entity.setDetail(detail);} catch (Exception e) {log.error(e.getMessage());return null;}return entity;}
}

4.2 事务失效修改示例

@Slf4j
@Service
public class GoodsService {@Resourceprivate GoodsRepository goodsRepository;@Resourceprivate GoodsDetailRepository goodsDetailRepository;@Transactionalpublic GoodsEntity save(GoodsEntity entity, GoodsDetailEntity detail) {entity.setCreateTime(new Date());try {entity = goodsRepository.save(entity);detail.setId(entity.getId());detail = goodsDetailRepository.save(detail);entity.setDetail(detail);} catch (Exception e) {log.error(e.getMessage());// 设置事务回滚TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();return null;}return entity;}
}

只需要在异常捕获的地方加上如下代码：

TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

4.3 原理

事务在提交之前，会再做一次是否回滚判断，源码如下：

package org.springframework.transaction.support;@SuppressWarnings("serial")
public abstract class AbstractPlatformTransactionManager implements PlatformTransactionManager, Serializable {@Overridepublic final void commit(TransactionStatus status) throws TransactionException {if (status.isCompleted()) {throw new IllegalTransactionStateException("Transaction is already completed - do not call commit or rollback more than once per transaction");}DefaultTransactionStatus defStatus = (DefaultTransactionStatus) status;// 如果本地代码设置了回滚if (defStatus.isLocalRollbackOnly()) {if (defStatus.isDebug()) {logger.debug("Transactional code has requested rollback");}processRollback(defStatus, false);return;}// 全局事务被标记为仅回滚，但事务代码请求提交if (!shouldCommitOnGlobalRollbackOnly() && defStatus.isGlobalRollbackOnly()) {if (defStatus.isDebug()) {logger.debug("Global transaction is marked as rollback-only but transactional code requested commit");}processRollback(defStatus, true);return;}// 提交处理processCommit(defStatus);}}

在commit()方法中，在真正提交处理前，会先进行两个判断：

1）defStatus.isLocalRollbackOnly()如果返回true，会执行回滚；

2）判断!shouldCommitOnGlobalRollbackOnly() && defStatus.isGlobalRollbackOnly()，如果为true，也会执行回滚；

内部方法调用

5.1 示例

@Service
public class MemberStatisticsService {@Resourceprivate TransactionTemplate transactionTemplate;@Resourceprivate MemberStatisticsRepository memberStatisticsRepository;public int addStatistics(MemberStatisticsEntity entity) {boolean rs = addStatisticsBs(entity);// 省略其他return rs ? 1 : 0;}@Transactionalpublic int addStatisticsBs(MemberStatisticsEntity entity) {// 省略其他memberStatisticsRepository.save(entity);return true;}}

如果是通过addStatistics()方法，方法没有添加@Transactional注解，然后调用带@Transactional注解的addStatisticsBs()方法时，当addStatisticsBs()出现异常时，事务不会回滚。

5.2 原理

【源码】SpringBoot事务注册原理-CSDN博客

在上面的博客中介绍了方法中添加@Transactional注解时，该类会生成代理类，代理类中添加了TransactionInterceptor拦截器，从而实现了事务管理。

当addStatistics()方法执行时，会先执行ReflectiveMethodInvocation.proceed()方法，循环遍历所有的拦截器。执行完所有拦截器之后，再执行动态代理对象的target类的对应方法，即原方法。详见：

【源码】Spring Data JPA原理解析之Repository执行过程及SimpleJpaRepository源码-CSDN博客

博客中的动态代理方法拦截部分。

因为addStatistics()没有添加@Transactional注解，所以执行target的addStatistics()方法，所以在addStatistics()方法内部的this对象是target，而不是代理对象。所以在addStatistics()内部调用addStatisticsBs()方法时，是执行target的addStatisticsBs()方法，所以不再先执行ReflectiveMethodInvocation.proceed()，也就不会执行TransactionInterceptor拦截器，所以没有开启事务管理。

传播特性使用不当

事务传播特性的详细说明见

【源码】Spring事务之传播特性的详解-CSDN博客

结尾

限于篇幅，本篇先分享到这里。

关于本篇内容你有什么自己的想法或独到见解，欢迎在评论区一起交流探讨下吧。