一、乐观锁概念
业务并发现象带来的问题:秒杀
● 假如有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?条件还成立吗? } }
运行程序,执行结果分析:
此时乐观锁已经实现完成,也可以通过参考官方文档来实现乐观锁。
乐观锁插件 | MyBatis-Plus (baomidou.com)
https://baomidou.com/pages/0d93c0/#optimisticlockerinnerinterceptor