java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > MybatisPlus 悲观锁 & 乐观锁

MybatisPlus实现悲观锁 & 乐观锁的项目实践

作者：ruleslol

MyBatis-Plus 对乐观锁提供了原生支持,但对悲观锁没有专门封装,需要借助底层 SQL 或 MyBatis 原生方式实现,本文详解乐观锁插件配置与悲观锁手写SQL方案,对比性能与适用场景,感兴趣的可以了解一下

MyBatis-Plus 对乐观锁提供了原生支持，但对悲观锁没有专门封装，需要借助底层 SQL 或 MyBatis 原生方式实现。

一、乐观锁（Optimistic Lock）

MyBatis-Plus 内置了乐观锁插件，核心思路是：更新时检查版本号，版本号匹配才更新，同时版本号+1。

1. 实体类加@Version注解

@Data
public class Product {
    private Long id;
    private String name;
    private Integer price;
    
    @Version  // 乐观锁版本号字段
    private Integer version;
}

2. 配置乐观锁拦截器

@Configuration
public class MybatisPlusConfig {
    
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        // 添加乐观锁拦截器
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }
}

3. 使用方式

// 1. 先查询出实体（version 会被查出来）
Product product = productService.getById(1L);

// 2. 修改数据
product.setPrice(product.getPrice() + 100);

// 3. 执行更新（MP 会自动在 WHERE 条件中加上 version = ?）
// 生成的 SQL 类似：
// UPDATE product SET price=?, version=version+1 WHERE id=? AND version=?
boolean success = productService.updateById(product);

4. 注意事项

注意点说明
version 字段类型支持 int、Integer、long、Long、Date、Timestamp
必须查后更新updateById(entity) 才会生效，直接 new 一个对象更新不会触发乐观锁
自增逻辑框架自动 version + 1，无需手动设置
更新失败如果返回 false，说明数据已被他人修改，需要业务上重试或抛异常

5. 批量更新也支持

// 批量更新时，每个实体的 version 都会参与 WHERE 条件
productService.updateBatchById(productList);

二、悲观锁（Pessimistic Lock）

MyBatis-Plus 没有提供专门的悲观锁插件，因为悲观锁是数据库层面的机制，需要通过 SQL 的 FOR UPDATE 实现。

方式一：手写 SQL（推荐）

在 Mapper 中用 @Select 手写带 FOR UPDATE 的 SQL：

public interface ProductMapper extends BaseMapper<Product> {
    
    @Select("SELECT * FROM product WHERE id = #{id} FOR UPDATE")
    Product selectByIdForUpdate(Long id);
}

Service 层调用：

@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> 
    implements ProductService {
    
    @Transactional  // 必须在事务中，FOR UPDATE 才有效
    public void deductStock(Long id) {
        // 1. 加锁查询
        Product product = baseMapper.selectByIdForUpdate(id);
        
        // 2. 执行业务逻辑
        if (product.getStock() > 0) {
            product.setStock(product.getStock() - 1);
            updateById(product);
        }
    }
}

方式二：用 Wrapper 拼接（不推荐，容易出问题）

// 不推荐，因为 FOR UPDATE 是写在 SQL 末尾的，QueryWrapper 不好控制位置
// 而且 MP 的 selectOne 等方法不支持直接加 FOR UPDATE

方式三：XML 方式

<!-- ProductMapper.xml -->
<select id="selectByIdForUpdate" resultType="com.example.entity.Product">
    SELECT * FROM product WHERE id = #{id} FOR UPDATE
</select>

三、对比与选型

特性乐观锁悲观锁
MP 支持✅ 原生插件支持❌ 需手写 SQL
实现机制版本号控制SELECT ... FOR UPDATE
性能高（无锁等待）低（有锁竞争、阻塞）
适用场景读多写少、冲突概率低写多读少、冲突概率高、强一致性
失败处理更新失败需重试排队等待，不会失败
事务要求非必须必须在事务中

四、最佳实践建议

优先用乐观锁：绝大多数互联网场景读多写少，乐观锁性能更好，MP 支持也完善。

悲观锁用于强一致性场景：如库存扣减、金融转账等高并发写场景。

乐观锁失败重试：

// 简单的重试机制
public boolean updateWithRetry(Product product, int maxRetries) {
    for (int i = 0; i < maxRetries; i++) {
        if (productService.updateById(product)) {
            return true;
        }
        // 重新查询最新数据
        product = productService.getById(product.getId());
    }
    throw new RuntimeException("更新失败，请重试");
}

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

您可能感兴趣的文章:
阅读全文