开发者社区> 游客472mxcrxda2he> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

MyBatisPlus实现乐观锁

简介: MyBatisPlus实现乐观锁
+关注继续查看

MyBatisPlus实现乐观锁

1.概念

在讲概念之前,我们先来分析一个问题:

业务并发现象带来的问题:秒杀

  1. 假如有100个商品或者票在出售,为了能保证每个商品或者票只能被一个人购买,如何保证不会出现超买或者重复卖
  2. 对于这一类问题,其实有很多的解决方案可以使用
  3. 第一个最先想到的就是锁,锁在一台服务器中是可以解决的,但是如果在多台服务器下锁就没有办法控制,比如12306有两台服务器在进行卖票,在两台服务器上都添加锁的话,那也有可能会导致在同一时刻有两个线程在进行卖票,还是会出现并发问题
  4. 我们接下来介绍的这种方式是针对于小型企业的解决方案,因为数据库本身的性能就是个瓶颈,如果对其并发量超过2000以上的就需要考虑其他的解决方案了。

乐观锁:在关系数据库管理系统里,乐观并发控制(又名“乐观锁”,Optimistic Concurrency Control,缩写“OCC”)是一种并发控制的方法。它假设多用户并发的事务在处理时不会彼此互相影响,各事务能够在不产生锁的情况下处理各自影响的那部分数据。在提交数据更新之前,每个事务会先检查在该事务读取数据后,有没有其他事务又修改了该数据。如果其他事务有更新的话,那么会放弃修改。

简单来说,乐观锁主要解决的问题是当要更新一条记录的时候,希望这条记录没有被别人更新,如果别人更新了那么我就不更新了。

2.实现乐观锁的思路

乐观锁的实现方式:

  • 数据库表中添加version列,比如默认值给1
  • 第一个线程要修改数据之前,取出记录时,获取当前数据库中的==version===1
  • 第二个线程要修改数据之前,取出记录时,获取当前数据库中的==version===1
  • 第一个线程执行更新时,set version = newVersion where version = oldVersion

    • newVersion = version+1 [2] (表示更新后的值)
    • oldVersion = version [1] (表示取出记录时的值)
  • 第二个线程执行更新时,set version = newVersion where version = oldVersion

    • newVersion = version+1 [2]
    • oldVersion = version [1]
  • 假如这两个线程都来更新数据,第一个和第二个线程都可能先执行

    • 假如第一个线程先执行更新,会把version改为2,
    • 第二个线程再更新的时候,set version = 2 where version = 1,此时数据库表的数据version已经为2,所以第二个线程会修改失败
    • 反之同理
    • 不管谁先执行都会确保只能有一个线程更新数据,这就是MP提供的乐观锁的实现原理分析。

3.实现乐观锁的具体步骤

  1. 在数据库表上添加version列,我这里直接创建一个新表方便演示
CREATE TABLE goods (
    id BIGINT(20) PRIMARY KEY AUTO_INCREMENT,
    NAME VARCHAR(32) NOT NULL,
    prices INT(10) NOT NULL ,
    `version` INT(10) NOT NULL DEFAULT 1
);

INSERT INTO goods VALUES(NULL,'book',10,1);
INSERT INTO goods VALUES(NULL,'computer',3000,1);

表的内容如下:

image-20220704214221536

  1. 在模型类中添加对应的属性
@Data
public class Goods {
    /**
     * 实现id自增长
     */
    @TableId(type = IdType.AUTO)
    private Integer id;
    private String name;
    //标记此属性为version列对应的属性
    @Version
    private Integer version;
}
  1. 添加乐观锁的拦截器
@Configuration
public class MybatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor(){
        //1 创建MybatisPlusInterceptor拦截器对象
        MybatisPlusInterceptor mpInterceptor=new MybatisPlusInterceptor();
        //2 添加乐观锁拦截器
        mpInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return mpInterceptor;
    }
}
  1. 在测试类中执行更新操作
@SpringBootTest
class SpringBootMypatisPlusApplicationTests {

    @Autowired
    private GoodsDao goodsDao;

    @Test
    void test()
    {
        Goods goods = new Goods();
        goods.setId(1);
        goods.setPrices(100);
        goodsDao.updateById(goods);
    }
}

在这里插入图片描述

通过结果我们可以发现,我们创建的这个对象并没有设置version数据,所以也就没有更新version字段

添加version数据

@SpringBootTest
class SpringBootMypatisPlusApplicationTests {

    @Autowired
    private GoodsDao goodsDao;

    @Test
    void test()
    {
        Goods goods = new Goods();
        goods.setId(1);
        goods.setVersion(1);
        goods.setPrices(100);
        goodsDao.updateById(goods);
    }
}

在这里插入图片描述

此时你可以发现,我们传递的是1,更新时会将version+1得到2,然后更新数据到数据库表里。

此时我们需要注意的是,我们设置的version数据就相当于上面讲的oldVersion,如果和数据库表中的不同,则sql更新失败

所以我们要想实现乐观锁,首先就是要得到表中要查找的那条数据的version,然后拿version当条件在将version加1更新回到数据库表中,所以我们在查询的时候,需要对其进行查询

@SpringBootTest
class SpringBootMypatisPlusApplicationTests {

    @Autowired
    private GoodsDao goodsDao;

    @Test
    void test()
    {
        //1.先通过要修改的数据id将当前数据查询出来
        //获得version字段值
        Goods goods = goodsDao.selectById(1);
        //2.修改数据
        goods.setPrices(200);
        goodsDao.updateById(goods);
    }
}

在这里插入图片描述

现在我们来模拟一遍秒杀的过程,看看多人修改同一商品的时候,是不是只能有一个人修改成功。

@SpringBootTest
class SpringBootMypatisPlusApplicationTests {

    @Autowired
    private GoodsDao goodsDao;

    @Test
    void test() {
        //1.先通过要修改的数据id将当前数据查询出来
        //获得version字段值
        Goods goods1 = goodsDao.selectById(1); // version = 3
        Goods goods2 = goodsDao.selectById(1); // version = 3
        //2.修改数据
        goods1.setPrices(1000);
        goodsDao.updateById(goods1);// 修改完后 version = 4
        goods2.setPrices(1000);
        goodsDao.updateById(goods2);// 此时 oldversion的值已经发生变化,不在等于3,所以修改失败
    }
}

在这里插入图片描述

在这里插入图片描述

至此,一个简单的乐观锁就实现了。

笔记参考B站黑马程序员:黑马程序员2022最新SSM框架教程

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
【mybatis-plus】什么是乐观锁?如何实现“乐观锁”
【mybatis-plus】什么是乐观锁?如何实现“乐观锁”
27 0
【多线程:线程八锁】
【多线程:线程八锁】
13 0
我也说说Emacs吧(4) - 光标的移动
spacemacs的光标移动命令,兼容vi的操作,与标准emacs有所不同
1476 0
使用 CSS3 动画实现的 3D 图片过渡特效
  这是一个基于 CSS3 动画实现的图片过渡效果,共有 Flip、Rotation、Multi-flip、Cube、Unfold 等6种效果,它们将证明 CSS3 Transform 和 Transition 属性的强大能力。
990 0
文章
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载