0
点赞
收藏
分享

微信扫一扫

【Spring事务详解】--- 2.事务应用的注意事项

Go_Viola 2022-01-04 阅读 95

文章目录

前言

接着上一遍【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提供的TransactionTemplatePlatformTransactionManager都支持编程式事务的实现,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);
    }
}
举报

相关推荐

0 条评论