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: 以非事务形式运行,如果存在事务,则抛出异常。
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持代码网。
发表评论