一次bug修复，重新认识spring事务传播机制—破案篇

vlambda
2021-01-20

一次bug修复，重新认识spring事务传播机制—破案篇

❝
前段时间，QA在jira提了个bug，偶现一个问题。报错：
org.springframework.transaction.UnexpectedRollbackException: Transaction rolled back because it has been marked as rollback-only

很遗憾，当时没有记录整个bug修复过程，现在那段代码也让我替换掉了。

不过在解决的过程中，让我对spring事务传播机制以及spring事务又多了一份了解。

当时出现这个没见过的异常应该是，类A的一个方法需要用事务处理，在调用B的时候，没有注意B的方法有事务，但是想对B的调用异常结果做额外业务处理，就加了try catch。

今天按照这个场景还原一下 ”案发现场“。

事务A

/**
 *  事务A
 * created by mayibz on 2021/1/15
 */
@Service
@Slf4j
public class TransactionA {
    @Autowired
    private TransactionB transactionB;
    @Autowired
    private TestTransactionMapper testTransactionMapper;

    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
    public void methodA() {
        log.info("开始执行事务A");
        testTransactionMapper.insertRecord("test record");
        try {
            transactionB.methodB();
        }catch (Exception e) {
            log.info("事务B执行异常，不打印异常栈");
        }
        log.info("事务A执行完毕");
    }
}

事务B

/**
 * 事务B
 * created by mayibz on 2021/1/15
 */
@Service
@Slf4j
public class TransactionB {
    @Transactional(rollbackFor = Exception.class)
    public void methodB() {
        log.info("开始执行事务B");
        throw new RuntimeException("执行事务B异常");
    }
}

从事务A开始调用

@Test
public void test() {
    transactionA.methodA();
}

如果这样做，你觉得会出现什么情况呢？

如果只限理论学习，或者不够深入，很容易给出如下结论：

日志只会输出：开始执行事务A，开始执行事务B，事务B执行异常，不打印异常栈，事务A执行完毕
事务A成功插入一条record

然而，事实并非如此：

一次bug修复，重新认识spring事务传播机制—破案篇

那么就让我们带着问题，使用debug，福尔摩斯的华生！走进科学(源码)！！！

一次bug修复，重新认识spring事务传播机制—破案篇

注解开启的事务，当然是通过切面，然后进入到spring 提供的 TransactionAspectSupport 类中。

一次bug修复，重新认识spring事务传播机制—破案篇首先执行事务A，即插入一条recod，然后调用事务B。

一次bug修复，重新认识spring事务传播机制—破案篇

毫无疑问，事务B会抛出异常。

调用processRollback(), 处理事务B的回滚。这是事务B的当前事务状态（这块已经出现了savepoint的身影，spring处理嵌套事务的关键）

一次bug修复，重新认识spring事务传播机制—破案篇

然后根据当前状态值，在这一步，通过doSertRollbackOnly() 调用数据库的rollback，进行事务B的回滚。

protected void doSetRollbackOnly(DefaultTransactionStatus status) {
   DataSourceTransactionObject txObject = (DataSourceTransactionObject) status.getTransaction();
   if (status.isDebug()) {
      logger.debug("Setting JDBC transaction [" + txObject.getConnectionHolder().getConnection() +
            "] rollback-only");
   }
   txObject.setRollbackOnly();
}

记住这个方法，doSetRollbackOnly()，案情突破的伏笔！

一次bug修复，重新认识spring事务传播机制—破案篇