devbox
一键难忘520
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

数据库事务，Spring事务_no existing transaction found for transaction mark

作者：一键难忘520 | 2024-08-18 01:00:37

赞

踩

no existing transaction found for transaction marked with propagation 'manda

数据库事务

 

通常的观念认为，事务仅与数据库相关，它是数据库管理系统执行过程中的一个逻辑单位，由一个有限的数据库操作序列构成。数据库事务通常包含了一个序列的对数据库的读/写操作。使用事务，是为了达到以下两个目的：

  1. 为数据库操作序列提供了一个从失败中恢复到正常状态的方法，同时提供了数据库即使在异常状态下仍能保持一致性的方法
  2. 当多个应用程序在并发访问数据库时，可以在这些应用程序之间提供一个隔离方法，以防止彼此的操作互相干扰

当事务被提交给了数据库管理系统， 则数据库管理系统需要确保该事务中的所有操作都完成且其结果被永久保存在数据库中，如果事务中有的操作没有成功完成，则事务中的所有操作都需要回滚，回到事务执行前的状态；同时，该事务对数据库或者其他事务的执行无影响，所有的事务都好像在独立的运行。

举例来说，某人在商店使用电子货币购买100元的东西，当中至少包括两个操作：

  1. 该人账户减少100元
  2. 商店账户增加100元

那么此时，这个交易系统的数据库管理系统，就必须要确保以上两个操作同时成功或者同时失败。在现实情况中，失败的风险其实是很高的，网络环境、程序代码的漏洞、数据库系统/操作系统出错、甚至存储介质出错等都有可能引起其中某一方失败的情况。因此，这就需要数据库管理系统对一个执行失败的事务执行恢复操作，将数据库恢复到数据一致的状态。为了实现将数据库恢复到一致状态的功能，数据库管理系统通常都需要维护事务日志，以追踪事务中所有影响数据库数据的操作。

开启事务开使用语句BEGIN，提交事务可以使用COMMIT。默认情况下，MySQL（innodb）会启用后自动提交模式（autocommit=ON），这意味着，只要执行DML操作的语句，MySQL会立即隐式地提交事务，相比之下，oracle则需要手动开启/提交事务。

并非所有对数据库的操作都需要开启事务，只有那些需要保证一致性的场景，才考虑使用事务。如果你的程序只是执行单条查询，则没有必要使用事务，即时是多条语句，很多情况下也是不需要事务的。简言之，每次在程序中要使用事务前都应该做好评估，而不是不加思索的使用事务，不应该在程序代码中泛滥的使用事务。另外，如果开启了事务，而没有即时提交，就可能会导致数据库事务提交异常，从而引起无法预料的错误。

事务的特性

数据库事务拥有以下四个特性，习惯上被称为ACID特性：

  • 原子性（Atomicity）：事务要么全部完成，要么全部取消。如果事务崩溃，数据库的状态要回滚到事务之前
  • 一致性（Consistency）：只有合法的数据（依照关系约束和函数约束）才能写入数据库
  • 隔离性（Isolation）：如果两个事务T1和T2同时运行，不论T1和T2谁先结束，事务T1和T2执行的最终结果是相同的
  • 持久性（Durability）：一旦事务交，不管发生什么（崩溃或者出错），数据都保存在数据库中

其中原子性和隔离性比较难理解，我们单独说明。

原子性

假设有如下操作序列：

  1. begin; -- 开始一个事务
  2. update table set A = A - 1;
  3. update table set B = B + 1;
  4. -- 其他读写操作
  5. commit; -- 提交事务
  6. 复制代码

保证原子性的意思是，在执行完begin和commit之间的操作全部成功完成后，才将结果统一提交给数据库保存，如果过程中任意一个操作失败，就要撤销前面的操作，且操作不会提交给数据库保存，这样就保证了操作的原子性。

隔离性

在原子性的操作序列基础上，假设同一时刻还有另外一个操作序列：

  1. begin;
  2. update table set A = A + 1;
  3. commit;
  4. 复制代码

此时，为了确保同时只能有一个事务在修改A，就需要对数据A加上互斥锁：

  • 只有获取到锁，才能修改对应的数据A，修改数据后，需要释放锁
  • 同一时间，只能有一个事务持有数据A的互斥锁
  • 没有获取到锁的事务，需要等待锁的释放

在事务中更新某条数据获得的互斥锁，只有在事务提交或失败之后才会释放，在此之前，其他事务只能读，不能写。这是隔离性的关键，针对隔离性的强度，共有以下四种级别：

  • 串行化：指对同一行记录，读写操作都会加锁。当出现读写锁冲突的时候，后访问的事务必须等待前一个事务执行完成，才能继续执行
  • 可重复度读（MySQL默认模式）：一个事务执行过程中看到的数据，总是与这个事务在启动的时候看到的数据是一致的，在可重复读的隔离级别下，未提交变更对其它事务是不可见的
  • 读已提交（Oracle、SQL Server默认模式）：一个事务提交之后，它做的变更才会被其他事务看到
  • 读未提交：一个事务还没有提交，它做的变更就能被其他的事务看到

Spring 中的事务

Spring为事务提供了完整的支持，使用Spring来管理事务有以下好处：

  • Spring为不同的编程模型如JTA、JDBC、Hibernate、JPA等，提供了统一的事务API
  • 支持声明式事务，更容易的管理事务
  • 相比于 JTA，Spring为编程式事务提供更加简单的API

声明式事务管理

使用@Transactional注解来管理事务比较简单，示例如下：

  1. @Service
  2. public class TransactionDemo {
  3.  
  4.     @Transactional
  5.     public void declarativeUpdate() {
  6.         updateOperation1();
  7.         updateOperation2();
  8.     }
  9. }
  10. 复制代码

这样的写法相当于在进入declarativeUpdate()方法前，使用BEGIN开启了事务，在执行完方法后，使用COMMIT提交事务。

也可以将@Transactional注解放在类上面，表示类中所有的public方法都开启了事务：

  1. @Service
  2. @Transactional
  3. public class TransactionDemo {
  4.     public void declarativeUpdate() {
  5.         updateOperation1();
  6.         updateOperation2();
  7.     }
  8.   	// 其他public方法...
  9. }
  10. 复制代码

编程式事务管理

相比之下，使用编程式事务要略微复杂一些：

  1. @Service
  2. public class TransactionDemo {
  3.     
  4.     @Autowired
  5.     private TransactionTemplate transactionTemplate;
  6.  
  7.     public void programmaticUpdate() {
  8.         // 这里也可以使用Lambda表达式
  9.         transactionTemplate.execute(new TransactionCallbackWithoutResult() {
  10.             protected void doInTransactionWithoutResult(TransactionStatus status) {
  11.                 updateOperation1();
  12.                 updateOperation2();
  13.             }
  14.         });
  15.     }
  16. }
  17.  
  18. 复制代码

如果你的程序中需要针对某种特定异常有特殊操作，那么可以使用try...catch，切记此时需要调用TransactionStatus的setRollbackOnly方法：

  1. package com.example.transaction;
  2.  
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.stereotype.Service;
  5. import org.springframework.transaction.TransactionStatus;
  6. import org.springframework.transaction.annotation.Transactional;
  7. import org.springframework.transaction.support.TransactionCallbackWithoutResult;
  8. import org.springframework.transaction.support.TransactionTemplate;
  9.  
  10. @Service
  11. @Slf4j
  12. public class TransactionDemo {
  13.  
  14.     @Autowired
  15.     private TransactionTemplate transactionTemplate;
  16.  
  17.     public void programmaticUpdate() {
  18.         
  19.         transactionTemplate.execute(new TransactionCallbackWithoutResult() {
  20.             protected void doInTransactionWithoutResult(TransactionStatus status) {
  21.                 try {
  22.                     updateOperation1();
  23.                     updateOperation2();
  24.                     // 指定异常类型
  25.                 } catch (Exception ex) {
  26.                     log.info("exception happen ....");
  27.                     status.setRollbackOnly();
  28.                 }
  29.             }
  30.         });
  31.     }
  32. }
  33.  
  34. 复制代码

如果需要获取事务的执行结果，那么可以使用：

  1. package com.example.transaction;
  2.  
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.stereotype.Service;
  6. import org.springframework.transaction.TransactionStatus;
  7. import org.springframework.transaction.annotation.Transactional;
  8. import org.springframework.transaction.support.TransactionCallback;
  9. import org.springframework.transaction.support.TransactionCallbackWithoutResult;
  10. import org.springframework.transaction.support.TransactionTemplate;
  11.  
  12. @Service
  13. public class TransactionDemo {
  14.  
  15.     @Autowired
  16.     private TransactionTemplate transactionTemplate;
  17.  
  18.     public void programmaticUpdate() {
  19.         String result = transactionTemplate.execute(new TransactionCallback<String>() {
  20.             @Override
  21.             public String doInTransaction(TransactionStatus status) {
  22.                 updateOperation1();
  23.                 updateOperation2();
  24.                 // 返回执行的结果
  25.                 return "ok";
  26.             }
  27.         });
  28.     }
  29. }
  30. 复制代码

声明式事务还是编程式事务？

编程式事务声明式事务
使用方法@TransactionalTransactionTemplate
优点使用简单可以控制事务提交的开启和提交时机，能够更小粒度的控制事务的范围，也更加直观
缺点使用不当事务可能失效；多个事务性操作可能导致事务无法正常提交，导致长事务需要硬编码来控制事务
适用场景同一个方法中，事务操作比较多当事务操作的数量很少

在合适的场景使用合适的方式非常重要，在一些场景下，当对事务操作非常频繁，特别是在递归、外部通讯等耗时的场景中使用事务，很有可能就会引发长事务，那么应该考虑将非事务的部分放在前面执行，最后在写入数据环节时再开启事务。

事务传播行为

事务的传播行为指的是，当应用程序中的服务间互相调用， 如果调用方已经创建或尚未创建事务，那么被调用的服务将如何处理事务的一种行为特征，如下图所示：

Spring中事务传播特性

Spring中规定了7种类型的事务传播特性：

事务传播行为类型说明
PROPAGATION_REQUIRED如果当前没有事务，就新建一个事务，如果已经存在一个事务中；就加入到这个事务中，这是事务传播行为的默认值
PROPAGATION_REQUIRES_NEW总是创建新的事务，新的事务回滚不会影响原来的事务
PROPAGATION_NESTED如果已经存在事务，则使用嵌套事务，如果当前没有事务，则新建事务
PROPAGATION_MANDATORY使用当前事务，如果当前没有事务，就抛出异常
PROPAGATION_NEVER以非事务方式执行操作，如果当前存在事务，则抛出异常
PROPAGATION_NOT_SUPPORTED以非事务方式执行操作，如果当前存在事务，就把当前事务挂起，执行结束之后再恢复事务
PROPAGATION_SUPPORTS如果当前存在事务则加入，如果当前没有事务，就以非事务方式执行

PROPAGATION_REQUIRED

PROPAGATION_REQUIRED是@Transactional的默认值，它有以下特点：

  • 如果当前没有物理事务，那么Spring会创建一个新的事务
  • 如果当前已经存在了一个物理事务，那么有@Transactional(propagation = Propagation.REQUIRED)注解的方法就会加入这个物理事务
  • 每一个有@Transactional(propagation = Propagation.REQUIRED)注解的方法，都对应一个逻辑事务，这些逻辑事务会加入到同一个物理事务
  • 每个逻辑事务都有自己的作用范围，但是在这种传播机制下，所有这些范围都会被映射到同一个物理事务中

正因为所有的逻辑事务都会映射到同一个物理事务上，当物理事务中的任何一个逻辑事务回滚，那么这个物理事务就会回滚。以下面两个逻辑事务为例：

  1. @Transactional(propagation=Propagation.REQUIRED)
  2. public void insertFirstAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Joana Nimar");
  5.   authorRepository.save(author);
  6.   // 调用另外一个事务方法
  7.   insertSecondAuthorService.insertSecondAuthor();
  8. }
  9. 复制代码
  1. @Transactional(propagation = Propagation.REQUIRED)
  2. public void insertSecondAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Alicia Tom");
  5.   authorRepository.save(author);
  6.   // 随机抛出异常
  7.   if(new Random().nextBoolean()) {
  8.     throw new RuntimeException("DummyException: this should cause rollback of both inserts!");
  9.   }
  10. }
  11. 复制代码

它们的执行过程如下：

  1. 当执行insertFirstAuthor()方法时，由于此时还没有物理事务，Spring将会在这个方法外部创建一个逻辑事务，包裹住这个方法
  2. 当insertFirstAuthor()调用insertSecondAuthor()方法的时候，由于已经存在了一个物理事务，因此，spring会为insertSecondAuthor()创建一个逻辑事务，并加入到当前的物理事务中
  3. 如果insertSecondAuthor()抛出了异常，那么Spring将会回滚所有的逻辑事务，这也意味着，两个方法中的插入操作都不会执行

如果用图的方式来描述：

其中，START表示insertFirstAuthor()被调用，绿色的线表示insertSecondAuthor()被调用。

PROPAGATION_REQUIRES_NEW

PROPAGATION_REQUIRES_NEW表示Spring总是会创建一个新的物理事务，这种隔离级别下，内部的事务可以声明自己的超时、只读和隔离级别设置，而不是继承外部物理事务的特征。同样的，我们用图来说明这一点：

在这种隔离级别下，每个物理事务都有自己的数据库连接，也就是说，当创建内部的物理事务的时候，会同步为这个事务绑定一个新的数据库连接。当内部的物理事务运行的时候，外部的物理事务的就会暂停执行（保持连接），当内部的物理事务提交之后，外部的时候恢复运行，继续执行提交或回滚操作。

另外，在这种传播级别下，即便内部的物理事务回滚，外部的物理事务也会正常提交，如果外部的物理事务在内部的物理事务提交之后回滚，内部的物理事务并不会受到任何影响。

  1. @Transactional(propagation=Propagation.REQUIRED)
  2. public void insertFirstAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Joana Nimar");
  5.   authorRepository.save(author);
  6.   insertSecondAuthorService.insertSecondAuthor();
  7. }
  8. 复制代码
  1. @Transactional(propagation = Propagation.REQUIRES_NEW)
  2. public void insertSecondAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Alicia Tom");
  5.   authorRepository.save(author);
  6.   if(new Random().nextBoolean()) {    
  7.     throw new RuntimeException ("DummyException: this should cause rollback of second insert only!");
  8.   }
  9. }
  10. 复制代码

它们的执行过程如下：

  1. 当调用insertFirstAuthor()的时候会创建一个新的物理事务，因为此时还没有物理事务

  2. 当insertFirstAuthor()调用insertSecondAuthor()的时候，Spring将会创建另外一个内部的物理事务

  3. 当发生运行时异常（RuntimeException）的时候，两个物理事务会按照内部事务、外部事务的顺序先后进行回滚，发生这种情况的原因是在insertSecondAuthor()中抛出的异常被传播到调用者即insertFirstAuthor()中，因此，也会导致外部物理事务的回滚。如果只需要回滚内部物理事务而不影响外部事务，那么需要在insertFirstAuthor()方法中捕获并处理异常：

    1. @Transactional(propagation = Propagation.REQUIRED)
    2. public void insertFirstAuthor() {
    3.   Author author = new Author();
    4.   author.setName("Joana Nimar");
    5.   authorRepository.save(author);
    6.   try {
    7.     insertSecondAuthorService.insertSecondAuthor();
    8.   } catch (RuntimeException e) {
    9.     System.err.println("Exception: " + e);
    10.   }
    11. }
    12. 复制代码

PROPAGATION_NESTED

Propagation.NESTED与PROPAGATION_REQUIRED比较类似，只是会使用保存点（savepoint），换句话说，内部逻辑事务可以部分回滚。

savepoint是数据库事务中的“子事务”，事务可以回滚到savepoint而不影响savepoint创建前的变化，而不是回滚整个事务。

PROPAGATION_MANDATORY

PROPAGATION_MANDATORY表示，一定要有一个物理事务，否则就会抛出异常：

  1. org.springframework.transaction.IllegalTransactionStateException: No existing transaction found for transaction marked with propagation 'mandatory'.
  2. 复制代码

考虑下面的例子：

  1. @Transactional(propagation=Propagation.REQUIRED)
  2. public void insertFirstAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Joana Nimar");
  5.   authorRepository.save(author);
  6.   insertSecondAuthorService.insertSecondAuthor();
  7. }
  8. 复制代码
  1. @Transactional(propagation = Propagation.MANDATORY)
  2. public void insertSecondAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Alicia Tom");
  5.   authorRepository.save(author);
  6.   if (new Random().nextBoolean()) {
  7.     throw new RuntimeException("DummyException: this should cause rollback of both inserts!");
  8.   }
  9. }
  10. 复制代码

当insertFirstAuthor()调用insertSecondAuthor()方法的时候，因为外部已经存在了物理事务（通过Propagation.REQUIRED创建），那么insertSecondAuthor()将会加入这个事务，如果内部事务回滚了，外部事务也会回滚，这一点和Propagation.REQUIRED相同。

PROPAGATION_NEVER

PROPAGATION_NEVER表示，如果当前存在物理事务，那么就抛出异常：

  1. org.springframework.transaction.IllegalTransactionStateException: Existing transaction found for transaction marked with propagation 'never'
  2. 复制代码

  1. @Transactional(propagation = Propagation.NEVER)
  2. public void insertFirstAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Joana Nimar");
  5.   authorRepository.save(author);
  6. }
  7. 复制代码

它的执行过程如下：

  1. 当insertFirstAuthor()方法被调用，Spring将会查找已有的物理事务
  2. 如果没有开启事务，则方法就会正常运行
  3. 当代码运行到save()方法时,Spring将会打开一个物理事务，专门用于运行此方法，这是因为save()方法使用了默认的Propagation.REQUIRED属性，此时回滚？？

当调用有@Transactional(propagation = Propagation.NEVER)注解的方法，一定要确保没有打开任何物理事务。

PROPAGATION_NOT_SUPPORTED

PROPAGATION_NOT_SUPPORTED表示，如果当前存在一个物理事务，那么它就会将这个事务挂起，然后以非事务的方式来运行程序，当执行完成后，事务会自动恢复。

正在上传…重新上传取消

  1. @Transactional(propagation = Propagation.REQUIRED)
  2. public void insertFirstAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Joana Nimar");
  5.   authorRepository.save(author);
  6.   insertSecondAuthorService.insertSecondAuthor();
  7. }
  8. 复制代码
  1. @Transactional(propagation = Propagation.NOT_SUPPORTED)
  2. public void insertSecondAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Alicia Tom");  
  5.   authorRepository.save(author);
  6.   if (new Random().nextBoolean()) {
  7.     throw new RuntimeException("DummyException: this should cause "
  8.                                + "rollback of the insert triggered in insertFirstAuthor() !");
  9.   }
  10. }
  11. 复制代码

它的执行过程如下：

  • 当调用insertFirstAuthor()的时候，由于此时还没有物理事务，因为Spring会创建一个新的物理事务
  • 然后执行insertFirstAuthor()中的save()方法，保存"Joana Nimar"
  • 当insertFirstAuthor()调用insertSecondAuthor()的时候，Spring会查看是否已有存在物理事务，在继续执行代码之前，Spring会将insertFirstAuthor()中开启的事务挂起
  • insertSecondAuthor()会以非事务的方式进行执行，直到调用save()方法，默认情况下，save()方法会创建一个新的物理事务，执行insert语句并提交事务
  • insertSecondAuthor()剩余的代码会在物理事务之外执行
  • 当执行完insertSecondAuthor()之后，Spring将会恢复被挂起的物理事务。如果在执行insertSecondAuthor()方法的时候发生了运行时异常（RuntimeException），这个异常会被传播到insertFirstAuthor()方法中，因此，insertFirstAuthor()的事务也会回滚

需要注意的是，即便当前的事务被挂起了，也应该避免执行运行时间很长的任务，这是因为被挂起的事务的数据库连接还是激活的状态，这意味着，数据库连接池无法重用这个连接：

  1. ...
  2. Suspending current transaction
  3. HikariPool-1 - Pool stats (total=10, active=1, idle=9, waiting=0)
  4. Resuming suspended transaction after completion of inner transaction
  5. 复制代码

PROPAGATION_SUPPORTS

PROPAGATION_SUPPORTS意味着，如果当前存在物理事务，那么就加入这个事务，如果没有物理事务，那么就以非事务的方式运行。

  1. @Transactional(propagation = Propagation.REQUIRED)
  2. public void insertFirstAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Joana Nimar");
  5.   authorRepository.save(author);
  6.   insertSecondAuthorService.insertSecondAuthor();
  7. }
  8. 复制代码
  1. @Transactional(propagation = Propagation.SUPPORTS)
  2. public void insertSecondAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Alicia Tom");
  5.   authorRepository.save(author);
  6.   if (new Random().nextBoolean()) {
  7.     throw new RuntimeException("DummyException: this should cause rollback of both inserts!");
  8.   }
  9. }
  10. 复制代码

它的执行过程如下：

  1. 当执行insertFirstAuthor()的时候，因为还没有物理事务，因此，Spring会创建一个新的物理事务
  2. 执行insertFirstAuthor()中的save()方法，保存"Joana Nimar"
  3. 当insertFirstAuthor()调用insertSecondAuthor()方法的时候，因为已经存在了一个物理事务，因此insertSecondAuthor()在这个物理事务内部创建一个逻辑事务，如果发生了运行时异常，那么内部和外部的逻辑事务都将回滚

如果在insertFirstAuthor()中捕获异常：

  1. @Transactional(propagation = Propagation.REQUIRED)
  2. public void insertFirstAuthor() {
  3.   Author author = new Author();
  4.   author.setName("Joana Nimar");
  5.   authorRepository.save(author);
  6.   try {
  7.     insertSecondAuthorService.insertSecondAuthor();
  8.   } catch (RuntimeException e) {
  9.     System.err.println("Exception: " + e);
  10.   }
  11. }
  12. 复制代码

此时，整个事务依然都会回滚，这是因为，两个逻辑事务的作用范围都映射到了同一个物理事务上。

如果去掉insertFirstAuthor()的 @Transactional(propagation = Propagation.REQUIRED)注解，此时，执行过程如下：

  1. 当调用insertFirstAuthor()的时候，将不会创建物理事务
  2. insertFirstAuthor()将以非事务的方式运行，直到调用save()方法，默认情况下，save()方法会创建一个新的物理事务，执行insert语句并提交事务
  3. 当insertFirstAuthor()调用insertSecondAuthor()的时候，由于当前没有物理事务，Spring也不会创建新的物理事务
  4. insertSecondAuthor()将以非事务的方式运行，直到调用save()方法，默认情况下，save()方法会创建一个新的物理事务，执行insert语句并提交事务
  5. 当发生运行时异常时，由于不存在物理事务，这两个方法都不会发生回滚

Spring 事务的实现原理

了解他们的基本概念和使用方法，接下来我们将一起分析Spring事务的实现原理。在正式分析实现过程前，我们首先需要了解一些比较核心API，这将帮助抽丝剥茧的理解Spring事务的实现原理。

Spring 事务的核心API

事务操作相关的API：

  • Spring事务@Enanle模块驱动 - @EnableTranSactionManagement
  • Spring事务注解 - @Transactional
  • Spring事务事件监听器 - @TransactionalEventListener

事务抽象相关的API

  • Spring平台事务管理器 - PlatformTransactionManager

  • Spring事务定义 - TransactionDefinition

  • Spring事务状态 - TransactionStatus

  • Spring事务代理配置 - ProxyTransactionManagementConfiguration

AOP相关的API：

  • Spring事务PointcutAdvisor实现 - BeanFactoryTransactionAttrubuteSourceAdvisor
  • Spring事务MethodInterceptor实现 - TransactionInterceptor
  • Spring事务属性源 - TransactionAttributeSource

其中，PlatformTransactionManager、TransactionDefinition、TransactionStatus最为重要，他们之间的关系如下：

PlatformTransactionManager

PlatformTransactionManager是Spring对于事务模型的抽象，它代表事务的整体执行过程。通常事务都应用在关系型数据库中，Spring对于事务的读写的模型做了更高层次的抽象，使得其可以应用在任何需要数据一致性的场景，比如JMX等，Spring将这些场景统一的抽象为commit和rollback两个核心方法。

PlatformTransactionManager的核心方法：

  1. package org.springframework.transaction;
  2.  
  3. import org.springframework.lang.Nullable;
  4.  
  5. public interface PlatformTransactionManager {
  6.     // 获取事务的执行状态
  7.     TransactionStatus getTransaction(@Nullable TransactionDefinition var1) throws TransactionException;
  8.     // 提交事务
  9.     void commit(TransactionStatus var1) throws TransactionException;
  10.     // 回滚事务
  11.     void rollback(TransactionStatus var1) throws TransactionException;
  12. }
  13. 复制代码

这里需要注意的是，如果有@Transactional注解的方法，如果他们对应的传播行为不同，那么其对应的TransactionDefinition也是不同的，这也就是说getTransaction这个方法获取到的并不是物理事务，而是某个具体方法的逻辑事务，同理，commit和rollback也是对应的这个逻辑事务。

TransactionDefinition

TransactionDefinition是事务的元信息定义，类似于Spring IOC中BeanDefinition。实际上，Spring中事务的定义参考了EJB中对于事务的定义，TransactionDefinition的核心方法有：

  1. package org.springframework.transaction;
  2.  
  3. import org.springframework.lang.Nullable;
  4.  
  5. public interface TransactionDefinition {
  6.     // 传播行为的枚举值...
  7.     
  8.     // 返回事务的传播行为，默认值为 REQUIRED。
  9.     int getPropagationBehavior();
  10.     //返回事务的隔离级别，默认值是 DEFAULT
  11.     int getIsolationLevel();
  12.     // 返回事务的超时时间，默认值为-1。如果超过该时间限制但事务还没有完成，则自动回滚事务。
  13.     int getTimeout();
  14.     // 返回是否为只读事务，默认值为 false
  15.     boolean isReadOnly();
  16.  
  17.     @Nullable
  18.     String getName();
  19. }
  20. 复制代码

TransactionStatus

事务分为逻辑事务和物理事务，逻辑事务是指代码中事务的操作；物理事务是通过数据库连接来获取相关的物理的连接以及相关的数据库的事务。TransactionStatus是用来描述当前逻辑事务的执行情况，其核心方法及含义：

  1. public interface TransactionStatus {
  2.     // 当前事务执行是否在新的事务
  3.     boolean isNewTransaction();
  4.     // 是否有恢复点（小范围的回滚）
  5.     boolean hasSavepoint();
  6.     // 设置当前事务为只回滚
  7.     void setRollbackOnly();
  8.     // 当前事务是否为只回滚
  9.     boolean isRollbackOnly(); 
  10.     // 当前事务是否已完成
  11.     boolean isCompleted;
  12. }
  13. 复制代码

从Spring5.2开始，对这个接口进行了拆分，将部分方法放置在了TransactionExecution中：

  1. /**
  2.  * @since 5.2
  3.  */
  4. public interface TransactionExecution {
  5. 	boolean isNewTransaction();
  6. 	void setRollbackOnly();
  7. 	boolean isRollbackOnly();
  8. 	boolean isCompleted();
  9. }
  10. 复制代码

事务实现过程分析

@Transactional与AOP

@Transactional基于Spring AOP实现，其执行流程大致如下：

针对于@Transactional的实现，几个关键点是：

  • Spring中是如何定义Interceptor的？也就是说，哪些方法会被拦截？
  • 拦截后，代理类中invoke方法是如何执行的？

@Transactional的实现原理

首先我们来观察@Transactional的定义：

  1. // 可以作用在类上面，也可以作用在方法上
  2. @Target({ElementType.TYPE, ElementType.METHOD})
  3. @Retention(RetentionPolicy.RUNTIME)
  4. @Inherited
  5. @Documented
  6. public @interface Transactional {
  7.  
  8. 	// 事务管理器（PlatformTransactionManager），和transactionManager互为别名
  9. 	@AliasFor("transactionManager")
  10.     
  11. 	String value() default "";
  12.  
  13. 	@AliasFor("value")
  14. 	String transactionManager() default "";
  15.  
  16. 	// 事务的传播行为
  17. 	Propagation propagation() default Propagation.REQUIRED;
  18.  
  19. 	// 事务的超时时间，默认是-1，表示永远不会超时
  20. 	int timeout() default TransactionDefinition.TIMEOUT_DEFAULT;
  21.  
  22.     // 是否只读事务，如果是只读事务，Spring会在执行事务的时候会做相应的优化
  23. 	boolean readOnly() default false;
  24.  
  25.     // 回滚的异常类型
  26. 	Class<? extends Throwable>[] rollbackFor() default {};
  27. }
  28. 复制代码

如果需要在SpringBoot中要使用@Transactional，我们需要添加@EnableTransactionManagement注解：

  1. @Target(ElementType.TYPE)
  2. @Retention(RetentionPolicy.RUNTIME)
  3. @Documented
  4. // 自动装配类
  5. @Import(TransactionManagementConfigurationSelector.class)
  6. public @interface EnableTransactionManagement {
  7.     // ...
  8. }
  9. 复制代码

进入这个注解对应的自动装配类：

  1. public class TransactionManagementConfigurationSelector extends AdviceModeImportSelector<EnableTransactionManagement> {
  2.  
  3. 	@Override
  4. 	protected String[] selectImports(AdviceMode adviceMode) {
  5.         // 支持动态代理和ASPECTJ两种AOP的实现方法，默认是代理的方式
  6. 		switch (adviceMode) {
  7. 			case PROXY:
  8. 				return new String[] {AutoProxyRegistrar.class.getName(),
  9. 						ProxyTransactionManagementConfiguration.class.getName()};
  10. 			case ASPECTJ:
  11. 				return new String[] {determineTransactionAspectClass()};
  12. 			default:
  13. 				return null;
  14. 		}
  15. 	}
  16. }
  17. 复制代码

进入代理模式的配置类ProxyTransactionManagementConfiguration，这是一个标准的SpringBoot的配置类：

  1. @Configuration(proxyBeanMethods = false)
  2. @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  3. public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration {
  4.  
  5. 	@Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME)
  6. 	@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  7. 	public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor(
  8. 			TransactionAttributeSource transactionAttributeSource, TransactionInterceptor transactionInterceptor) {
  9.  
  10. 		BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor();
  11. 		advisor.setTransactionAttributeSource(transactionAttributeSource);
  12. 		advisor.setAdvice(transactionInterceptor);
  13. 		if (this.enableTx != null) {
  14. 			advisor.setOrder(this.enableTx.<Integer>getNumber("order"));
  15. 		}
  16. 		return advisor;
  17. 	}
  18.  
  19.     // 获取AOP的注解
  20. 	@Bean
  21. 	@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  22. 	public TransactionAttributeSource transactionAttributeSource() {
  23. 		return new AnnotationTransactionAttributeSource();
  24. 	}
  25.  
  26. 	@Bean
  27. 	@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  28. 	public TransactionInterceptor transactionInterceptor(TransactionAttributeSource transactionAttributeSource) {
  29. 		TransactionInterceptor interceptor = new TransactionInterceptor();
  30. 		interceptor.setTransactionAttributeSource(transactionAttributeSource);
  31. 		if (this.txManager != null) {
  32. 			interceptor.setTransactionManager(this.txManager);
  33. 		}
  34. 		return interceptor;
  35. 	}
  36.  
  37. }
  38. 复制代码

TransactionAttributeSource前面我们介绍过，它是Spring事务属性源 ，进入AnnotationTransactionAttributeSource的构造方法，我们可以看到：

  1. 	public AnnotationTransactionAttributeSource(boolean publicMethodsOnly) {
  2. 		this.publicMethodsOnly = publicMethodsOnly;
  3. 		if (jta12Present || ejb3Present) {
  4. 			this.annotationParsers = new LinkedHashSet<>(4);
  5. 			this.annotationParsers.add(new SpringTransactionAnnotationParser());
  6. 			if (jta12Present) {
  7. 				this.annotationParsers.add(new JtaTransactionAnnotationParser());
  8. 			}
  9. 			if (ejb3Present) {
  10. 				this.annotationParsers.add(new Ejb3TransactionAnnotationParser());
  11. 			}
  12. 		}
  13. 		else {
  14. 			this.annotationParsers = Collections.singleton(new SpringTransactionAnnotationParser());
  15. 		}
  16. 	}
  17. 复制代码

这里会将一些注解解析类添加到AnnotationTransactionAttributeSource的annotationParsers中，这里以默认的SpringTransactionAnnotationParser为例：

  1. 	@Override
  2. 	@Nullable
  3. 	public TransactionAttribute parseTransactionAnnotation(AnnotatedElement element) {
  4.         // 获取拥有@Transactional注解的类或方法
  5. 		AnnotationAttributes attributes = AnnotatedElementUtils.findMergedAnnotationAttributes(
  6. 				element, Transactional.class, false, false);
  7. 		if (attributes != null) {
  8. 			return parseTransactionAnnotation(attributes);
  9. 		}
  10. 		else {
  11. 			return null;
  12. 		}
  13. 	}
  14. 复制代码

JtaTransactionAnnotationParser和Ejb3TransactionAnnotationParser也是类似的实现，这说明Spring不仅支持org.springframework.transaction.annotation.Transactional还支持javax.transaction.Transactional.class和javax.ejb.TransactionAttribute，在Spring统一的编程模型下，这三个注解都可以通用。

接下来我们查看执行的核心方法，即TransactionInterceptor的invoke方法：

  1. @Override
  2. 	@Nullable
  3. 	public Object invoke(MethodInvocation invocation) throws Throwable {
  4.         
  5. 		// ...
  6.         
  7. 		return invokeWithinTransaction(invocation.getMethod(), targetClass, new CoroutinesInvocationCallback() {
  8. 			@Override
  9. 			@Nullable
  10. 			public Object proceedWithInvocation() throws Throwable {
  11. 				return invocation.proceed();
  12. 			}
  13. 			@Override
  14. 			public Object getTarget() {
  15. 				return invocation.getThis();
  16. 			}
  17. 			@Override
  18. 			public Object[] getArguments() {
  19. 				return invocation.getArguments();
  20. 			}
  21. 		});
  22. 	}
  23. 复制代码

进入invokeWithinTransaction方法：

  1. 	@Nullable
  2. 	protected Object invokeWithinTransaction(Method method, @Nullable Class<?> targetClass,
  3. 			final InvocationCallback invocation) throws Throwable {
  4.  
  5. 		// If the transaction attribute is null, the method is non-transactional.
  6. 		TransactionAttributeSource tas = getTransactionAttributeSource();
  7. 		final TransactionAttribute txAttr = (tas != null ? tas.getTransactionAttribute(method, targetClass) : null);
  8. 		final TransactionManager tm = determineTransactionManager(txAttr);
  9. 		PlatformTransactionManager ptm = asPlatformTransactionManager(tm);
  10.         
  11. 		final String joinpointIdentification = methodIdentification(method, targetClass, txAttr);
  12.  
  13. 		if (txAttr == null || !(ptm instanceof CallbackPreferringPlatformTransactionManager)) {
  14. 			TransactionInfo txInfo = createTransactionIfNecessary(ptm, txAttr, joinpointIdentification);
  15.  
  16. 			Object retVal;
  17. 			try {
  18. 				// 环绕通知
  19. 				retVal = invocation.proceedWithInvocation();
  20. 			}
  21. 			catch (Throwable ex) {
  22. 				// target invocation exception
  23.                 // 发生异常
  24. 				completeTransactionAfterThrowing(txInfo, ex);
  25. 				throw ex;
  26. 			}
  27. 			finally {
  28. 				cleanupTransactionInfo(txInfo);
  29. 			}
  30.  
  31. 			if (retVal != null && vavrPresent && VavrDelegate.isVavrTry(retVal)) {
  32. 				// Set rollback-only in case of Vavr failure matching our rollback rules...
  33. 				TransactionStatus status = txInfo.getTransactionStatus();
  34. 				if (status != null && txAttr != null) {
  35. 					retVal = VavrDelegate.evaluateTryFailure(retVal, txAttr, status);
  36. 				}
  37. 			}
  38. 			// 正常提交
  39. 			commitTransactionAfterReturning(txInfo);
  40. 			return retVal;
  41. 		}
  42. 		// 异常回滚
  43. 		else {
  44. 			Object result;
  45. 			final ThrowableHolder throwableHolder = new ThrowableHolder();
  46.  
  47. 			// It's a CallbackPreferringPlatformTransactionManager: pass a TransactionCallback in.
  48. 			try {
  49. 				result = ((CallbackPreferringPlatformTransactionManager) ptm).execute(txAttr, status -> {
  50. 					TransactionInfo txInfo = prepareTransactionInfo(ptm, txAttr, joinpointIdentification, status);
  51. 					try {
  52. 						Object retVal = invocation.proceedWithInvocation();
  53. 						if (retVal != null && vavrPresent && VavrDelegate.isVavrTry(retVal)) {
  54. 							// Set rollback-only in case of Vavr failure matching our rollback rules...
  55. 							retVal = VavrDelegate.evaluateTryFailure(retVal, txAttr, status);
  56. 						}
  57. 						return retVal;
  58. 					}
  59. 					catch (Throwable ex) {
  60. 						if (txAttr.rollbackOn(ex)) {
  61. 							// A RuntimeException: will lead to a rollback.
  62. 							if (ex instanceof RuntimeException) {
  63. 								throw (RuntimeException) ex;
  64. 							}
  65. 							else {
  66. 								throw new ThrowableHolderException(ex);
  67. 							}
  68. 						}
  69. 						else {
  70. 							// A normal return value: will lead to a commit.
  71. 							throwableHolder.throwable = ex;
  72. 							return null;
  73. 						}
  74. 					}
  75. 					finally {
  76. 						cleanupTransactionInfo(txInfo);
  77. 					}
  78. 				});
  79. 			}
  80. 			catch (ThrowableHolderException ex) {
  81. 				throw ex.getCause();
  82. 			}
  83. 			catch (TransactionSystemException ex2) {
  84. 				if (throwableHolder.throwable != null) {
  85. 					logger.error("Application exception overridden by commit exception", throwableHolder.throwable);
  86. 					ex2.initApplicationException(throwableHolder.throwable);
  87. 				}
  88. 				throw ex2;
  89. 			}
  90. 			catch (Throwable ex2) {
  91. 				if (throwableHolder.throwable != null) {
  92. 					logger.error("Application exception overridden by commit exception", throwableHolder.throwable);
  93. 				}
  94. 				throw ex2;
  95. 			}
  96.  
  97. 			// Check result state: It might indicate a Throwable to rethrow.
  98. 			if (throwableHolder.throwable != null) {
  99. 				throw throwableHolder.throwable;
  100. 			}
  101. 			return result;
  102. 		}
  103. 	}
  104. 复制代码

其中：

  1. protected void commitTransactionAfterReturning(@Nullable TransactionInfo txInfo) {
  2. 		if (txInfo != null && txInfo.getTransactionStatus() != null) {
  3. 			txInfo.getTransactionManager().commit(txInfo.getTransactionStatus());
  4. 		}
  5. 	}
  6. 复制代码

进入commit方法：

  1. 	@Override
  2. 	public final void commit(TransactionStatus status) throws TransactionException {
  3. 		if (status.isCompleted()) {
  4. 			throw new IllegalTransactionStateException(
  5. 					"Transaction is already completed - do not call commit or rollback more than once per transaction");
  6. 		}
  7.  
  8. 		DefaultTransactionStatus defStatus = (DefaultTransactionStatus) status;
  9. 		if (defStatus.isLocalRollbackOnly()) {
  10. 			if (defStatus.isDebug()) {
  11. 				logger.debug("Transactional code has requested rollback");
  12. 			}
  13. 			processRollback(defStatus, false);
  14. 			return;
  15. 		}
  16.  
  17. 		if (!shouldCommitOnGlobalRollbackOnly() && defStatus.isGlobalRollbackOnly()) {
  18. 			if (defStatus.isDebug()) {
  19. 				logger.debug("Global transaction is marked as rollback-only but transactional code requested commit");
  20. 			}
  21. 			processRollback(defStatus, true);
  22. 			return;
  23. 		}
  24.  
  25. 		processCommit(defStatus);
  26. 	}
  27. 复制代码

继续进入processCommit方法：

  1. private void processCommit(DefaultTransactionStatus status) throws TransactionException {
  2. 		try {
  3. 			boolean beforeCompletionInvoked = false;
  4.  
  5. 			try {
  6. 				boolean unexpectedRollback = false;
  7. 				prepareForCommit(status);
  8. 				triggerBeforeCommit(status);
  9. 				triggerBeforeCompletion(status);
  10. 				beforeCompletionInvoked = true;
  11.  
  12. 				if (status.hasSavepoint()) {
  13. 					if (status.isDebug()) {
  14. 						logger.debug("Releasing transaction savepoint");
  15. 					}
  16. 					unexpectedRollback = status.isGlobalRollbackOnly();
  17. 					status.releaseHeldSavepoint();
  18. 				}
  19. 				else if (status.isNewTransaction()) {
  20. 					if (status.isDebug()) {
  21. 						logger.debug("Initiating transaction commit");
  22. 					}
  23. 					unexpectedRollback = status.isGlobalRollbackOnly();
  24.                                        // 真正提交事务的方法
  25. 					doCommit(status);
  26. 				}
  27. 				else if (isFailEarlyOnGlobalRollbackOnly()) {
  28. 					unexpectedRollback = status.isGlobalRollbackOnly();
  29. 				}
  30.  
  31. 				// Throw UnexpectedRollbackException if we have a global rollback-only
  32. 				// marker but still didn't get a corresponding exception from commit.
  33. 				if (unexpectedRollback) {
  34. 					throw new UnexpectedRollbackException(
  35. 							"Transaction silently rolled back because it has been marked as rollback-only");
  36. 				}
  37. 			}
  38. 			catch (UnexpectedRollbackException ex) {
  39. 				// can only be caused by doCommit
  40. 				triggerAfterCompletion(status, TransactionSynchronization.STATUS_ROLLED_BACK);
  41. 				throw ex;
  42. 			}
  43. 			catch (TransactionException ex) {
  44. 				// can only be caused by doCommit
  45. 				if (isRollbackOnCommitFailure()) {
  46. 					doRollbackOnCommitException(status, ex);
  47. 				}
  48. 				else {
  49. 					triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN);
  50. 				}
  51. 				throw ex;
  52. 			}
  53. 			catch (RuntimeException | Error ex) {
  54. 				if (!beforeCompletionInvoked) {
  55. 					triggerBeforeCompletion(status);
  56. 				}
  57. 				doRollbackOnCommitException(status, ex);
  58. 				throw ex;
  59. 			}
  60.  
  61. 			// Trigger afterCommit callbacks, with an exception thrown there
  62. 			// propagated to callers but the transaction still considered as committed.
  63. 			try {
  64. 				triggerAfterCommit(status);
  65. 			}
  66. 			finally {
  67. 				triggerAfterCompletion(status, TransactionSynchronization.STATUS_COMMITTED);
  68. 			}
  69.  
  70. 		}
  71. 		finally {
  72. 			cleanupAfterCompletion(status);
  73. 		}
  74. 	}
  75.  
  76. 复制代码

以DataSourceTransactionManager中的doCommit为例：

  1. 	@Override
  2. 	protected void doCommit(DefaultTransactionStatus status) {
  3. 		DataSourceTransactionObject txObject = (DataSourceTransactionObject) status.getTransaction();
  4.                 // 获取数据库连接
  5. 		Connection con = txObject.getConnectionHolder().getConnection();
  6. 		try {
  7.                         // 提交事务
  8. 			con.commit();
  9. 		}
  10. 		catch (SQLException ex) {
  11. 			throw translateException("JDBC commit", ex);
  12. 		}
  13. 	}
  14. 复制代码

可以看到，这里才是物理事务的提交。类似的，回滚也是获取数据库的连接，然后调用回滚的方法：

  1. 	@Override
  2. 	protected void doRollback(DefaultTransactionStatus status) {
  3. 		DataSourceTransactionObject txObject = (DataSourceTransactionObject) status.getTransaction();
  4. 		Connection con = txObject.getConnectionHolder().getConnection();
  5. 		try {
  6.        // 回滚事务
  7. 			con.rollback();
  8. 		}
  9. 		catch (SQLException ex) {
  10. 			throw translateException("JDBC rollback", ex);
  11. 		}
  12. 	}
  13. 复制代码

TransactionTemplate的实现原理

有了@Transactional实现过程的基础，TransactionTemplate的实现就比较容易理解了，TransactionTemplate本质上是一种模板方法的设计模式的应用：

  1. 	@SuppressWarnings("serial")
  2. public class TransactionTemplate extends DefaultTransactionDefinition
  3. 		implements TransactionOperations, InitializingBean {
  4.     @Override
  5. 	@Nullable
  6. 	public <T> T execute(TransactionCallback<T> action) throws TransactionException {
  7.                         //...
  8. 			TransactionStatus status = this.transactionManager.getTransaction(this);
  9. 			T result;
  10. 			try {
  11.                                 // 模板方法
  12. 				result = action.doInTransaction(status);
  13. 			}
  14. 			catch (RuntimeException | Error ex) {
  15.                                 // 发生异常即回滚
  16. 				rollbackOnException(status, ex);
  17. 				throw ex;
  18. 			}
  19. 			catch (Throwable ex) {
  20. 				rollbackOnException(status, ex);
  21. 				throw new UndeclaredThrowableException(ex, "TransactionCallback threw undeclared checked exception");
  22. 			}
  23.                         // 没有发生异常就提交事务
  24. 			this.transactionManager.commit(status);
  25. 			return result;
  26. 		}
  27. }
  28. 复制代码

这一点可以从TransactionCallbackWithoutResult这个抽象类中就可以看出：

  1. public abstract class TransactionCallbackWithoutResult implements TransactionCallback<Object> {
  2.  
  3. 	@Override
  4. 	@Nullable
  5. 	public final Object doInTransaction(TransactionStatus status) {
  6. 		doInTransactionWithoutResult(status);
  7. 		return null;
  8. 	}
  9.  
  10. 	// 方法的实现就是我们需要执行的业务代码
  11. 	protected abstract void doInTransactionWithoutResult(TransactionStatus status);
  12.  
  13. }
  14. 复制代码

事务失效及长事务

事务失效

方法内部调用

在实际开发中，如果碰到长事务，一个自然的想法，就是将其中涉及到事务的部分单独抽出来，只在这个方法上添加@Transactional注解。

  1. @Service
  2. public class UserService {
  3.  
  4.     @Autowired
  5.     private UserMapper userMapper;
  6.  
  7.     //@Transactional
  8.     public void add(UserModel userModel) {
  9.         // do something...
  10.         updateStatus(userModel);
  11.     }
  12.  
  13.     @Transactional
  14.     public void updateStatus(UserModel userModel) {
  15.         doSameThing();
  16.     }
  17. }
  18.  
  19. 复制代码

这是一个非常常见的误区，通过前文的分析，我们已经知道@Transactional是通过AOP来实现的。在调用add()方法的时候，add()方法并没有获取到事务的功能，那么在调用updateStatus()的时候，其实就是this.updateStatus()，这时候的this并不是代理对象代理之后的方法，自然也不会再拥有事务的功能了。解决方法内部调用导致事务失效的方法共有以下三种。

方法一：添加一个Service方法：

  1. @Servcie
  2. public class ServiceA {
  3.    @Autowired
  4.    prvate ServiceB serviceB;
  5.  
  6.    public void save(User user) {
  7.          // do something...
  8.          serviceB.doSave(user);
  9.    }
  10.  }
  11.  
  12.  @Servcie
  13.  public class ServiceB {
  14.  
  15.     @Transactional(rollbackFor=Exception.class)
  16.     public void doSave(User user) {
  17.        addData1();
  18.        updateData2();
  19.     }
  20.  
  21.  }
  22. 复制代码

方法二：如果不想新增一个Service类，那么在Service类中注入自己也是一种选择。

  1. @Servcie
  2. public class ServiceA {
  3.    @Autowired
  4.    prvate ServiceA serviceA;
  5.  
  6.    public void save(User user) {
  7.         // do something...
  8.         serviceA.doSave(user);
  9.    }
  10.  
  11.    @Transactional(rollbackFor=Exception.class)
  12.    public void doSave(User user) {
  13.        addData1();
  14.        updateData2();
  15.     }
  16.  }
  17. 复制代码

方法三：通过AopContent类，在该Service类中使用AopContext.currentProxy()获取代理对象。

  1. @Servcie
  2. public class ServiceA {
  3.  
  4.    public void save(User user) {
  5.          // do something...
  6.          ((ServiceA)AopContext.currentProxy()).doSave(user);
  7.    }
  8.  
  9.    @Transactional(rollbackFor=Exception.class)
  10.    public void doSave(User user) {
  11.        addData1();
  12.        updateData2();
  13.     }
  14.  }
  15. 复制代码

访问权限不正确

private方法将会导致事务失效：

  1. @Service
  2. public class UserService {
  3.     
  4.     @Transactional
  5.     private void add(UserModel userModel) {
  6.          saveData(userModel);
  7.          updateData(userModel);
  8.     }
  9. }
  10. 复制代码

这是因为在AbstractFallbackTransactionAttributeSource类的computeTransactionAttribute方法中有个判断，如果目标方法不是public，则TransactionAttribute返回 null （空) ，即不支持事务。

  1. protected TransactionAttribute computeTransactionAttribute(Method method, @Nullable Class<?> targetClass) {
  2.     // 如果方法不是pulic的，就返回null
  3.     if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
  4.       return null;
  5.     }
  6.   	// ...
  7.   }
  8. 复制代码

方法使用final修饰

如果一个事务方法被定义成了final，也会导致事务不生效，这是因为通过cglib是通过生成子类来方式生成代理类。如果方法被定义为final，则意味着该方法无法被重写，无法添加事务功能。

  1. @Service
  2. public class UserService {
  3.  
  4.     @Transactional
  5.     public final void add(UserModel userModel){
  6.         saveData(userModel);
  7.         updateData(userModel);
  8.     }
  9. }
  10. 复制代码

未被Spring管理

Spring在依赖查找的时候，是从BeanFactory中取出需要被代理的类，也就是说，事物生效的前提是，对象要被Spring管理。我们通过可以使用@Service、Component、@Repository等来实现Bean的依赖注入。

  1. //@Service
  2. public class UserService {
  3.  
  4.     @Transactional
  5.     public void add(UserModel userModel) {
  6.          saveData(userModel);
  7.          updateData(userModel);
  8.     }    
  9. }
  10. 复制代码

多线程调用

事物有一个很重要的特性，就是不能跨线程使用，在如下的例子中，虽然我们使用了@Transactional注解，但依然无法管理事务：

  1. @Slf4j
  2. @Service
  3. public class UserService {
  4.  
  5.     @Autowired
  6.     private UserMapper userMapper;
  7.     @Autowired
  8.     private RoleService roleService;
  9.  
  10.     @Transactional
  11.     public void add(UserModel userModel) throws Exception {
  12.         userMapper.insertUser(userModel);
  13.         new Thread(() -> {
  14.             roleService.doOtherThing();
  15.         }).start();
  16.     }
  17. }
  18.  
  19. @Service
  20. public class RoleService {
  21.  
  22.     @Transactional
  23.     public void doOtherThing() {
  24.         System.out.println("保存role表数据");
  25.     }
  26. }
  27. 复制代码

这是因为insertUser()方法和doOtherThing()方法在不同的线程中，那么它们获取到的数据库连接也是不一样的，这就导致，这两个方法在不同的事务中。这一点可以在org.springframework.transaction.support.TransactionSynchronizationManager中得到印证。

存储引擎不支持事务

并不是所有的存储引擎都支持事务，例如MySQL中的MyISAM存储引擎，如果需要支持事务，需要替换为InnoDB存储引擎。

错误的传播特性

前面我们对事务的传播特性，做了深入且全面的介绍，如果传播特性设置错误，事务自然也不会生效。

  1. @Service
  2. public class UserService {
  3.  
  4.     @Transactional(propagation = Propagation.NEVER)
  5.     public void add(UserModel userModel) {
  6.         saveData(userModel);
  7.         updateData(userModel);
  8.     }
  9. }
  10. 复制代码

异常处理不正确

对于异常的处理不正确，也会导致事务失效，例如，开发者手动处理了异常，这样被代理的方法将无法捕获到异常，自然也就无法回滚。

  1. @Slf4j
  2. @Service
  3. public class UserService {
  4.     
  5.     @Transactional
  6.     public void add(UserModel userModel) {
  7.         try {
  8.             saveData(userModel);
  9.             updateData(userModel);
  10.         } catch (Exception e) {
  11.             log.error(e.getMessage(), e);
  12.         }
  13.     }
  14. }
  15.  
  16. 复制代码

另外，由于@Transactional默认捕获的异常是RuntimeException和Error，如果抛出的是其他类型异常，则也会导致事务无法回滚。

  1. @Slf4j
  2. @Service
  3. public class UserService {
  4.     
  5.     @Transactional
  6.     public void add(UserModel userModel) throws Exception {
  7.         try {
  8.              saveData(userModel);
  9.              updateData(userModel);
  10.         } catch (Exception e) {
  11.             log.error(e.getMessage(), e);
  12.             throw new Exception(e);
  13.         }
  14.     }
  15. }
  16.  
  17. 复制代码

因此，你可能会经常见到这样的代码:

  1. @Slf4j
  2. @Service
  3. public class UserService {
  4.     
  5.     @Transactional(rollbackFor = Exception.class)
  6.     public void add(UserModel userModel) throws Exception {
  7.         try {
  8.              saveData(userModel);
  9.              updateData(userModel);
  10.         } catch (Exception e) {
  11.             log.error(e.getMessage(), e);
  12.             throw new Exception(e);
  13.         }
  14.     }
  15. }
  16. 复制代码

长事务

长事务可能会导致如下问题：

少用@Transactional注解

虽然@Transactional注解使用比较方便，但会导致整个业务方法都在同一个事务中，粒度比较粗，无法精确的控制事务的范围，就可能会导致长事务的产生：

  1. @Transactional(rollbackFor=Exception.class)
  2.    public void save(User user) {
  3.          // do something...
  4.    }
  5. 复制代码

正确的做法是，在有可能产生长事务的地方使用编程式事务：

  1.  
  2.    @Autowired
  3.    private TransactionTemplate transactionTemplate;
  4.    
  5.    // ...
  6.    
  7.    public void save(final User user) {
  8.          transactionTemplate.execute((status) => {
  9.             // do something...
  10.             return Boolean.TRUE;
  11.          })
  12.    }
  13. 复制代码

将查询方法放到事务外

如果出现长事务，可以将查询的方法放到事务外，因为一般情况下，这类方法是不需要事务的，例如：

  1.    @Transactional(rollbackFor=Exception.class)
  2.    public void save(User user) {
  3.          queryData1();
  4.          queryData2();
  5.          addData1();
  6.          updateData2();
  7.    }
  8. 复制代码

可以将queryData1()和queryData2()两个查询方法放在事务外执行，将真正需要事务执行的方法 addData1()和updateData2()放在事务中，这样能有效的减少事务的粒度。

  1.  
  2.    @Autowired
  3.    private TransactionTemplate transactionTemplate;
  4.    
  5.    // ...
  6.    
  7.    public void save(final User user) {
  8.          queryData1();
  9.          queryData2();
  10.          transactionTemplate.execute((status) => {
  11.             addData1();
  12.             updateData2();
  13.             return Boolean.TRUE;
  14.          })
  15.    }
  16. 复制代码

事务中避免远程调用

在业务代码中，调用其他系统的接口是不可避免的，由于网络不稳定或其他因素，这种远程调用的响应时间无法保证。如果将远程调用的代码放在事务中，就可能导致长事务。

  1. @Transactional(rollbackFor=Exception.class)
  2.    public void save(User user) {
  3.          callRemoteApi();
  4.          addData1();
  5.    }
  6. 复制代码

正确的做法是，把这些操作都放在事务外：

  1.  
  2.    @Autowired
  3.    private TransactionTemplate transactionTemplate;
  4.    
  5.    // ...
  6.    
  7.    public void save(final User user) {
  8.          callRemoteApi();
  9.          transactionTemplate.execute((status) => {
  10.             addData1();
  11.             return Boolean.TRUE;
  12.          })
  13.    }
  14. 复制代码

不过，这样做就无法保证数据的一致性了，需要建立重试+补偿机制，达到数据的最终一致性。

事务中避免一次性处理太多数据

如果一个事务中需要处理大量的数据，也会造成大事务的问题，比如批量更新、批量插入等操作。可以使用分页进行处理，1000条数据，分50页，每次只处理20条数据，这样可以大大减少大事务的出现。

非事务执行

​ 在每次使用事务之前，我们都应该思考，是不是所有的数据库操作都需要在事务中执行？

  1.    @Autowired
  2.    private TransactionTemplate transactionTemplate;
  3.    
  4.    // ...
  5.    public void save(final User user) {
  6.          transactionTemplate.execute((status) => {
  7.             addData();
  8.             addLog();
  9.             updateCount();
  10.             return Boolean.TRUE;
  11.          })
  12.    }
  13. 复制代码

上面的例子中，增加操作日志的方法addLog()和更新统计数量方法updateCount()，都是可以不在事务中执行，因为操作日志和统计数据这种业务允许少量数据出现不一致的情况。

参考文献


作者：清风孤月残酌
链接：https://juejin.cn/post/7106158883055353870
来源：稀土掘金
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/一键难忘520/article/detail/995162
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号