Mybatis-Plus15: 悲观锁 乐观锁

MyBatis-Plus 对乐观锁提供了原生支持但对悲观锁没有专门封装需要借助底层 SQL 或 MyBatis 原生方式实现。一、乐观锁Optimistic LockMyBatis-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?, versionversion1 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 LockMyBatis-Plus没有提供专门的悲观锁插件因为悲观锁是数据库层面的机制需要通过 SQL 的FOR UPDATE实现。方式一手写 SQL推荐在 Mapper 中用Select手写带FOR UPDATE的 SQLpublic interface ProductMapper extends BaseMapperProduct { Select(SELECT * FROM product WHERE id #{id} FOR UPDATE) Product selectByIdForUpdate(Long id); }Service 层调用Service public class ProductServiceImpl extends ServiceImplProductMapper, 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 idselectByIdForUpdate resultTypecom.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(更新失败请重试); }