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。

相关文章

SpringBoot中六种批量更新Mysql的方式效率对比分析

SpringBoot中六种批量更新Mysql的方式效率对比分析

《SpringBoot中六种批量更新Mysql的方式效率对比分析》文章比较了MySQL大数据量批量更新的多种方法,指出REPLACEINTO和ONDUPLICATEKEY效率最高但存在数据风险,MyB... 目录效率比较测试结构数据库初始化测试数据批量修改方案第一种 for第二种 case when第三种
阅读更多...
python生成随机唯一id的几种实现方法

python生成随机唯一id的几种实现方法

《python生成随机唯一id的几种实现方法》在Python中生成随机唯一ID有多种方法,根据不同的需求场景可以选择最适合的方案,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习... 目录方法 1：使用 UUID 模块（推荐）方法 2：使用 Secrets 模块（安全敏感场景）方法
阅读更多...
Java docx4j高效处理Word文档的实战指南

Java docx4j高效处理Word文档的实战指南

《Javadocx4j高效处理Word文档的实战指南》对于需要在Java应用程序中生成、修改或处理Word文档的开发者来说,docx4j是一个强大而专业的选择,下面我们就来看看docx4j的具体使用... 目录引言一、环境准备与基础配置1.1 Maven依赖配置1.2 初始化测试类二、增强版文档操作示例2.
阅读更多...
一文详解如何使用Java获取PDF页面信息

一文详解如何使用Java获取PDF页面信息

《一文详解如何使用Java获取PDF页面信息》了解PDF页面属性是我们在处理文档、内容提取、打印设置或页面重组等任务时不可或缺的一环,下面我们就来看看如何使用Java语言获取这些信息吧... 目录引言一、安装和引入PDF处理库引入依赖二、获取 PDF 页数三、获取页面尺寸（宽高）四、获取页面旋转角度五、判断
阅读更多...
Spring Boot中的路径变量示例详解

Spring Boot中的路径变量示例详解

《SpringBoot中的路径变量示例详解》SpringBoot中PathVariable通过@PathVariable注解实现URL参数与方法参数绑定,支持多参数接收、类型转换、可选参数、默认值及... 目录一. 基本用法与参数映射1.路径定义2.参数绑定&nhttp://www.chinasem.cnbs
阅读更多...
MySQL 迁移至 Doris 最佳实践方案(最新整理)

MySQL 迁移至 Doris 最佳实践方案(最新整理)

《MySQL迁移至Doris最佳实践方案(最新整理)》本文将深入剖析三种经过实践验证的MySQL迁移至Doris的最佳方案,涵盖全量迁移、增量同步、混合迁移以及基于CDC(ChangeData... 目录一、China编程JDBC Catalog 联邦查询方案（适合跨库实时查询）1. 方案概述2. 环境要求3.
阅读更多...
JAVA中安装多个JDK的方法

JAVA中安装多个JDK的方法

《JAVA中安装多个JDK的方法》文章介绍了在Windows系统上安装多个JDK版本的方法,包括下载、安装路径修改、环境变量配置（JAVA_HOME和Path）,并说明如何通过调整JAVA_HOME在... 首先去oracle官网下载好两个版本不同的jdk（需要登录Oracle账号，没有可以免费注册）下载完
阅读更多...
Spring StateMachine实现状态机使用示例详解

Spring StateMachine实现状态机使用示例详解

《SpringStateMachine实现状态机使用示例详解》本文介绍SpringStateMachine实现状态机的步骤,包括依赖导入、枚举定义、状态转移规则配置、上下文管理及服务调用示例,重点解... 目录什么是状态机使用示例什么是状态机状态机是计算机科学中的​​核心建模工具​​，用于描述对象在其生命
阅读更多...
Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

《SpringBoot结合WxJava实现文章上传微信公众号草稿箱与群发》本文将详细介绍如何使用SpringBoot框架结合WxJava开发工具包,实现文章上传到微信公众号草稿箱以及群发功能,... 目录一、项目环境准备1.1 开发环境1.2 微信公众号准备二、Spring Boot 项目搭建2.1 创建
阅读更多...
Java中Integer128陷阱

Java中Integer128陷阱

《Java中Integer128陷阱》本文主要介绍了Java中Integer与int的区别及装箱拆箱机制,重点指出-128至127范围内的Integer值会复用缓存对象,导致==比较结果为true,下... 目录一、Integer和int的联系1.1 Integer和int的区别1.2 Integer和in
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2