文章目录
前言
接着上一遍【Spring事务详解】— 1.事务传播的案例演示,本文再来看看事务的具体使用。
通过Spring来开启事务管理非常简单,默认支持两种方式,一种为编程式事务、一种为声明式事务,大多数人对声明式事务都比较熟悉,我们就先从它开始说起。
声明式事务
开启声明式事务非常简单,直接通过@Transactional
注解即可
@Transactional
public void func() {
}
滥用@Transactional
不过,也因为它的简单灵活,而经常导致被滥用的情况发生。
千万不要直接把注解加在Service
上,这会导致整个Service
中的方法,只要调用到数据库,就都会被进行事务管理,从而影响数据库和Web服务的QPS。
@Service
@Transactional // 不要加在Service上
public class DemoService {
}
长事务
简单来说,就是在整个方法的生命周期内,真正需要事务管理的方法可能只占用了200毫秒,而其他业务流程占用了2秒,但是由于事务是对整个方法生效,从而导致一个数据库连接被占用2秒多。
@Transactional
public void func() {
// 两个select花费了2秒
select1();
select2();
// 两个save只花费了200毫秒
save1();
save2();
}
解决方式也很简单,把长事务拆分为短事务即可
public void func() {
select1();
select2();
manager.save();
}
@Transactional
public void save() {
save1();
save2();
}
编程式事务
声明式事务的最大问题就在于,粒度控制问题,声明式事务最细的粒度也是方法级别的,这很容易导致长事务问题的产生,所以我们一般使用编程式事务替代。
Spring提供的TransactionTemplate
、PlatformTransactionManager
都支持编程式事务的实现,TransactionTemplate
是在原始的事务管理类上又封装了一次,调用其核心方法execute
实现整个事务的管理。
@Override
@Nullable
public <T> T execute(TransactionCallback<T> action) throws TransactionException {
Assert.state(this.transactionManager != null, "No PlatformTransactionManager set");
if (this.transactionManager instanceof CallbackPreferringPlatformTransactionManager) {
return ((CallbackPreferringPlatformTransactionManager) this.transactionManager).execute(this, action);
}
else {
TransactionStatus status = this.transactionManager.getTransaction(this);
T result;
try {
result = action.doInTransaction(status);
}
catch (RuntimeException | Error ex) {
// Transactional code threw application exception -> rollback
rollbackOnException(status, ex);
throw ex;
}
catch (Throwable ex) {
// Transactional code threw unexpected exception -> rollback
rollbackOnException(status, ex);
throw new UndeclaredThrowableException(ex, "TransactionCallback threw undeclared checked exception");
}
this.transactionManager.commit(status);
return result;
}
}
PlatformTransactionManager
则更灵活一点,就定义了三个关键方法,一看就明白了
public interface PlatformTransactionManager extends TransactionManager {
TransactionStatus getTransaction(@Nullable TransactionDefinition definition)
throws TransactionException;
void commit(TransactionStatus status) throws TransactionException;
void rollback(TransactionStatus status) throws TransactionException;
}
TransactionTemplate演示
execute
中入参为TransactionCallback
,这是一个函数式接口,只定义了一个方法doInTransaction
可以传入TransactionCallbackWithoutResult
不带返回参数的
@Resource
private TransactionTemplate transactionTemplate;
public void func() {
transactionTemplate.execute(new TransactionCallbackWithoutResult() {
@Override
protected void doInTransactionWithoutResult(TransactionStatus status) {
testMapper.updateT1();
t2Service.func();
int i = 1 / 0;
}
});
}
或者直接传入TransactionCallback
带返回参数的也可以。
PlatformTransactionManager演示
@Resource
private PlatformTransactionManager platformTransactionManager;
public void func() {
TransactionStatus status = platformTransactionManager.getTransaction(new DefaultTransactionDefinition());
try {
testMapper.updateT1();
t2Service.func();
int i = 1 / 0;
platformTransactionManager.commit(status);
} catch (Exception e) {
e.printStackTrace();
platformTransactionManager.rollback(status);
}
}