当前位置:   article > 正文

事务的7种传播行为_事务的传播行为

事务的传播行为

事务传播行为

事务传播行为指的是当一个事务方法被另一个事务方法调用时,这个方法是怎么运行的。
举例说明:有两个事务方法,一个是方法A,一个是方法B,方法A中调用了方法B,那方法B是开启一个事务运行还是在方法A中的事务中运行,是由方法B的事务传播行为控制的。
在Spring中定义了7中事务传播行为:

传播行为含义
PROPAGATION_REQUIRED表示当前方法必须运行在事务中,如果当前事务存在,方法将会在该事务中运行,否则,会启动一个新的事务
PROPAGATION_SUPPORTS表示该方法不需要事务上下文,但是如果存在当前的事务的话,那么该方法会在这个事务汇总运行
PROPAGATION_MANDATORY表示该方法必须在事务中运行,如果当前事务不存在,则会抛出一个异常
PROPAGATION_REQUIRED_NEW表示当前方法必须运行在它自己的事务中。一个新的事务将被启动,如果存在当前事务,在该方法执行期间,当期事务会被挂起。如果使用JTATransactionManager的话,则需要访问TransactionManager
PROPAGATION_NOT_SUPPORTED表示当前方法不应该运行在事务中,如果存在当前事务,在该方法运行期间,当前事务将被挂起,如果使用JTATransactionManager的话,则需要访问TransactionManager
PROPAGATION_NEVER表示当前方法不应该运行在事务上下文中,如果当前正有一个事务在运行,则抛出异常
PROPAGATION_NESTED表示如果当前已经存在一个事务,那么该方法将会在嵌套事务中运行。嵌套的事务可以独立于当前事务进行单独的提交或回滚。如果当前事务不存在,那么其行为和 PROPAGATION_REQUIRED一样。注意各厂商对这种传播行为的支持是有所差异的,可以参考资源管理器的文档来确认它们是够支持嵌套事务

1、PROPAGATION_REQUIRED

存在事务就支持该事务,不存在则开启一个事务


演示代码:

  1. @Component
  2. public class Transaction {
  3. @Autowired
  4. JdbcTemplate jdbcTemplate;
  5. @Transactional(propagation = Propagation.REQUIRED)
  6. public void methodA() {
  7. jdbcTemplate.update("insert into users value (12,'wangwu','000000')");
  8. methodB();
  9. }
  10. @Transactional(propagation = Propagation.REQUIRED)
  11. public void methodB() {
  12. jdbcTemplate.update("insert into actor value (20,'范闲',now())");
  13. // 此处抛出异常,方法A和方法B的操作都将回滚
  14. int i = 100 / 0;
  15. }
  16. }

单独调用方法B,因为上下文不存在事务,所以会开启一个事务
当调用方法A时,因为上下文不存在事务,所以会开启一个事务,当执行到方法B时,方法B发现存在一个事务,方法B就不会开启新的事务,而是在方法A中的事务中执行。

2、PROPAGATION_SUPPORTS

如果存在事务则支持当前事务,如果不存在事务则无事务运行
演示代码:

  1. @Component
  2. public class Transaction {
  3. @Autowired
  4. JdbcTemplate jdbcTemplate;
  5. @Transactional(propagation = Propagation.REQUIRED)
  6. public void methodA() {
  7. jdbcTemplate.update("insert into users value (12,'wangwu','000000')");
  8. methodB();
  9. }
  10. @Transactional(propagation = Propagation.SUPPORTS)
  11. public void methodB() {
  12. jdbcTemplate.update("insert into actor value (20,'范闲',now())");
  13. // 存在事务回滚操作,不存在事务则不回滚
  14. int i = 100 / 0;
  15. }
  16. }

单独调用方法B,无事务运行
调用方法A,方法B加入方法A的事务,事务的运行

3、PROPAGATION_MANDATORY

如果存在一个事务,则事务的运行,没有事务则抛出异常

  1. @Component
  2. public class Transaction {
  3. @Autowired
  4. JdbcTemplate jdbcTemplate;
  5. @Transactional(propagation = Propagation.REQUIRED)
  6. public void methodA() {
  7. jdbcTemplate.update("insert into users value (12,'wangwu','000000')");
  8. methodB();
  9. }
  10. @Transactional(propagation = Propagation.MANDATORY)
  11. public void methodB() {
  12. jdbcTemplate.update("insert into actor value (20,'范闲',now())");
  13. }
  14. }

直接调用方法B,因为没有事务所有会抛出异常
No existing transaction found for transaction marked with propagation 'mandatory'
调用方法A,方法B会加入到方法A的事务中去

4、PROPAGATION_REQUIRED_NEW


使用PROPAGATION_REQUIRES_NEW,需要使用 JtaTransactionManager作为事务管理器。
会开启一个事务,如果存在一个事务,则会把存在的事务挂起

  1. @Component
  2. public class Transaction {
  3. @Autowired
  4. JdbcTemplate jdbcTemplate;
  5. @Transactional(propagation = Propagation.REQUIRED)
  6. public void methodA() {
  7. doSomeTingA();
  8. methodB();
  9. doSomeTingB();
  10. }
  11. @Transactional(propagation = Propagation.REQUIRES_NEW)
  12. public void methodB() {
  13. jdbcTemplate.update("insert into actor value (20,'范闲',now())");
  14. }
  15. public void doSomeTingA() {
  16. jdbcTemplate.update("insert into users value (12,'wangwu','000000')");
  17. }
  18. public void doSomeTingB() {
  19. jdbcTemplate.update("insert into actor value (21,'范思辙',now())");
  20. }
  21. }

当调用

  1. main(){
  2. methodA();
  3. }

相当于调用

  1. main(){
  2. TransactionManager tm = null;
  3. try{
  4. //获得一个JTA事务管理器
  5. tm = getTransactionManager();
  6. tm.begin();//开启一个新的事务
  7. Transaction ts1 = tm.getTransaction();
  8. doSomeThing();
  9. tm.suspend();//挂起当前事务
  10. try{
  11. tm.begin();//重新开启第二个事务
  12. Transaction ts2 = tm.getTransaction();
  13. methodB();
  14. ts2.commit();//提交第二个事务
  15. } Catch(RunTimeException ex) {
  16. ts2.rollback();//回滚第二个事务
  17. } finally {
  18. //释放资源
  19. }
  20. //methodB执行完后,恢复第一个事务
  21. tm.resume(ts1);
  22. doSomeThingB();
  23. ts1.commit();//提交第一个事务
  24. } catch(RunTimeException ex) {
  25. ts1.rollback();//回滚第一个事务
  26. } finally {
  27. //释放资源
  28. }
  29. }

在这里,把ts1称为外层事务,ts2称为内层事务。从上面的代码可以看出,ts2与ts1是两个独立的事务,互不相干。Ts2是否成功并不依赖于 ts1。如果methodA方法在调用methodB方法后的doSomeThingB方法失败了,而methodB方法所做的结果依然被提交。而除了 methodB之外的其它代码导致的结果却被回滚了

5、PROPAGATION_NOT_SUPPORTED

PROPAGATION_NOT_SUPPORTED总是非事务的运行,并且挂起任何存在的事务,使用PROPAGATION_NOT_SUPPORTED,也需要使用JtaTransactionManager作为事务管理器。

 

6、PROPAGATION_NEVER

总是非事务的运行,如果存在一个活动的事务,则抛出异常

7、PROPAGATION_NESTED


如果一个活动的事务存在,则运行在一个嵌套事务中,如果没有活动事务,则按照PROPAGATION_REQUIRED属性执行
这是一个嵌套事务,使用JDBC 3.0驱动时,仅仅支持DataSourceTransactionManager作为事务管理器。
需要JDBC 驱动的java.sql.Savepoint类。使用PROPAGATION_NESTED,还需要把PlatformTransactionManager的nestedTransactionAllowed属性设为true(属性值默认为false)。

  1. @Component
  2. public class Transaction {
  3. @Autowired
  4. JdbcTemplate jdbcTemplate;
  5. @Transactional(propagation = Propagation.REQUIRED)
  6. public void methodA() {
  7. doSomeTingA();
  8. methodB();
  9. doSomeTingB();
  10. }
  11. @Transactional(propagation = Propagation.NESTED)
  12. public void methodB() {
  13. jdbcTemplate.update("insert into actor value (20,'范闲',now())");
  14. }
  15. public void doSomeTingA() {
  16. jdbcTemplate.update("insert into users value (12,'wangwu','000000')");
  17. }
  18. public void doSomeTingB() {
  19. jdbcTemplate.update("insert into actor value (21,'范思辙',now())");
  20. }
  21. }

单独执行方法B,按照PROPAGATION_REQUIRED属性执行
如果调用方法A,相当于如下效果:

  1. main(){
  2. Connection con = null;
  3. Savepoint savepoint = null;
  4. try{
  5. con = getConnection();
  6. con.setAutoCommit(false);
  7. doSomeThingA();
  8. savepoint = con2.setSavepoint();
  9. try{
  10. methodB();
  11. } catch(RuntimeException ex) {
  12. con.rollback(savepoint);
  13. } finally {
  14. //释放资源
  15. }
  16. doSomeThingB();
  17. con.commit();
  18. } catch(RuntimeException ex) {
  19. con.rollback();
  20. } finally {
  21. //释放资源
  22. }
  23. }

当methodB方法调用之前,调用setSavepoint方法,保存当前的状态到savepoint。如果methodB方法调用失败,则恢复到之前保存的状态。但是需要注意的是,这时的事务并没有进行提交,如果后续的代码(doSomeThingB()方法)调用失败,则回滚包括methodB方法的所有操作。嵌套事务一个非常重要的概念就是内层事务依赖于外层事务。外层事务失败时,会回滚内层事务所做的动作。而内层事务操作失败并不会引起外层事务的回滚。

PROPAGATION_NESTED 与PROPAGATION_REQUIRES_NEW的区别:

它们非常类似,都像一个嵌套事务,如果不存在一个活动的事务,都会开启一个新的事务。
使用 PROPAGATION_REQUIRES_NEW时,内层事务与外层事务就像两个独立的事务一样,一旦内层事务进行了提交后,外层事务不能对其进行回滚。两个事务互不影响。两个事务不是一个真正的嵌套事务。同时它需要JTA事务管理器的支持。

使用PROPAGATION_NESTED时,外层事务的回滚可以引起内层事务的回滚。而内层事务的异常并不会导致外层事务的回滚,它是一个真正的嵌套事务。DataSourceTransactionManager使用savepoint支持PROPAGATION_NESTED时,需要JDBC 3.0以上驱动及1.4以上的JDK版本支持。其它的JTATrasactionManager实现可能有不同的支持方式。

PROPAGATION_REQUIRES_NEW 启动一个新的, 不依赖于环境的 “内部” 事务. 这个事务将被完全 commited 或 rolled back 而不依赖于外部事务, 它拥有自己的隔离范围, 自己的锁, 等等. 当内部事务开始执行时, 外部事务将被挂起, 内务事务结束时, 外部事务将继续执行。

另一方面, PROPAGATION_NESTED 开始一个 “嵌套的” 事务, 它是已经存在事务的一个真正的子事务. 潜套事务开始执行时, 它将取得一个 savepoint. 如果这个嵌套事务失败, 我们将回滚到此 savepoint. 潜套事务是外部事务的一部分, 只有外部事务结束后它才会被提交。

由此可见, PROPAGATION_REQUIRES_NEW 和 PROPAGATION_NESTED 的最大区别在于, PROPAGATION_REQUIRES_NEW 完全是一个新的事务, 而 PROPAGATION_NESTED 则是外部事务的子事务, 如果外部事务 commit, 嵌套事务也会被 commit, 这个规则同样适用于 roll back.

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

闽ICP备14008679号