spring事务管理方式
- 编码式事务管理:将事务控制代码编写在业务代码之中。
- 声明式事务管理:基于aop(面向切面编程),事务管理与业务逻辑解耦。
声明式事务管理的两种实现:
- (1)在配置文件(xml)中配置。
- (2)基于@transactional注解。
@transactional使用起来方便,但也需要注意引起@transactional失效的场景,本文总结了七种情况,下面进行逐一分析:
一、数据库本身不支持
mysql 的 myisam 引擎不支持回滚,如果需要自动回滚事务,需要将mysql的引擎设置成innodb;
二、注解的方法是否为public
//@transactional注解在private方法上会失效 @transactional private void deleteuser() throws myexception{ usermapper.deleteusera(); int i = 1/0; usermapper.deleteuserb(); }
idea直接会给出提示methods annotated with ‘@transactional’ must be overridable ,原理很简单,private修饰的方式,spring无法生成动态代理,aop代理分别在intercept()和invoke()方法判断是否进行事务拦截,这两个方法都会间接调用abstractfallbacktransactionattributesource类的computetransactionattribute方法来获取事务控制的相关属性。
这其中有以下一段代码
/** * same signature as {@link #gettransactionattribute}, but doesn't cache the result. * {@link #gettransactionattribute} is effectively a caching decorator for this method. * <p>as of 4.1.8, this method can be overridden. * @since 4.1.8 * @see #gettransactionattribute */ protected transactionattribute computetransactionattribute(method method, class<?> targetclass) { // don't allow no-public methods as required. if (allowpublicmethodsonly() && !modifier.ispublic(method.getmodifiers())) { return null; } //... }
这段代码会导致no-public的方法无法进入事务控制,所以一定要确保自己需要进行事务控制的方法包含public修饰符。
三、异常处理不当
当异常被捕获后,并且没有再抛出,那么deleteusera是不会回滚的,例如:
@transactional public void deleteuser() { usermapper.deleteusera(); try { int i = 1 / 0; usermapper.deleteuserb(); } catch (exception e) { e.printstacktrace(); } }
异步虽然抛出了,但是抛出的是非runtimeexception类型的异常,依旧不会生效,例如:
@transactional public void deleteuser() throws myexception{ usermapper.deleteusera(); try { int i = 1 / 0; usermapper.deleteuserb(); } catch (exception e) { throw new myexception(); } }
注解为事务范围的方法中,事务的回滚仅仅对于unchecked的异常有效。对于checked异常无效。也就是说事务回滚仅仅发生在,出现runtimeexception或error的时候。通俗一点就是:代码中出现的空指针等异常,会被回滚。而文件读写、网络超时问题等,spring就没法回滚了。
解决方案:如果指定了回滚异常类型为exception,那么就可以回滚checked类型异常了。
@transactional(rollbackfor = exception.class)
java里面将派生于error或者runtimeexception(比如空指针,1/0)的异常称为unchecked异常,其他继承自java.lang.exception得异常统称为checked exception,如ioexception、timeoutexception等
四、方法内部直接调用
如果先调用deleteuser(),那么deleteusera()是不会回滚的,其原因就是@transactional根本没生成代理,例如:
public void deleteuser() throws myexception{ deleteuser2(); // 事物失效 } @transactional public void deleteuser2() throws myexception{ usermapper.deleteusera(); int i = 1 / 0; usermapper.deleteuserb(); }
五、多数据源事物配置问题
项目中没有配置事务管理器,需要在配置类或者配置文件中配置,因为项目是多数据源的,所以要区别配置不同数据源的事务管理器,如下:
@primary @bean(name = "db1") public datasource getdatasource() { return createdatasource(); } @bean(name = "db1transactionmanager") public platformtransactionmanager txmanager(@qualifier("db1") datasource datasource) { return new datasourcetransactionmanager(datasource); } @bean(name = "db2") public datasource getdatasource() { return builddatasource(); } @bean(name = "db2transactionmanager") public platformtransactionmanager txmanager(@qualifier("db2") datasource datasource) { return new datasourcetransactionmanager(datasource); }
可以看到,两个事务管理器配置了不同的beanname,接下来只需要 在需要事务控制的位置加上该事务管理器的name就可以完美解决!
@override @transactional(value = "db1transactionmanager",rollbackfor = exception.class) public int updateorinsert(baserequest<banktemplatedto> param) { ... }
六、新开启一个线程
如下的方式deleteusera()也不会回滚,因为spring实现事务的原理是通过threadlocal把数据库连接绑定到当前线程中,新开启一个线程获取到的连接就不是同一个了,例如:
@transactional public void deleteuser() throws myexception{ usermapper.deleteusera(); try { //休眠1秒,保证deleteusera先执行 thread.sleep(1000); } catch (interruptedexception e) { e.printstacktrace(); } new thread(() -> { int i = 1/0; usermapper.deleteuserb(); }).start(); }
七、事务传播属性设置错误
注意传播属性的设置,一般情况下,propagation属性无需配置。会使用默认配置,即:propagation_required,有些propagation属性会导致事务不会触发,一定要注意:
- propagation_supports: 如果存在事务,则进入事务;否则,以非事务方式运行。
- propagation_not_supported: 如果存在事务,则挂起事务,并以非事务方式运行。
- propagation_never: 以非事务形式运行,如果存在事务,则抛出异常。
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持代码网。
发表评论