Spring Retry 实现乐观锁重试实践记录

2025-03-01 17:50
文章标签 java 实现 实践 记录 spring 重试 乐观 retry

本文主要是介绍Spring Retry 实现乐观锁重试实践记录，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

《SpringRetry实现乐观锁重试实践记录》本文介绍了在秒杀商品SKU表中使用乐观锁和MybatisPlus配置乐观锁的方法,并分析了测试环境和生产环境的隔离级别对乐观锁的影响,通过简单验证,...

一、场景分析

假设有这么一张表：

create table pms_sec_kill_sku
(
    id             int auto_increment comment '主键ID'
        primary key,
    spec_detail    varchar(50)              not null comment '规格描述',
    purchase_price decimal(10, 2)           not null comment '采购价格',
    sale_price     decimal(10, 2)           not null comment '销售价格',
    origin_stock   int unsigned default '0' not null comment '初始库存',
    sold_stock     int unsigned default '0' not null comment '已售库存',
    stock          int unsigned default '0' not null comment '实时库存',
    occupy_stock   int unsigned default '0' not null comment '订单占用库存',
    version        int          dpythonefault 0   not null comment '乐观锁版本号',
    created_time   datetime                 not null comment '创建时间',
    updated_time   datetime                 not null comment '更新时间'
)
    comment '促销管理服务-秒杀商品SKU';

一张简单的秒杀商品SKU表。使用 version 字段做乐观锁。使用 unsigned 关键字，限制 int 类型非负，防止库存超卖。

 使用 MyBATisPlus 来配置乐观锁：

import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;
@EnableTransactionManagement
@Configuration
public class MybatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        // 分页插件
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.mysql));
        // 乐观锁插件
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }
    @Bean
    public DefaultDBFieldHandler defaultDBFieldHandler() {
        DefaultDBFieldHandler defaultDBFieldHandler = new DefaultDBFieldHandler();
        return defaultDBFieldHandler;
    }
}
@Data
@TableName("pms_sec_kill_sku")
@ApiModel(value = "PmsSecKillSku对象", description = "促销管理-秒杀商品SKU")
public class PmsSecKillSku implements Serializable {
    private static final long serialVersionUID = 1L;
    // @Version 注解不能遗漏
    @Version
    @ApiModelProperty("乐观锁版本号")
    private Integer version;
    // other properties ......
}

 现在有这么一个支付回调接口：

/**
 * 促销管理-秒杀商品SKU 服务实现类
 * @since 2025-02-26 14:21:42
 */
@Service
public class PmsSecKillSkuServiceImpl extends ServiceImpl<PmsSecKillSkuMapper, PmsSecKillSku> implements PmsSecKillSkuService {
    // 最大重试次数
    private static final int MAX_RETRIES = 3;
    /**
     * 订单支付成功回调
     * 假设每次只能秒杀一个数量的SKU
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void paySucCallback(Integer skuId) {
        // 持久化库存
        int count = 0, retries = 0;
        while (count == 0 && retries < MAX_RETRIES) {
            PmsSecKillSkuVo pmsSkuVo = this.baseMapper.findDetailById(skuId);
            PmsSecKilljsSku wt = new PmsSecKillSku();
            wt.setId(pmsSkuVo.getId());
            wt.setVersion(pmsSkuVo.getVersion());
            // 占用库存减1
            wt.setOccupyStock( pmsSkuVo.getOccupyStock()-1 );
            // 已售库存加1
            wt.setSoldStock( pmsSkuVo.getSoldStock()+1 );
            // 实时库存减1
            wt.setStock( pmsSkuVo.getStock()-1 );
            count = this.baseMapper.updateById(wt);
            retries++;
            if (count == 0) {
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    throw new BusinessException(e.getMessage());
                }
            }
        }
        if (count == 0) {
            throw new BusinessException("请刷新后重新取消!");
        }
    }
}

该方法的目的，是为了进行库存更新，当乐观锁版本号有冲突时，对方法进行休眠重试。

该方法在测试环境还能正常跑，到了生产环境，却频繁报 "请刷新后重新取消!"

仔细分析后发现，测试环境的MYSQL数据库全局隔离级别是，READ-COMMITTED（读已提交）。而生产环境是 REPEATABLE_READ（可重复读）。

SHOW GLOBAL VARIABLES LIKE 'transaction_isolation';
  • 在读已提交隔离级别下，该方法每次重试，都能读取到别的事务提交的最新的 version，相当于拿到乐观锁。
  • 在可重复读隔离级别下，因为有 MVCC 多版本并发控制，该方法每次重试，读取到的都是同一个结果，相当于一直拿不到乐观锁。所以多次循环之后，count 还是等于 0，程序抛出异常。

 二、简单验证

假设现在表里面有这么一条记录：

INSERT INTO `pms_sec_kill_sku` 
(`id`, `spec_detail`, `purcphphase_price`, `sale_price`, 
`origin_stock`, `sold_stock`, `stock`, `occupy_stock`, 
`version`, `created_time`, `updated_time`) VALUES 
(1, '尺码:M1', 100.00, 1.00, 
2, 0, 2, 2, 
2, '2025-02-26 15:51:22', '2025-02-26 15:51:24');

 2.1、可重复读

 修改服务程序：

Spring Retry 实现乐观锁重试实践记录

  • 增加会话的隔离级别为 isolation = Isolation.REPEATABLE_READ 可以重复读。
  • 增加记录日志。
  • 在方法更新前阻塞当前线程，模拟另一个事务先提交。
@Api(value = "促销管理-秒杀商品SKU", tags = {"促销管理-秒杀商品SKU接口"})
@RestController
@RequiredArgsConstructor
@RequestMapping("pmsSecKillSku")
public class PmsSecKillSkuController {
    private final PmsSecKillSkuService pmsSecKillSkuService;
    @ApiOperation(value = "支付成功", notes = "支付成功")
    @PostMapping("/pay")
    public R<Void> pay(Integer id) {
        pmsSecKillSkuService.paySucCallback(id);
        return R.success();
    }
}

访问接口：

###
POST http://localhost:5910/pmsSecKillSku/pay?id=1
Content-Type: application/json
token: 123

在第0次查询的时候，执行更新：

UPDATE `pms_sec_kill_sku`
SET sold_stock = sold_stock + 1, stock = stock - 1, 
occupy_stock = occupy_stock - 1, version = version + 1
WHERE id = 1;

可以看到，三次查询，返回结果都是一样的：

Spring Retry 实现乐观锁重试实践记录

Spring Retry 实现乐观锁重试实践记录

数据库的版本号只有3：

Spring Retry 实现乐观锁重试实践记录

 2.2、读已提交

修改会话的隔离级别为 isolation = Isolation.READ_COMMITTED 读已提交。

Spring Retry 实现乐观锁重试实践记录

恢复数据：

Spring Retry 实现乐观锁重试实践记录

访问接口：

###
POST http://localhost:5910/pmsSecKillSku/pay?id=1
Content-Type: application/json
token: 123

 在第0次查询的时候，执行更新：

UPDATE `pms_sec_kill_sku`
SET sold_stock = sold_stock + 1, stock = stock - 1, 
occupy_stock = occupy_stock - 1, version = version + 1
WHERE id = 1;

Spring Retry 实现乐观锁重试实践记录

 可以看到，第0次查询的时候，version=2；执行完 SQL语句，第1次查询的时候，version=3；拿到了乐观锁，更新成功。

 三、最佳实践

可以看到，使用 Thread.sleep 配合循环来进行获取乐观锁的重试，存在一些问题：

  • 依赖事务隔离级别的正确设置。
  • 休眠的时间不好把控。
  • 代码复用性差。

Spring Retry 提供了一种更优雅的方式，来进行乐观锁的重试。

 恢复数据：

Spring Retry 实现乐观锁重试实践记录

 3.1、配置重试模板

import org.springframework.retry.policy.SimpleRetryPolicy;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.retry.annotation.EnableRetry;
import org.springframework.retry.backoff.FixedBackOffPolicy;
import org.springframework.retry.support.RetryTemplate;
@Configuration
@EnableRetry
public class RetryConfig {
    @Bean
    public RetryTemplate retryTemplate() {
        RetryTemplate retryTemplate = new RetryTemplate();
        // 设置重试策略，这里设置最大重试次数为3次
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(3);
        retryTemplate.setRetryPolicy(retryPolicy);
        // 设置重试间隔时间，这里设置为固定的500毫秒
        // 可以根据系统的并发度，来设置
        // 并发度高，设置长一点，并发度低，设置短一点
    VQbxnmbh    FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
        backOffPolicy.setBackOffPeriod(500);
        retryTemplate.setBackOffPolicy(backOffPolicy);
        return retryTemplate;
    }
}

 3.2、使用 Spring 的@Retryable注解

@Override
    @Retryable(value = OptimisticLockingFailureException.class)
    @Transactional(rollbackFor = Exception.class, 
                    isolation = Isolation.REPEATABLE_READ)
    public void paySucRetry(Integer skuId) {
        PmsSecKillSkuVo pmsSkuVo = this.baseMapper.findDetailById(skuId);
        log.info("===============查询结果为{}", pmsSkuVo);
        PmsSecKillSku wt = new PmsSecKillSku();
        wt.setId(pmsSkuVo.getId());
        wt.setVersion(pmsSkuVo.getVersion());
        // 占用库存减1
        wt.setOccupyStock( pmsSkuVo.getOccupyStock()-1 );
        // 已售库存加1
        wt.setSoldStock( pmsSkuVo.getSoldStock()+1 );
        // 实时库存减1
        wt.setStock( pmsSkuVo.getStock()-1 );
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            throw nphpew BusinessException(e.getMessage());
        }
        int count = this.baseMapper.updateById(wt);
        if (count == 0) {
            throw new OptimisticLockingFailureException("乐观锁冲突");
        }
    }

当乐观锁冲突的时候，抛出异常， OptimisticLockingFailureException。

这里特意设置事务隔离级别为 REPEATABLE_READ

3.3、测试

 访问接口：

@Api(value = "促销管理-秒杀商品SKU", tags = {"促销管理-秒杀商品SKU接口"})
@RestController
@RequiredArgsConstructor
@RequestMapping("pmsSecKillSku")
public class PmsSecKillSkuController {
    private final PmsSecKillSkuService pmsSecKillSkuService;
    @ApiOperation(value = "可重试", notes = "可重试")
    @PostMapping("/retry")
    public R<Void> retry(Integer id) {
        pmsSecKillSkuService.paySucRetry(id);
        return R.success();
    }
}
###
POST http://localhost:5910/pmsSecKillSku/retry?id=1
Content-Type: application/json
token: 123

 在第0次查询的时候，执行更新：

UPDATE `pms_sec_kill_sku`
SET sold_stock = sold_stock + 1, stock = stock - 1, 
occupy_stock = occupy_stock - 1, version = version + 1
WHERE id = 1;

Spring Retry 实现乐观锁重试实践记录

可以看到，在第二次查询的时候，就获取到锁，并成功执行更新。

到此这篇关于Spring Retry 实现乐观锁重试的文章就介绍到这了,更多相关Spring Retry 乐观锁重试内容请搜索China编程(www.chinasem.cn)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程China编程(www.chinasem.cn)！

这篇关于Spring Retry 实现乐观锁重试实践记录的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1153599。

相关文章

Spring事务传播机制最佳实践

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED（默认）2.2 SUPPORTS2
阅读更多...
怎样通过分析GC日志来定位Java进程的内存问题

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》：本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.
阅读更多...
Java进程异常故障定位及排查过程

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》：本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存
阅读更多...
Python实现对阿里云OSS对象存储的操作详解

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os
阅读更多...
java中新生代和老生代的关系说明

java中新生代和老生代的关系说明

《java中新生代和老生代的关系说明》：本文主要介绍java中新生代和老生代的关系说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、内存区域划分新生代老年代二、对象生命周期与晋升流程三、新生代与老年代的协作机制1. 跨代引用处理2. 动态年龄判定3. 空间分
阅读更多...
Java设计模式---迭代器模式(Iterator)解读

Java设计模式---迭代器模式(Iterator)解读

《Java设计模式---迭代器模式(Iterator)解读》：本文主要介绍Java设计模式---迭代器模式(Iterator),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录1、迭代器（Iterator）1.1、结构1.2、常用方法1.3、本质1、解耦集合与遍历逻辑2、统一
阅读更多...
Java内存分配与JVM参数详解(推荐)

Java内存分配与JVM参数详解(推荐)

《Java内存分配与JVM参数详解(推荐)》本文详解JVM内存结构与参数调整,涵盖堆分代、元空间、GC选择及优化策略,帮助开发者提升性能、避免内存泄漏,本文给大家介绍Java内存分配与JVM参数详解,... 目录引言JVM内存结构JVM参数概述堆内存分配年轻代与老年代调整堆内存大小调整年轻代与老年代比例元空
阅读更多...
深度解析Java DTO(最新推荐)

深度解析Java DTO(最新推荐)

《深度解析JavaDTO(最新推荐)》DTO（DataTransferObject）是一种用于在不同层（如Controller层、Service层）之间传输数据的对象设计模式,其核心目的是封装数据,... 目录一、什么是DTO？DTO的核心特点：二、为什么需要DTO？（对比Entity）三、实际应用场景解析
阅读更多...
Java 线程安全与 volatile与单例模式问题及解决方案

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因（调度随机、变量修改、非原子操作、内存可见性、指令重排序）及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操
阅读更多...
关于集合与数组转换实现方法

关于集合与数组转换实现方法

《关于集合与数组转换实现方法》：本文主要介绍关于集合与数组转换实现方法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、Arrays.asList()1.1、方法作用1.2、内部实现1.3、修改元素的影响1.4、注意事项2、list.toArray()2.1、方
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2