这期内容当中小编将会给大家带来有关Spring中@Transactional事务不生效如何解决,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
事务管理在系统开发中是不可缺少的一部分,Spring
提供了很好事务管理机制,主要分为编程式事务
和声明式事务
两种。
编码式事务管理:将事务控制代码编写在业务代码之中。
声明式事务管理:基于AOP(面向切面编程),事务管理与业务逻辑解耦。两种实现:(1)在配置文件(xml)中配置。(2)基于@Transactional注解。
@Transactional 可以作用在接口
、类
、类方法
。
作用于类:当把@Transactional 注解放在类上时,表示所有该类的public
方法都配置相同的事务属性信息。
作用于方法:当类配置了@Transactional,方法也配置了@Transactional,方法的事务会覆盖类的事务配置信息。
作用于接口:不推荐这种使用方法,因为一旦标注在Interface上并且配置了Spring AOP 使用CGLib动态代理,将会导致@Transactional注解失效
MySql 的 MyISAM 引擎不支持回滚,如果需要自动回滚事务,需要将MySql的引擎设置成InnoDB;
//@Transactional注解在private方法上会失效@Transactionalprivate 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是不会回滚的,例如:
@Transactionalpublic void deleteUser() {userMapper.deleteUserA();try {int i = 1 / 0;userMapper.deleteUserB();} catch (Exception e) {e.printStackTrace();}}
异步虽然抛出了,但是抛出的是非RuntimeException类型的异常,依旧不会生效,例如:
@Transactionalpublic 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(); // 事物失效}@Transactionalpublic 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把数据库连接绑定到当前线程中,新开启一个线程获取到的连接就不是同一个了,例如:
@Transactionalpublic 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: 以非事务形式运行,如果存在事务,则抛出异常。
propagation属性
propagation
代表事务的传播行为,默认值为 Propagation.REQUIRED
,其他的属性信息如下:
Propagation.REQUIRED
:如果当前存在事务,则加入该事务,如果当前不存在事务,则创建一个新的事务。( 也就是说如果A方法和B方法都添加了注解,在默认传播模式下,A方法内部调用B方法,会把两个方法的事务合并为一个事务 )
Propagation.SUPPORTS
:如果当前存在事务,则加入该事务;如果当前不存在事务,则以非事务的方式继续运行。
Propagation.MANDATORY
:如果当前存在事务,则加入该事务;如果当前不存在事务,则抛出异常。
Propagation.REQUIRES_NEW
:重新创建一个新的事务,如果当前存在事务,暂停当前的事务。( 当类A中的 a 方法用默认Propagation.REQUIRED
模式,类B中的 b方法加上采用 Propagation.REQUIRES_NEW
模式,然后在 a 方法中调用 b方法操作数据库,然而 a方法抛出异常后,b方法并没有进行回滚,因为Propagation.REQUIRES_NEW
会暂停 a方法的事务 )
Propagation.NOT_SUPPORTED
:以非事务的方式运行,如果当前存在事务,暂停当前的事务。
Propagation.NEVER
:以非事务的方式运行,如果当前存在事务,则抛出异常。
Propagation.NESTED
:和 Propagation.REQUIRED 效果一样。
isolation 属性
isolation
:事务的隔离级别,默认值为 Isolation.DEFAULT
。
Isolation.DEFAULT:使用底层数据库默认的隔离级别。
Isolation.READ_UNCOMMITTED
Isolation.READ_COMMITTED
Isolation.REPEATABLE_READ
Isolation.SERIALIZABLE
timeout 属性
timeout
:事务的超时时间,默认值为 -1。如果超过该时间限制但事务还没有完成,则自动回滚事务。
readOnly 属性
readOnly
:指定事务是否为只读事务,默认值为 false;为了忽略那些不需要事务的方法,比如读取数据,可以设置 read-only 为 true。
rollbackFor 属性
rollbackFor
:用于指定能够触发事务回滚的异常类型,可以指定多个异常类型。
noRollbackFor属性**
noRollbackFor
:抛出指定的异常类型,不回滚事务,也可以指定多个异常类型
上述就是小编为大家分享的Spring中@Transactional事务不生效如何解决了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。