如何在SpringBoot中灵活应用手动提交事务

今天在工作中遇到了一个 spring 事务的问题：

在 service 方法内需要通过线程去执行添加用户积分和用户积分日志的情况，试了下通过@Transactional 声明式事务不起作用，只能使用手动事务去控制。

因此写了这篇博客，记录一下这个情况。

一、事务的重要性

相信在实际开发过程中，都有很深的了解了。

但是存在一个问题我们经常在开发的时候一般情况下都是用的注解的方式来进行事务的控制，说白了基于 spring 的 7 种事务控制方式来进行事务的之间的协调。

二、spring 的 7 中事务传播行为

三、数据库四大特性和 MySQL 事务的隔离级别

1）四大特性

a、原子性（Atomicity）

原子性是指事务包含的所有操作要么全部成功，要么全部失败回滚。

b、 一致性（Consistency）

一致性是指事务必须使数据库从一个一致性状态变换到另一个一致性状态，也就是说一个事务执行之前和执行之后都必须处于一致性状态。

c、隔离性（Isolation）

隔离性是当多个用户并发访问数据库时，比如操作同一张表时，数据库为每一个用户开启的事务，不能被其他事务的操作所干扰，多个并发事务之间要相互隔离。

d、 持久性（Durability）

持久性是指一个事务一旦被提交了，那么对数据库中的数据的改变就是永久性的，即便是在数据库系统遇到故障的情况下也不会丢失提交事务的操作。

2）隔离级别

a、脏读是指在一个事务处理过程里读取了另一个未提交的事务中的数据。（读取未提交的数据）

b、不可重复读是指在对于数据库中的某个数据，一个事务范围内多次查询却返回了不同的数据值，这是由于在查询间隔，被另一个事务修改并提交了。（边读边写）

c、幻读指两个事务同时发生，两个事务修改数据，读到的数据不是自己开始修改的数据。幻读和不可重复读都是读取了另一条已经提交的事务（这点就脏读不同），所不同的是不可重复读查询的都是同一个数据项，而幻读针对的是一批数据整体。（同时写，同时读）

3）数据库事务级别

默认使用 Repeatable read 级别，列表级别从下往上级别越低。

查看级别：

select @@tx_isolation;

四、写上面 spring 事务和数据库事务隔离级别

主要的目的就是了解事务之间存在的传递关系，这样在控制的时候，spring 会通过事务与事务之间关系，来达到回滚或者提交的效果。

五、如果在没有办法使用注解的时候（比如多线程等）

就要使用手动的方式来做事务管理了，这也就是编程式的事务管理。

1）首先加入注解

这就是 spring 的 jdbc 框架中提供的事务管理方式

@Autowired
private PlatformTransactionManager platformTransactionManager;

@Autowired
private TransactionDefinition transactionDefinition;

2）看一下源码

@Bean
@ConditionalOnMissingBean({PlatformTransactionManager.class})
public DataSourceTransactionManager transactionManager(DataSourceProperties properties) {
    DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(this.dataSource);
        if (this.transactionManagerCustomizers != null) {
            this.transactionManagerCustomizers.customize(transactionManager);
        }

        return transactionManager;
}

备注：有兴趣可以了解一下DataSourceTransactionManager的写法和原理。

@Bean
@ConditionalOnMissingBean
public TransactionTemplate transactionTemplate() {
    return new TransactionTemplate(this.transactionManager);
}

注意，这里的所有事务传播方式包括处理，都需要自己手动去处理。

3）编写方式

TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);
platformTransactionManager.commit(transactionStatus);
platformTransactionManager.rollback(transactionStatus);

说明：这里开发事务过后，返回一个事务状态，这个状态记录了东西，用来控制事务的管理，当然，多个事务之间的控制需要人为控制。

4）编程式的事务控制经量少用

因为控制程度上面来说 spring 的方式还是来的更加不错，编程式的方式，更多用于在需要事务的时候，没有办法加入事务，才采取手动控制事务的方式。

使用示例

1.在 service 内注入 这两个 bean

@Autowired
private PlatformTransactionManager platformTransactionManager;
 
@Autowired
private TransactionDefinition transactionDefinition;

2.在 service 方法内创建 TransactionStatus

TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);
通过 platformTransactionManager.commit(transactionStatus); 提交事务
通过 platformTransactionManager.rollback(transactionStatus); 回滚事务

示例代码：

@Autowired
private PlatformTransactionManager platformTransactionManager;
 
@Autowired
private TransactionDefinition transactionDefinition;
 
public void b(){
    TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);
 
    UserIntegralInfo info = new UserIntegralInfo();
    info.setUserId(1L);
    info.setPoint(1);
    info.setOp("");
    info.setCurrIntegral(1);
    integralMapper.insert(info);
    platformTransactionManager.commit(transactionStatus);
    throw new RuntimeException();
}

总结

以上就是 SpringBoot 中手动提交事务的全部内容，纯属为个人经验，希望能给大家一个参考。