SpringBoot中的手动提交事务
今天在工作中遇到了一个spring事务的问题：
在service方法内需要通过线程去执行添加用户积分和用户积分日志的情况，试了下通过@Transactional声明式事务不起作用，只能使用手动事务去控制
因此写了这篇博客,记录一下这个情况
一、事务的重要性
相信在实际开发过程中，都有很深的了解了。
但是存在一个问题我们经常在开发的时候一般情况下都是用的注解的方式来进行事务的控制，说白了基于spring的7种事务控制方式来进行事务的之间的协调。
二、spring的7中事务传播行为
| Propagation.REQUIRED | 代表当前方法支持当前的事务，且与调用者处于同一事务上下文中，回滚统一回滚（如果当前方法是被其他方法调用的时候，且调用者本身即有事务），如果没有事务，则自己新建事务， |
|---|---|
| Propagation.SUPPORTS | 代表当前方法支持当前的事务，且与调用者处于同一事务上下文中，回滚统一回滚（如果当前方法是被其他方法调用的时候，且调用者本身即有事务），如果没有事务，则该方法在非事务的上下文中执行 |
| Propagation.MANDATORY | 代表当前方法支持当前的事务，且与调用者处于同一事务上下文中，回滚统一回滚（如果当前方法是被其他方法调用的时候，且调用者本身即有事务）,如果没有事务，则抛出异常 |
| Propagation.REQUIRES_NEW | 创建一个新的事务上下文，如果当前方法的调用者已经有了事务，则挂起调用者的事务，这两个事务不处于同一上下文，如果各自发生异常，各自回滚 |
| Propagation.NOT_SUPPORTED | 该方法以非事务的状态执行，如果调用该方法的调用者有事务则先挂起调用者的事务 |
| Propagation.NEVER | 该方法以非事务的状态执行，如果调用者存在事务，则抛出异常 |
| Propagation.NESTED | 如果当前上下文中存在事务，则以嵌套事务执行该方法，也就说，这部分方法是外部方法的一部分，调用者回滚，则该方法回滚，但如果该方法自己发生异常，则自己回滚，不会影响外部事务，如果不存在事务，则与PROPAGATION_REQUIRED一样 |
三、数据库四大特性和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）看一下源码
（DataSourceTransactionManagerAutoConfiguration.class、TransactionTemplate.class）
@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 ApplicationContext接口深入分析
ApplicationContext是Spring应用程序中的中央接口，由于继承了多个组件，使得ApplicationContext拥有了许多Spring的核心功能，如获取bean组件，注册监听事件，加载资源文件等2022-11-11
Java concurrency线程池之线程池原理(一)_动力节点Java学院整理
这篇文章主要为大家详细介绍了Java concurrency线程池之线程池原理，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-06-06
我们在设计系统的时候，为了系统的高扩展性，会创建无状态的系统。但是，要使系统具有更好的可扩展性，除了无状态设计之外，还要考虑采用什么负载均衡算法，本文就带领大家认识以下常见的4种负载均衡算法2023-01-01
这篇文章主要介绍了在项目迁移中，nodejs连接dubbo服务的java工程实现示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步2022-03-03
这篇文章主要介绍了普通对象使用spring容器中的对象的实现方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-06-06
在 Java 8 中,线程池（Thread Pool）是一种管理线程资源的机制,能够有效地控制并发执行的线程数量,减少线程创建和销毁的开销,提高系统的性能,本篇文章将详细介绍如何在 Java 8 中创建和使用线程池,需要的朋友可以参考下2024-06-06
这篇文章主要介绍了在Android系统中解析XML文件的方法,利用Java写成的XmlPullParser解析器,需要的朋友可以参考下2015-07-07
这篇文章主要为大家介绍了elasticsearch索引index功能源码示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-04-04
Java中CountDownLatch进行多线程同步详解及实例代码
这篇文章主要介绍了Java中CountDownLatch进行多线程同步详解及实例代码的相关资料,需要的朋友可以参考下2017-03-03
这篇文章主要为大家详细介绍了java使用EasyExcel实现合并单元格的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下2023-12-12
最新评论