基于MySQL和Redis扣减库存的实践
怎么入门数据库编程?需要学习哪些知识点?这是新手们刚接触编程时常见的问题;下面golang学习网就来给大家整理分享一些知识点,希望能够给初学者一些帮助。本篇文章就来介绍《基于MySQL和Redis扣减库存的实践》,涉及到mysqlredis、扣减库存,有需要的可以收藏一下
背景
在很多情况下,扣减库存是一个十分常见的需求,例如:学生选课系统中课程数量的扣减,抽奖系统中活动次数的扣减,电商系统中商品库存的扣减等,都涉及到数量的扣减,这些系统在成功扣减的前提下,绝对不能出现库存扣减多了的情况,也就是不能出现超卖。同时,我们也要注重系统性能的提升,这篇文章从这两个角度进行分析和讨论。
环境搭建
后台系统
基于 SpringBoot 搭建后台系统,JDK 为 1.8
<properties><java.version>1.8</java.version><project.build.sourceencoding>UTF-8</project.build.sourceencoding><project.reporting.outputencoding>UTF-8</project.reporting.outputencoding><spring-boot.version>2.3.12.RELEASE</spring-boot.version></properties><dependencies><dependency><groupid>org.springframework.boot</groupid><artifactid>spring-boot-starter-data-redis</artifactid></dependency><dependency><groupid>org.springframework.boot</groupid><artifactid>spring-boot-starter-web</artifactid></dependency><dependency><groupid>mysql</groupid><artifactid>mysql-connector-java</artifactid></dependency><dependency><groupid>org.projectlombok</groupid><artifactid>lombok</artifactid><optional>true</optional></dependency><dependency><groupid>com.baomidou</groupid><artifactid>mybatis-plus-boot-starter</artifactid><version>3.5.2</version></dependency></dependencies>
中间件
中间件使用 MySQL + Redis 进行数据的存储,使用 Mybatis 作为 ORM 框架
create database t_desc collate utf8mb4_general_ci; use t_desc; create table t_good ( id bigint auto_increment primary key comment '自增id', good_name varchar(255) not null comment '商品名称', stock int not null comment '商品库存' ) comment '库存测试表'; insert into t_good(good_name, stock) value('iphone', 50);
创建一张商品库存表,里面含有商品 id、商品名称 和库存 3 个字段,所有扣减库存的操作都在这张表上进行;
测试工具
使用 JMeter 5.5 进行测试
以下的库存数量统一设置为 50 个,线程组的数量为 10 个,循环 10 次,共 100 个扣减请求,最终正确的结果应该是扣减完毕后库存的数量应该为 0, 而不是 -50
扣减模式
基于数据库行锁 + CAS 实现库存的扣减
行锁
若直接直接在数据库层面进行库存的直接扣减,100 个线程同时进行请求,肯定会造成库存的超卖
SQL 语句为
<update id="descGoodStock"> update t_desc.t_good set t_good.stock = t_good.stock - 1 where id = #{id} </update>
考虑到 update 语句,若根据主键索引作为条件进行更新,会对数据库的某一行加上行锁(数据库开启事务自动提交),所以我们加上 stock > 0
的判断条件
<update id="descGoodStockByLock"> update t_desc.t_good set t_good.stock = t_good.stock - 1 where id = #{id} and t_good.stock > 0 </update>
开启 JMeter 进行测试,可见没有超卖
CAS
CAS 即 Compare and Set,先把旧的库存查出来,再把旧的库存作为 update 的条件之一,若数据库中的库存与旧的库存一致,则进行更新,否则不进行更新。
其实本质上与行锁的方式没什么区别,而且多了一次查询,写这个方法只是为了记录而已
若有两个以上的线程先查询到了商品的旧库存,这种方法可能会出现扣不完的情况
Java 代码:
@PostMapping("/db") public Map<string object> goodDescControllerByDataBase(Long id) { HashMap<string object> ret = new HashMap(); // 查出旧的值 Good good = goodMapper.selectStockById(id); // 再进行更新 int i = goodMapper.descGoodStockCAS(id, good.getStock()); if (i > 1) { ret.put("info", "success, 扣减成功"); } else { ret.put("info", "fail, 扣减失败"); } return ret; }</string></string>
SQL 语句
<update id="descGoodStockCAS"> update t_desc.t_good set t_good.stock = t_good.stock - 1 where id = #{id} and t_good.stock = #{stock} and t_good.stock > 0 </update>
测试结果:
综上,基于数据库的两种扣减库存的方式都没有实现超卖,但是毕竟是数据库,数据存储于物理磁盘中,性能方面就有待考量;
基于 Redis 实现库存的扣减
基本思想是:我们把库存的数量提前放到 Redis 上,直接在 Redis 进行库存的扣减
- 先查询 redis 中的库存
- 若小于 0 直接返回
- 若大于 0 则进行 Redis 和 数据库 中的库存扣减
不过这里存在 并发 问题,考虑极限情况,两个线程同时获得 stock = 1,然后再去进行库存扣减,势必会造成超卖的现象
下面给出两种解决办法
使用 decrement 方法
redisTemplate.opsForValue().decrement()
:对某个 key 进行减 1 操作,会返回扣减后的值
若该值大于等于 0 才进行数据库的库存的扣减,否则直接返回库存不足的提示
这种方法是基于 Redis 的指令是原子性的
Java 代码:
@PostMapping("/redis") public Map<string object> goodDescControllerByRedis(Long id) throws InterruptedException { HashMap<string object> ret = new HashMap(); ret.put("info", "fail, 扣减失败"); // 查询 Redis 中的库存 Integer stock = (Integer) redisTemplate.opsForValue().get(key + id); Thread.sleep(100); if (stock = 0) { // 扣减数据库库存 goodMapper.descGoodStock(id); ret.put("info", "success, 扣减成功"); } return ret; }</string></string>
其实 decrement
方法是原子性的,可以不用对库存先进行查询的操作,只需要判断扣减后的数是否大于 0 即可。但是如果并发量高的话,建议还是加上判断的逻辑,可以提高 Redis 的性能,不用每次进行 decrement
操作;
缺点:这种办法会导致 Redis 中库存产生超卖现象,若对 Redis 中库存数量要求准确,就不要使用这种方法;
测试结果:
Redis 中的库存产生超卖现象:
MySQL 中的库存没有超卖:
使用 LUA 脚本
上述问题的关键是:查询 和 扣减 是两个分开操作,不是一条原子性的命令。我们可以使用 LUA 脚本,把这两条命令封装到 LUA 代码中,实现这两个操作的原子性
LUA 代码
--- --- Generated by EmmyLua(https://github.com/EmmyLua) --- Created by Ezreal. --- DateTime: 2023/5/6 21:56 --- if (redis.call('exists', KEYS[1]) == 1) then local stock = tonumber(redis.call('get', KEYS[1])); if (stock 0) then redis.call('incrby', KEYS[1], -1); return 1; end end return -1
先获取值,然后判断库存数量,若没有小于等于 0 就先进行扣减即可
Java 代码
private static final DefaultRedisScript<long> DECREASE_GOOD_STOCK_SCRIPT = new DefaultRedisScript(); static { DECREASE_GOOD_STOCK_SCRIPT.setLocation(new ClassPathResource("/lua/desc_stock.lua")); // 设置返回值类型 DECREASE_GOOD_STOCK_SCRIPT.setResultType(Long.class); } @PostMapping("/lua") public Map<string object> goodDescControllerByLUA(Long id) { List<string> keys = new ArrayList(); keys.add("stock:" + id); HashMap<string object> ret = new HashMap(); ret.put("info", "fail, 扣减失败"); Long execute = redisTemplate.execute(DECREASE_GOOD_STOCK_SCRIPT, keys); if (execute == 1) { goodMapper.descGoodStock(id); ret.put("info", "success, 扣减成功"); } return ret; }</string></string></string></long>
结果:Redis 和 MySQL 中的库存均为 0 ,没有超卖
使用分布式锁
可以使用 redisson 分布式锁进行扣减库存处理,锁住查询和扣减两个步骤即可;
若是在分布式环境下,要考虑 分布式锁 与 LUA 脚本的结合!
java 代码
@PostMapping("/lock") public Map<string object> goodDescControllerByLock(Long id) throws InterruptedException { HashMap<string object> ret = new HashMap(); ret.put("info", "fail, 扣减失败"); // 加锁 RLock lock = redissonClient.getLock("stock" + id); boolean tryLock = lock.tryLock(2L, 1L, TimeUnit.SECONDS); if (tryLock) { Integer stock = (Integer) redisTemplate.opsForValue().get(key + id); if (stock = 0) { goodMapper.descGoodStock(id); ret.put("info", "success, 扣减成功"); } } return ret; }</string></string>
测试结果:
Redis 中库存数量没有超卖
MySQL 中库存数量没有超卖
总结
如果在项目初期流量较少可以考虑基于 数据库行锁 进行库存的扣减,到了后期流量大,几乎都要用到 Redis:
- decrement:追求简单快速实现,不考虑 Redis 库存中的准确性;
- LUA 脚本:追求 Redis 中库存的准确性,在 Redis 层面上要进行多重的条件判断
- Lock:追求 Redis 中库存的准确性,在分布式环境中要考虑 LUA + Lock 的结合
文中关于mysql的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《基于MySQL和Redis扣减库存的实践》文章吧,也可关注golang学习网公众号了解相关技术文章。

- 上一篇
- MySQL索引查询的具体使用

- 下一篇
- MySQL获取binlog的开始时间和结束时间(最新方法)
-
- 数据库 · MySQL | 1小时前 |
- MySQL排序优化与性能提升技巧
- 368浏览 收藏
-
- 数据库 · MySQL | 15小时前 |
- MySQL连接池配置与优化方法
- 297浏览 收藏
-
- 数据库 · MySQL | 16小时前 |
- MySQLGROUPBY使用技巧与常见问题
- 306浏览 收藏
-
- 数据库 · MySQL | 18小时前 |
- MySQL缓存优化技巧分享
- 392浏览 收藏
-
- 数据库 · MySQL | 19小时前 |
- MySQL安装到D盘教程及路径设置详解
- 279浏览 收藏
-
- 数据库 · MySQL | 21小时前 |
- MySQL缓存设置及查询作用解析
- 470浏览 收藏
-
- 数据库 · MySQL | 1天前 |
- MySQLcount优化技巧及性能提升方法
- 371浏览 收藏
-
- 数据库 · MySQL | 1天前 |
- MySQLUPDATE替换字段值方法详解
- 292浏览 收藏
-
- 数据库 · MySQL | 1天前 |
- MySQL基础:增删改查全教程
- 356浏览 收藏
-
- 数据库 · MySQL | 1天前 |
- MySQL建表语法详解与实例教程
- 498浏览 收藏
-
- 数据库 · MySQL | 1天前 |
- MySQL中文界面设置方法详解
- 356浏览 收藏
-
- 数据库 · MySQL | 1天前 |
- MySQL安装后如何启动和连接
- 233浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 511次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 498次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 484次学习
-
- 千音漫语
- 千音漫语,北京熠声科技倾力打造的智能声音创作助手,提供AI配音、音视频翻译、语音识别、声音克隆等强大功能,助力有声书制作、视频创作、教育培训等领域,官网:https://qianyin123.com
- 94次使用
-
- MiniWork
- MiniWork是一款智能高效的AI工具平台,专为提升工作与学习效率而设计。整合文本处理、图像生成、营销策划及运营管理等多元AI工具,提供精准智能解决方案,让复杂工作简单高效。
- 89次使用
-
- NoCode
- NoCode (nocode.cn)是领先的无代码开发平台,通过拖放、AI对话等简单操作,助您快速创建各类应用、网站与管理系统。无需编程知识,轻松实现个人生活、商业经营、企业管理多场景需求,大幅降低开发门槛,高效低成本。
- 104次使用
-
- 达医智影
- 达医智影,阿里巴巴达摩院医疗AI创新力作。全球率先利用平扫CT实现“一扫多筛”,仅一次CT扫描即可高效识别多种癌症、急症及慢病,为疾病早期发现提供智能、精准的AI影像早筛解决方案。
- 98次使用
-
- 智慧芽Eureka
- 智慧芽Eureka,专为技术创新打造的AI Agent平台。深度理解专利、研发、生物医药、材料、科创等复杂场景,通过专家级AI Agent精准执行任务,智能化工作流解放70%生产力,让您专注核心创新。
- 95次使用
-
- MySQL+Redis缓存+Gearman共同构建数据库缓存的方法
- 2023-01-21 495浏览
-
- 浅谈MySQL与redis缓存的同步方案
- 2022-12-30 491浏览
-
- 从MySQL到Redis的简单数据库迁移方法
- 2023-01-07 481浏览