@Transactional 是声明式事务管理
编程中使用的注解
@Transactional 详解
Spring之@Transactional注解原理以及走过的坑
Spring 事务管理分为编码式
和声明式
的两种方式。编程式事务
指的是通过编码方式实现事务
;声明式事务
基于AOP
,将具体业务逻辑与事务处理解耦
。
声明式事务管理使业务代码逻辑不受污染, 因此在实际使用中声明式事务用的比较多
。
声明式事务有两种方式,一种是在配置文件中做相关的事务规则声明
,另一种是基于@Transactional 注解
的方式。
使用@Transactional的相比传统的我们需要手动开启事务,然后提交事务来说。它提供如下方便
1 2 |
根据你的配置,设置是否自动开启事务 自动提交事务或者遇到异常自动回滚 |
声明式事务(@Transactional)基本原理
如下:配置文件开启注解驱动
,在相关的类和方法上通过注解@Transactional标识
。
spring 在启动的时候
会去解析生成相关的bean
,这时候会查看拥有相关注解的类和方法
,并且为这些类和方法生成代理
,并根据@Transaction的相关参数进行相关配置注入
,这样就在代理中为我们把相关的事务处理掉了(开启正常提交事务,异常回滚事务)。
真正的数据库层的事务
提交和回滚是通过binlog或者redo log
实现的。
1)接口实现类
或接口实现方法
上,而不是接口类
中。
2)访问权限:public 的方法才起作用
。@Transactional 注解应该只被应用到 public 方法上
,这是由 Spring AOP 的本质决定的。
系统设计:将标签放置在需要进行事务管理的方法上
,而不是放在所有接口实现类上
只读的接口就不需要事务管理
,由于配置了@Transactional就需要AOP拦截及事务的处理
,可能影响系统性能。
@Transactional
注解只能
在抛出RuntimeException或者Error
时才会触发事务的回滚
,常见的非RuntimeException是不会触发事务的回滚的
。但是我们平时做业务处理时,需要捕获异常,所以可以手动抛出RuntimeException异常
或者添加rollbackFor = Exception.class(也可以指定相应异常)
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
/* * 捕获异常时,要想使事务生效,需要手动抛出RuntimeException异常或者添加rollbackFor = Exception.class */ @Override @Transactional public Long addBook(Book book) { Long result = null; try { result = bookDao.addBook(book); int i = 1/0; } catch (Exception e) { e.printStackTrace(); throw new RuntimeException(); } return result; } @Override @Transactional(rollbackFor = Exception.class) public Long addBook(Book book) { Long result = null; try { result = bookDao.addBook(book); int i = 1/0; } catch (Exception e) { e.printStackTrace(); throw e; } return result; } |
1 2 3 4 5 6 7 8 9 10 11 12 |
1.接口中A、B两个方法,A无@Transactional标签,B有,上层通过A间接调用B,此时事务不生效。 2.接口中异常(运行时异常)被捕获而没有被抛出。 默认配置下,spring 只有在抛出的异常为运行时 unchecked 异常时才回滚该事务, 也就是抛出的异常为RuntimeException 的子类(Errors也会导致事务回滚), 而抛出 checked 异常则不会导致事务回滚 。可通过 @Transactional rollbackFor进行配置。 3.多线程下事务管理因为线程不属于 spring 托管,故线程不能够默认使用 spring 的事务, 也不能获取spring 注入的 bean 。 在被 spring 声明式事务管理的方法内开启多线程,多线程内的方法不被事务控制。 一个使用了@Transactional 的方法,如果方法内包含多线程的使用,方法内部出现异常, 不会回滚线程中调用方法的事务。 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 |
结论:当无事务方法调用有事务的方法时事务不会生效, 而主方法有事务去调用其他方法,无论被调用的方法有无事务,且是否出现异常(有异常需要能够抛出不被捕获),都触发事务。 /* * 情况一:都有事务注解,异常在子方法出现,事务生效 */ @Override @Transactional public Long addBook(Book book) { Long result = add(book); return result; } @Transactional public Long add(Book book){ Long result = bookDao.addBook(book); int i = 1/0; return result; } /* * 情况二:都有事务注解,异常在主方法出现,事务生效 */ @Override @Transactional public Long addBook(Book book) { Long result = add(book); int i = 1/0; return result; } @Transactional public Long add(Book book){ Long result = bookDao.addBook(book); return result; } /* * 情况三:只有主方法有事务注解,异常在子方法出现,事务生效 */ @Override @Transactional public Long addBook(Book book) { Long result = add(book); return result; } public Long add(Book book){ Long result = bookDao.addBook(book); int i = 1/0; return result; } /* * 情况四:只有主方法有事务注解,异常在主方法出现,事务生效 */ @Override @Transactional public Long addBook(Book book) { Long result = add(book); int i = 1/0; return result; } public Long add(Book book){ Long result = bookDao.addBook(book); return result; } /* * 情况五:只有子方法有事务注解,异常在子方法出现,事务不生效 */ @Override public Long addBook(Book book) { Long result = add(book); return result; } @Transactional public Long add(Book book){ Long result = bookDao.addBook(book); int i = 1/0; return result; } |
@Transactional注解底层使用的是动态代理
来进行实现的,如果在调用本类中的方法
,此时不添加@Transactional注解
,而是在调用类中使用this
调用本类中的另外一个添加了@Transactional注解
,此时this调用的方法上的@Transactional注解是不起作用的
。
1 2 3 4 5 6 7 8 9 10 11 12 |
类似于上面 调用同类中的方法 例如 impl{ test1(){ test2(); } 某个注解 test2(){} } |
1 |
此时 test2() 上的注解是不生效的,使用下面的 方法,使用代理调用内部方法 |
1 2 3 4 5 6 7 8 9 10 |
impl{ XXXService xxxService; test1(){ ((XXXService) AopContext.currentProxy()).test2(request); } 某个注解 test2(){} } |
@Transactional 实质是使用了 JDBC 的事务
来进行事务控制的
@Transactional 基于 Spring 的动态代理的机制
1 2 3 4 5 6 7 8 9 10 11 12 13 |
@Transactional 实现原理: 1) 事务开始时,通过AOP机制,生成一个代理connection对象, 并将其放入 DataSource 实例的某个与 DataSourceTransactionManager 相关的某处容器中。 在接下来的整个事务中,客户代码都应该使用该 connection 连接数据库, 执行所有数据库命令。 [不使用该 connection 连接数据库执行的数据库命令,在本事务回滚的时候得不到回滚] (物理连接 connection 逻辑上新建一个会话session; DataSource 与 TransactionManager 配置相同的数据源) 2) 事务结束时,回滚在第1步骤中得到的代理 connection 对象上执行的数据库命令, 然后关闭该代理 connection 对象。 (事务结束后,回滚操作不会对已执行完毕的SQL操作命令起作用) |
事务的两种开启方式:
1 显示开启
start transaction | begin
,通过 commit | rollback 结束事务
关闭数据库中自动提交 autocommit set autocommit = 0
;MySQL 默认开启自动提交
;通过手动提交或执行回滚操作来结束事务
2 Spring 关闭数据库中自动提交:在方法执行前关闭自动提交,方法执行完毕后再开启自动提交
首先我在Mysql中准备了一条数据
示例参考彻底弄懂@Transactional和@Transactional(rollbackFor = Exception.class)的区别到底在哪里
参考Spring事务For循环中的代码单独为一个事务,循环一次提交一次事务
参考上面 throw RuntimeException
,然后加 @Transactional
当假设有一个大小为10的for循环,当执行到第二个数据的时候,出现异常
,可以保证不影响已经执行已经执行的语句
,以及余下的8次执行
,单独catch住第二次的执行所抛出的异常
。
可以使用以下的策略:
1、在一个Aservice实现类的方法里面定义一个for循环,Aservice实现类上面加上@Transactional(rollbackFor = Exception.class)注解
;
2、再在这个for循环里面调用另一个Bservice的实现类方法
,在Bservice的实现类
的上面加上@Transactional(propagation = Propagation.REQUIRES_NEW)
注解
参考spring 事务-使用@Transactional 注解(事务隔离级别)
from:https://blog.csdn.net/qq_40813329/article/details/123254855