Spring事务原理解析

目录
  • 前言
  • 问题描述
  • 代码复现
  • 排查
    • 1. 锁失效
    • 2. 事务隔离级别
    • 3. 修改Spring事务传播配置
  • 解决方案

前言

最近在编写公司APP产品的商品砍价功能，其中有一个接口涉及并发访问。自测时通过ApiFox接口管理工具进行压测，落地数据时出现了"锁失效"的情景。十分感谢后端小伙伴的帮助排查，解决了这个问题。

问题描述

并发接口中，先对主表数据进行读取，进行业务判断后，新增、修改它表的数据。在理应串行执行的情况下发生了多个请求线程读取到了相同的主表数据，导致数据处理异常。也正是前言中所说的"锁失效"了。（实际情况加锁操作是有效的）

代码复现

@RequestMapping("/test")
@Transactional(rollbackFor = Exception.class)
public String test() {
    DistributedLock.lock("ct_lock");
    try {
        Map<String, Object> resultMap = jdbcTemplate.queryForMap("select * from concurrent_read_uncommit");
        int num = Integer.parseInt(resultMap.get("num").toString());
        num++;
        jdbcTemplate.update("update concurrent_read_uncommit set num = " + num);
    } finally {
        DistributedLock.unlock("ct_lock");
    }
    return "success";
}
  • 最少的代码进行演示，Controller方法体中的内容应是Service中的代码
  • DistributedLock中封装的Redission
  • 通过将先读后改的方式演示，实际中本质就是进行了这样的操作，但会存在更多的业务代码（不演示新增的情况）

ApiFox中通过创建100个请求线程进行压测，最终concurrent_read_uncommit表中的num字段值为94，而非100。

排查

1. 锁失效

新编写了两个简单接口，第一个接口加锁，并线程休眠30秒后释放锁。另一个接口加同样的锁，打印一条语句后直接返回。先调用第一个接口，在调用第二个接口。Debug中发现锁是有效的，在redis中存有锁Key。并且访问第二个接口时，线程被阻塞在了加锁行代码。

2. 事务隔离级别

查询数据库事务默认隔离级别：

select @@tx_isolation;

结果

REPEATABLE-READ

就是默认的RR级别，那么说明同个事务内多次读取数据都会是一样的，不会读取到脏数据。

3. 修改Spring事务传播配置

@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)

与这个并没有关系，八竿子打不着。当时的想法时是多个并发请求在进入到了同个事务内，并一起读取到了没有被修改前的数据。细想想：

  • 事务传播配置一般用在不同事务方法间产生调用时的事务决策，是共用事务还是新创建事务，亦或是其他的方式进行处理
  • test方法本身为根方法，也没有调用其他的事务方法，所以无需配置事务传播配置
  • 即便不在同一事务内，依旧能查询到其他事务修改但未提交的相同数据

解决方案

在锁代码块中调用事务方法，而不是在事务方法中进行加锁。

原因为：并发情境下，执行速度过快，很有可能发生：请求线程在释放锁后没有来得及提交事务，另一个请求线程在加锁处被唤醒，继而读取到了事务未提交的数据。即读取到了脏数据，产生了"锁失效"的效果。

修正代码：

@RequestMapping("/test2")
public String test2() {
    ConcurrentTransactionalController proxyBean = SpringContextUtils.getBean(this.getClass());
    proxyBean.doTest2();
    return "success";
}
@Transactional(rollbackFor = Exception.class)
public void doTest2() {
    DistributedLock.lock("ct_lock");
    try {
        Map<String, Object> resultMap = jdbcTemplate.queryForMap("select * from concurrent_read_uncommit");
        int num = Integer.parseInt(resultMap.get("num").toString());
        num++;
        jdbcTemplate.update("update concurrent_read_uncommit set num = " + num);
        Thread.sleep(500);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    } finally {
        DistributedLock.unlock("ct_lock");
    }
}
  • 将需要加锁的事务代码进行提取另一个方法
  • 调用方法中进行加锁，并且必须要去掉事务注解
  • 因为是在非事务方法调用事务方法，为了保证事务生效，需要通过事务代理Bean进行调用

这样就保证了不会读取到事务未提交的数据，同时又具有锁的排他性。

其实锁一直都是有效的，本质原因就在于Spring的事务代理Bean屏蔽了事务代码。我们不能手动的进行控制，也就是说你变更了不了事务代码的顺序。如果能将提交事务的行代码写到释放锁之前，就不会存在这个问题了。所以，也可以通过编程式事务解决这个问题，关于编程式事务，Spring也有做代码封装。如果不通过编程式事务，那么就只能通过上述代码变相的来实现。

到此这篇关于Spring事务原理解析的文章就介绍到这了,更多相关Spring事务内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • Spring事务管理零基础入门

    目录 一.简介 二.特性(一原持久隔离) 2.1 原子性 2.2 一致性(类似能量守恒) 2.3 隔离性 2.4 持久性 三.隔离级别 3.1 事务级别(从低到高) 3.2 常用数据库默认级别: 3.3 事务中可能出现的问题: 四.传播特性 4.1 死活都不要事务 4.2 可有可无的 4.3 必须要有事务 五.应用 5.1 数据表 5.2 实体类 5.3 Service 一.简介 概念:事务是数据库操作的最小工作单元,是作为单个逻辑工作单元执行的一系列操作,这些操作一起提交,要么都执行,要么都不

  • Spring底层事务原理解析

    目录 一.@EnableTransactionManagement工作原理 二.Spring事务基本执行原理 四.Spring事务传播机制 五.Spring事务传播机制分类 六.Spring事务强制回滚 七.TransactionSynchronization 一.@EnableTransactionManagement工作原理 开启Spring事务本质上就是增加了一个Advisor,但我们使用 @EnableTransactionManagement注解来开启Spring事务是,该注解代理的功

  • 浅析Spring的事务实现原理

    目录 SQL事务实现简介 编程式事务 声明式事务 注释事务属性源 事务拦截器 Bean工厂事务属性源指导 事务多样性支持 总结 SQL事务实现简介 首先我们来了解下,最简单的事务是怎么实现的呢?以JDBC为例,当一个数据库Connection对象创建后,其会默认自动提交事务:每次执行SQL语句时,如果成功,就会向数据库自动提交,不能回滚. 通过调用setAutoCommit(false)方法可以取消自动提交事务.等到所有的SQL语句都执行成功后,调用commit()方法提交事务.如果其中某个操作

  • Spring事务管理中关于数据库连接池详解

    目录 Spring事务管理 环境搭建 标准配置 声明式事务 总结 SqlSessionFactory XML中构建SqlSessionFactory 获得SqlSession的实例 代码实现 作用域(Scope)和生命周期 SqlSessionFactoryBuilder(构造器) SqlSessionFactory(工厂) SqlSession(会话) Spring事务管理 事务(Transaction),一般是指要做的或所做的事情.在计算机术语中是指访问并可能更新数据库中各种数据项的一个程序

  • Spring事务管理详细讲解

    目录 事务回顾 spring事务操作 基于注解声明事务 @Transactional注解使用 事务传播机制 事务隔离级别 @Transactional其他属性 基于XML 声明式事务 完全注解开发 说明:基于atguigu学习笔记. 事务回顾 事务是逻辑上的一组数据库操作,要么都执行,要么都不执行. 假如,张三给李四转账100元,转账行为欧两个关键操作:将张三的余额减200元,将李四的余额增加200元.如果两个操作之间突然出现错误,例如银行系统崩溃导致张三余额减少,而李四的余额没有增加,这样的系

  • Spring事务原理解析

    目录 前言 问题描述 代码复现 排查 1. 锁失效 2. 事务隔离级别 3. 修改Spring事务传播配置 解决方案 前言 最近在编写公司APP产品的商品砍价功能,其中有一个接口涉及并发访问.自测时通过ApiFox接口管理工具进行压测,落地数据时出现了"锁失效"的情景.十分感谢后端小伙伴的帮助排查,解决了这个问题. 问题描述 并发接口中,先对主表数据进行读取,进行业务判断后,新增.修改它表的数据.在理应串行执行的情况下发生了多个请求线程读取到了相同的主表数据,导致数据处理异常.也正是前

  • mybatis开启spring事务代码解析

    1.事务 Spring事务的本质其实就是数据库对事务的支持,没有数据库的事务支持,spring是无法提供事务功能的.最终都是调用数据库连接来完成事务的开启.提交和回滚. 2.模块 那么在对于spring事务而言,几个不可或缺的模块就是数据源.事务管理器以及事务编程 3.xml配置 <!--事务管理器--> <bean id="springTransactionManager" class="org.springframework.jdbc.datasourc

  • 深入理解Spring事务原理

    深入理解Spring事务原理

    一.事务的基本原理 Spring事务的本质其实就是数据库对事务的支持,没有数据库的事务支持,spring是无法提供事务功能的.对于纯JDBC操作数据库,想要用到事务,可以按照以下步骤进行:  1.获取连接 Connection con = DriverManager.getConnection()  2.开启事务con.setAutoCommit(true/false);  3.执行CRUD  4.提交事务/回滚事务 con.commit() / con.rollback();  5.关闭连接

  • MySQL数据库本地事务原理解析

    在经典的数据库理论里,本地事务具备四大特征: 原子性 事务中的所有操作都是以原子的方式执行的,要么全部成功,要么全部失败: 一致性 事务执行前后,所有的数据都应该处于一致性状态---即要满足数据库表的一致性约束,也要达到业务一致性(完成了业务目标): 隔离性 并发执行的事务不应该相互干扰:隔离性的强度由隔离级别决定: 持久性 事务一旦被提交,它添加/修改的数据不会随着系统崩溃而丢失: 在MySQL(InnoDB引擎)中,原子性和持久性是通过Redo Log来实现的,一致性是通过Undo Log实

  • 简单谈谈Spring Ioc原理解析

    业务场景: 在使用Java进行开发业务的过程中,很多时候一个业务是由各种组件组成,在每个使用到这些组件时都会毫不犹豫的new一个组件对象来使用,在小项目中这样的做法无可厚非,也不存在什么问题.但是在业务逻辑复杂并且多人协作开发的项目中,这会导致业务和组件之间的关系错综复杂而且不便于管理,对象之间的耦合度变得很高,这就是所谓的牵一发而动全身吧. 而这个问题在spring中得到了解决,它的核心在于Ioc思想: Ioc:全文是Inversion of Control.翻译过来就是控制反转,意思是对象之

  • spring事务异常回滚实例解析

    最近遇到了事务不回滚的情况,我还考虑说JPA的事务有bug?我想多了....... 为了打印清楚日志,很多方法我都加tyrcatch,在catch中打印日志.但是这边情况来了,当这个方法异常时候日志是打印了,但是加的事务却没有回滚. 例: 类似这样的方法不会回滚(一个方法出错,另一个方法不会回滚): if(userSave){ try { userDao.save(user); userCapabilityQuotaDao.save(capabilityQuota); } catch (Exce

  • 这一次搞懂Spring事务注解的解析方式

    前言 事务我们都知道是什么,而Spring事务就是在数据库之上利用AOP提供声明式事务和编程式事务帮助我们简化开发,解耦业务逻辑和系统逻辑.但是Spring事务原理是怎样?事务在方法间是如何传播的?为什么有时候事务会失效?接下来几篇文章将重点分析Spring事务源码,让我们彻底搞懂Spring事务的原理. 正文 XML标签的解析 <tx:annotation-driven transaction-manager="transactionManager"/> 配置过事务的应该

  • Spring事务的开启原理详解

    在事务配置类上声明@EnableTransactionManagement注解开启事务 在事务配置类上定义数据源 在事务配置类上定义事务管理器 在相关类或者方法上使用@Transactional声明事务 代码如下: @Configuration @EnableTransactionManagement public class RootConfig{ @Bean public DataSource dataSource(){ DruidDataSource dataSource = new Dr

  • Spring事务隔离级别简介及实例解析

    Spring事务隔离级别简介及实例解析

    本文研究的主要是Spring事务隔离级别(solation level)介绍及例子,具体如下. 当两个事务对同一个数据库的记录进行操作时,那么,他们之间的影响是怎么样的呢?这就出现了事务隔离级别的概念.数据库的隔离性与并发控制有很大关系.数据库的隔离级别是数据库的事务特性ACID的一部分.ACID,即原子性(atomicity).一致性(consistency).隔离性(isolation)和持久性(durability).Spring的事务隔离级别有四个:READ_UNCOMMITTED.RE

随机推荐