MyBatisPlus-乐观锁概念及实现步骤-阿里云开发者社区

MyBatisPlus-乐观锁概念及实现步骤

2023-12-15 46

版权

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

简介： MyBatisPlus-乐观锁概念及实现步骤

一、乐观锁概念

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

● 假如有100个商品或者票在出售，为了能保证每个商品或者票只能被一个人购买，如何保证不会出现超买或者重复卖

● 对于这一类问题，其实有很多的解决方案可以使用

● 第一个最先想到的就是锁，锁在一台服务器中是可以解决的，但是如果在多台服务器下锁就没有办法控制，比如12306有两台服务器在进行卖票，在两台服务器上都添加锁的话，那也有可能会导致在同一时刻有两个线程在进行卖票，还是会出现并发问题

● 我们接下来介绍的这种方式是针对于小型企业的解决方案，因为数据库本身的性能就是个瓶颈，如果对其并发量超过2000以上的就需要考虑其他的解决方案了。

简单来说，乐观锁主要解决的问题是当要更新一条记录的时候，希望这条记录没有被别人更新。

二、乐观锁实现方式

● 数据库表中添加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，所以第二个线程会修改失败

◆ 假如第二个线程先执行更新，会把version改为2，

◆ 第一个线程再更新的时候，set version = 2 where version = 1,此时数据库表的数

据version已经为2，所以第一个线程会修改失败

◆ 不管谁先执行都会确保只能有一个线程更新数据，这就是MP提供的乐观锁的实现原理分析。

三、乐观锁实现步骤

1、数据库表添加列

列名可以任意，比如使用version，给列设置默认值为1

2、在模型类中添加对应的属性

根据添加的字段列名，在模型类中添加对应的属性值

@Data 
//@TableName("tbl_user") 可以不写是因为配置了全局配置 
public class User { 
    @TableId(type = IdType.ASSIGN_UUID) 
    private String id; 
    private String name; 
    @TableField(value="pwd",select=false) 
    private String password; 
    private Integer age; 
    private String tel; 
    @TableField(exist=false) 
    private Integer online;
    private Integer deleted; 
    @Version 
    private Integer version; 
}

3、添加乐观锁拦截器

@Configuration 
public class MpConfig { 
    @Bean 
    public MybatisPlusInterceptor mpInterceptor() { 
        //1.定义Mp拦截器 
        MybatisPlusInterceptor mpInterceptor = new MybatisPlusInterceptor(); 
        //2.添加乐观锁拦截器 
        mpInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor()); 
        return mpInterceptor; 
    } 
}

4、执行更新操作

@SpringBootTest 
class Mybatisplus03DqlApplicationTests { 
    @Autowired 
    private UserDao userDao; 
    @Test 
    void testUpdate(){ 
        //1.先通过要修改的数据id将当前数据查询出来 
        User user = userDao.selectById(3L); //version=3 
        User user2 = userDao.selectById(3L); //version=3 
        user2.setName("Jock aaa"); 
        userDao.updateById(user2); //version=>4 
        user.setName("Jock bbb"); 
        userDao.updateById(user); //verion=3?条件还成立吗？ 
    }
}