美文网首页
记一次线上事务并发问题

记一次线上事务并发问题

作者: 给时光生命 | 来源:发表于2018-09-25 09:50 被阅读14次

今天一同事线上遇到一个问题,程序不明原因的进入了死循环。最后通过一步步分析代码的线程运行情况,定位出是事务产生的并发问题

我们看下代码入口。
    @Transactional
    public Result<Boolean> execute(Map<String, String> currentRow, Map<String, String> contextInfo) {
        ...
         synchronized (this) {
              userVipCardDO.setCardNo(userVipCardService.getVipCardNo(contextInfo.get("storeId")));
         }             
    }

此方法可能多线程运行

第2个方法代码

private int getVipCardNo(String storeId) {
        //获取数据库当前值
        SerialNumberDO serialNumberDO = serialNumberDao.getByKey(Long.parseLong(storeId), SerialBusiType.HY.getCode());
        if (serialNumberDO == null) {
            ...
            return 1;
        }
        //查出数据库当前值
        long counter = serialNumberDO.getCounter();
        SerialNumberDO updateDO = new SerialNumberDO();
        ...
        updateDO.setCounter(counter);
        int i = serialNumberDao.increase(updateDO);
        if(i == 0){
            return getVipCardNo(storeId);
        }else {
            return counter;
        }
    }

相当于一个乐观锁 compare And Set
此处呢,由于外面synchronized单线程运行
这是一个递归调用

第3个dao层sql

 <update id="increase" parameterType="SerialNumberDO">
        update sh_serial_number
        set counter = counter+1
        where store_id = #{storeId}
        and busi_type = #{busiType}
        and counter = #{counter}
</update>

乐观锁sql

问题出在哪呢。

  1. 第一断代码,当时所有线程进来读到的值都是8
  2. @Transactional 默认事务隔离级别Repeatable read 可重复读
    1. 这就意味着第一步多个线程进来后。读到的值,其它事务进行修改提交之后。它还是读的当 时进来的这个值8
  3. 第一个线程读到8 当时数据库确实是8 所以修改成 9 修改成功
  4. 第一个之后的线程呢 。
    1. 当时进来时开启事务数据库里是8
    2. synchronized等待
    3. 等第一个修改成功之后进去select
    4. 由于事务隔离级别Repeatable read的原因,虽然数据库里改成了9,它这里仍然读到是8
    5. 然后update .... and counter=#{counter} 比较的时候呢,却是比较数据库真实的值,所有 8=9一直不成功
    6. 一直重试递归调用 进入了死循环
问题找到了,那么最简单的解决方案就是@Transactional(isolation = Isolation.READ_COMMITTED) 将隔离级别降低一级。读取已提交的

最后分下这个代码

  1. 如果不加synchronized其实也会出问题。只是出的几率小一点。
  2. 为了其它service方法使用默认隔离级别,调用getVipCardNo 不出类似问题。我觉得应该利用事务传播行为,
    getVipCardNo开启一个新的事务,再将隔离级别设置成读取已提交的

相关文章

  • 记一次线上事务并发问题

    今天一同事线上遇到一个问题,程序不明原因的进入了死循环。最后通过一步步分析代码的线程运行情况,定位出是事务产生的并...

  • 2019-01-18

    1.MySQL事务隔离级别:事务隔离级别,解决什么并发问题,以及存在什么并发问题 (1)READ_UNCOMMIT...

  • Hibernate之事务管理

    一、事务并发问题 数据库没有做任何并发处理的情况下有5类事务并发问题 A:第一类丢失更新:两个事务更新相同数据,如...

  • Maridb中的事务

    今天对mariadb事务并发的五类问题,进行了测试,结果得到以下的结论 事务并发5类问题(如果数据库没有做任何并发...

  • 数据库事务--事务隔离级别

    数据库里关于事务的并发问题,也叫做竞态条件(race condition)。它是描述并发事务中,一个事务需要读取另...

  • 事务的隔离、传播、回滚

    springboot之事务的隔离与传播 事务的隔离 多个事务是并发的访问数据库,并发是必须的但会带来几个问题: 脏...

  • 第六章 锁(下)

    6.5 锁问题通过锁机制可以实现事务隔离性要求,使得事务可以并发地工作。锁提高了并发,但是却会带来潜在的问题。不过...

  • mysql事务隔离机制及其原理

    目录 事务特性ACID属性 并发事务带来的问题 事务隔离级别 事务实现原理 闲聊 【迈莫coding】 事务特性A...

  • mysql事务隔离机制及其隔离级别、实现原理分析

    目录 事务特性ACID属性 并发事务带来的问题 事务隔离级别 事务实现原理 事务特性ACID属性 事务特性指的就是...

  • Mysql神乎乎的MVCC到底该怎么理解

    引言 MVCC即多版本并发控制主要是为了解决数据库中并发事务读写的一致性问题,那么多个事务并发执行的时候事务的隔离...

网友评论

      本文标题:记一次线上事务并发问题

      本文链接:https://www.haomeiwen.com/subject/kwykoftx.html