MyBatisPlus乐观锁和悲观锁的实现示例

更新时间：2025年11月30日 15:01:08 作者：222you

本文主要介绍了MyBatisPlus乐观锁和悲观锁,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

1.场景

一件商品，成本价是80元，售价是100元。老板先是通知小李，说你去把商品价格增加50元。小李正在玩游戏，耽搁了一个小时。正好一个小时后，老板觉得商品价格增加到150元，价格太高，可能会影响销量。又通知小王，你把商品价格降低30元。

此时，小李和小王同时操作商品后台系统。小李操作的时候，系统先取出商品价格100元；小王也在操作，取出的商品价格也是100元。小李将价格加了50元，并将100+50=150元存入了数据库；小王将商品减了30元，并将100-30=70元存入了数据库。是的，如果没有锁，小李的操作就完全被小王的覆盖了。

现在商品价格是70元，比成本价低10元。几分钟后，这个商品很快出售了1千多件商品，老板亏1 万多。

2.乐观锁和悲观锁

上面的故事，如果是乐观锁，小王保存价格前，会检查下价格是否被人修改过了。如果被修改过了，则重新取出的被修改后的价格， 150元，这样他会将120元存入数据库。

如果是悲观锁，小李取出数据后，小王只能等小李操作完之后，才能对价格进行操作，也会保证最终的价格是120元。

3.乐观锁实现

添加插件：

    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        // 添加分页插件
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));

        // 添加乐观锁插件
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }

创建表：

CREATE TABLE t_product
(
    id BIGINT(20) NOT NULL COMMENT '主键ID',
    NAME VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名称 ',
    price INT(11) DEFAULT 0 COMMENT '价格 ',
    VERSION INT(11) DEFAULT 0 COMMENT '乐观锁版本号 ',
    PRIMARY KEY (id)
);

添加数据：

INSERT INTO t_product (id, NAME, price) VALUES (1, '外星人笔记本 ', 100);

如图：

编写实体类：

package com.qcby.entity;

import com.baomidou.mybatisplus.annotation.Version;
import lombok.Data;

@Data
public class Product {
    private Long id;
    private String name;
    private Integer price;

    @Version
    private Integer version;
}

mapper：

package com.qcby.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.qcby.entity.Product;
import org.springframework.stereotype.Repository;

@Repository
public interface ProductMapper extends BaseMapper<Product> {
}

测试：

package com.qcby;

import com.qcby.entity.Product;
import com.qcby.mapper.ProductMapper;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class MybatisTestOptimisticLock {

    @Autowired
    private ProductMapper productMapper;

    @Test
    public void testOptimisticLock() {
        // 小李查询商品信息
        Product productLi = productMapper.selectById(1L);
        System.out.println("小李查询价格: " + productLi.getPrice() + ", 版本: " + productLi.getVersion());

        // 小王查询商品信息
        Product productWang = productMapper.selectById(1L);
        System.out.println("小王查询价格: " + productWang.getPrice() + ", 版本: " + productWang.getVersion());

        // 小李修改价格 +50
        productLi.setPrice(productLi.getPrice() + 50);
        int resultLi = productMapper.updateById(productLi);
        System.out.println("小李修改结果: " + resultLi);

        if (resultLi > 0) {
            Product afterLi = productMapper.selectById(1L);
            System.out.println("小李修改后价格: " + afterLi.getPrice() + ", 版本: " + afterLi.getVersion());
        }

        // 小王修改价格 -30
        productWang.setPrice(productWang.getPrice() - 30);
        int resultWang = productMapper.updateById(productWang);
        System.out.println("小王修改结果: " + resultWang);

        if (resultWang == 0) {
            // 小王修改失败，需要重新尝试
            System.out.println("小王修改失败，版本已变更，需要重新操作");
            Product newProductWang = productMapper.selectById(1L);
            newProductWang.setPrice(newProductWang.getPrice() - 30);
            resultWang = productMapper.updateById(newProductWang);
            System.out.println("小王重试结果: " + resultWang);
        }

        // 最终价格
        Product finalProduct = productMapper.selectById(1L);
        System.out.println("最终价格: " + finalProduct.getPrice() + ", 版本: " + finalProduct.getVersion());
    }
}

实际流程：

1. 小李查询: SELECT id,name,price,version FROM t_product WHERE id=1
结果: price=100, version=0

2. 小王查询: SELECT id,name,price,version FROM t_product WHERE id=1
结果: price=100, version=0

3. 小李更新: UPDATE t_product SET name=?, price=150, version=1
WHERE id=1 AND version=0
成功: version变为1

4. 小王更新: UPDATE t_product SET name=?, price=70, version=1
WHERE id=1 AND version=0
失败: version条件不匹配

5. 小王重试: 重新查询 price=150, version=1
更新: SET price=120, version=2 WHERE id=1 AND version=1
成功

6. 最终价格: 120元 (正确的价格)

4.悲观锁

悲观锁总是假设最坏的情况，认为共享资源每次被访问的时候就会出现问题(比如共享数据被修改)，所以每次在获取资源操作的时候都会上锁，这样其他线程想拿到这个资源就会阻塞直到锁被上一个持有者释放。也就是说，共享资源每次只给一个线程使用，其它线程阻塞，用完后再把资源转让给其它线程。

到此这篇关于MyBatisPlus乐观锁和悲观锁的实现示例的文章就介绍到这了,更多相关MyBatisPlus乐观锁和悲观锁内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

jvm crash的崩溃日志详细分析及注意点
本篇文章主要介绍了jvm crash的崩溃日志详细分析及注意点。具有很好的参考价值，下面跟着小编一起来看下吧
2017-04-04
JAVA springboot如何开启俩端口
这篇文章主要介绍了JAVA springboot如何开启俩端口问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2025-03-03
使用SpringSecurity设置角色和权限的注意点
这篇文章主要介绍了使用SpringSecurity设置角色和权限的注意点，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-03-03
通过原理解析Spring mvc的内置编码过滤器
这篇文章通过原理主要给大家解析了关于Spring mvc的内置编码过滤器的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起看看吧。
2017-09-09
使用springboot对外部静态资源文件的处理操作
这篇文章主要介绍了使用springboot对外部静态资源文件的处理操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-08-08
详解SpringBoot如何实现统一后端返回格式
在前后端分离的项目中后端返回的格式一定要友好，不然会对前端的开发人员带来很多的工作量。那么SpringBoot如何做到统一的后端返回格式呢？本文将为大家详细讲讲
2022-04-04
Java高级之HashMap中的entrySet()方法使用
这篇文章主要介绍了Java高级之HashMap中的entrySet()方法使用，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-03-03
$解决Java properties文件里面如何写"\"的问题$
解决Java properties文件里面如何写"\"的问题
由于properties使用“\”相当于是java的转义符，如果想要写出\的效果，只需修改相应的写法即可，对java properties文件里的"\"写法感兴趣的朋友一起看看吧
2022-04-04
详解SpringMVC的类型转换及验证方法
在本篇文章里面我们给大家详细分析了SpringMVC的类型转换及验证方法的相关知识，对此有需要的朋友们学习下吧。
2018-10-10
Java版坦克大战游戏源码示例
本篇文章主要介绍了Java版坦克大战游戏源码示例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-10-10