社区精选|秒杀系统常见问题—库存超卖
共 9375字,需浏览 19分钟
·
2023-11-12 14:43
今天小编为大家带来的是社区作者 sum墨 的文章,让我们一起来学习秒杀系统常见问题—库存超卖。
先看问题
public String buy(Long goodsId, Integer goodsNum) {
//查询商品库存
Goods goods = goodsMapper.selectById(goodsId);
//如果当前库存为0,提示商品已经卖光了
if (goods.getGoodsInventory() <= 0) {
return "商品已经卖光了!";
}
//如果当前购买数量大于库存,提示库存不足
if (goodsNum > goods.getGoodsInventory()) {
return "库存不足!";
}
//更新库存
goods.setGoodsInventory(goods.getGoodsInventory() - goodsNum);
goodsMapper.updateById(goods);
return "购买成功!";
}
从图上看,逻辑还是很清晰明了的,而且单测的话,也测试不出来什么 bug 。但是在秒杀场景下,问题可就大发了,100 件商品可能卖出 1000 单,出现超卖问题,这下就真的需要杀个程序员祭天了。
问题分析
不同的时刻不同的请求,每次拿到的商品库存都是更新过之后的,逻辑是ok的。
秒杀场景的特点如下:
-
高并发处理:秒杀场景下,可能会有大量的购物者同时涌入系统,因此需要具备高并发处理能力,保证系统能够承受高并发访问,并提供快速的响应。 -
快速响应:秒杀场景下,由于时间限制和竞争激烈,需要系统能够快速响应购物者的请求,否则可能会导致购买失败,影响购物者的购物体验。 -
分布式系统:秒杀场景下,单台服务器扛不住请求高峰,分布式系统可以提高系统的容错能力和抗压能力,非常适合秒杀场景。
如果在同一时刻查询商品库存表,那么得到的商品库存也肯定是相同的,判断的逻辑也是相同的。
举个例子,现在商品的库存是 10 件,请求 1 买 6 件,请求 2 买 5 件,由于两次请求查询到的库存都是 10 ,肯定是可以卖的。
但是真实情况是 5+6=11>10 ,明显有问题好吧!这两笔请求必然有一笔失败才是对的!
那么,这种问题怎么解决呢?
问题解决
CREATE TABLE `t_goods` (
`id` bigint NOT NULL COMMENT '物理主键',
`goods_name` varchar(64) DEFAULT NULL COMMENT '商品名称',
`goods_pic` varchar(255) DEFAULT NULL COMMENT '商品图片',
`goods_desc` varchar(255) DEFAULT NULL COMMENT '商品描述信息',
`goods_inventory` int DEFAULT NULL COMMENT '商品库存',
`goods_price` decimal(10,2) DEFAULT NULL COMMENT '商品价格',
`create_time` datetime DEFAULT NULL COMMENT '创建时间',
`update_time` datetime DEFAULT NULL COMMENT '更新时间',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
方法一、 redis 分布式锁
Redisson 介绍
官方介绍:Redisson 是一个基于 Redis的 Java 驻留内存数据网格(In-Memory Data Grid)。它封装了 Redis 客户端 API ,并提供了一个分布式锁、分布式集合、分布式对象、分布式 Map 等常用的数据结构和服务。Redisson 支持 Java 6 以上版本和 Redis 2.6 以上版本,并且采用编解码器和序列化器来支持任何对象类型。Redisson 还提供了一些高级功能,比如异步 API 和响应式流式 API 。它可以在分布式系统中被用来实现高可用性、高性能、高可扩展性的数据处理。
Redisson 使用
引入
<!--使用redisson作为分布式锁-->
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.16.8</version>
</dependency>
注入对象
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RedissonConfig {
/**
* 所有对Redisson的使用都是通过RedissonClient对象
*
* @return
*/
@Bean(destroyMethod = "shutdown")
public RedissonClient redissonClient() {
// 创建配置 指定redis地址及节点信息
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379").setPassword("123456");
// 根据config创建出RedissonClient实例
RedissonClient redissonClient = Redisson.create(config);
return redissonClient;
}
}
代码优化
public String buyRedisLock(Long goodsId, Integer goodsNum) {
RLock lock = redissonClient.getLock("goods_buy");
try {
//加分布式锁
lock.lock();
//查询商品库存
Goods goods = goodsMapper.selectById(goodsId);
//如果当前库存为0,提示商品已经卖光了
if (goods.getGoodsInventory() <= 0) {
return "商品已经卖光了!";
}
//如果当前购买数量大于库存,提示库存不足
if (goodsNum > goods.getGoodsInventory()) {
return "库存不足!";
}
//更新库存
goods.setGoodsInventory(goods.getGoodsInventory() - goodsNum);
goodsMapper.updateById(goods);
return "购买成功!";
} catch (Exception e) {
log.error("秒杀失败");
} finally {
lock.unlock();
}
return "购买失败";
}
方法二、MySQL的行锁
行锁介绍
MySQL 的行锁是一种针对行级别数据的锁,它可以锁定某个表中的某一行数据,以保证在锁定期间,其他事务无法修改该行数据,从而保证数据的一致性和完整性。
特点如下:
MySQL 的行锁只能在 InnoDB 存储引擎中使用。
行锁需要有索引才能实现,否则会自动锁定整张表。
可以通过使用“ SELECT ... FOR UPDATE”和“SELECT ... LOCK IN SHARE MODE ”语句来显式地使用行锁。
//查询商品库存
Goods goods = goodsMapper.selectById(goodsId);
原始查询SQL
SELECT *
FROM t_goods
WHERE id = #{goodsId}
改写为
SELECT *
FROM t_goods
WHERE id = #{goodsId} for update
方法三、乐观锁
商品表增加 version 字段并初始化数据为 0
`version` int(11) DEFAULT NULL COMMENT '版本'
将更新 SQL 修改如下
update t_goods
set goods_inventory = goods_inventory - #{goodsNum},
version = version + 1
where id = #{goodsId}
and version = #{version}
Java 代码修改如下
public String buyVersion(Long goodsId, Integer goodsNum) {
//查询商品库存(该语句使用了行锁)
Goods goods = goodsMapper.selectById(goodsId);
//如果当前库存为0,提示商品已经卖光了
if (goods.getGoodsInventory() <= 0) {
return "商品已经卖光了!";
}
if (goodsMapper.updateInventoryAndVersion(goodsId, goodsNum, goods.getVersion()) > 0) {
return "购买成功!";
}
return "库存不足!";
}
通过增加了版本号的控制,在扣减库存的时候在 where 条件进行版本号的比对。实现查询的是哪一条记录,那么就要求更新的是哪一条记录,在查询到更新的过程中版本号不能变动,否则更新失败。
方法四、 where 条件和 unsigned 非负字段限制
前面的两种办法是通过每次都拿到最新的库存
从而解决超卖问题,那换一种思路:保证在扣除库存的时候,库存一定大于购买量
是不是也可以解决这个问题呢?
答案是可以的。回到上面的代码:
//更新库存
goods.setGoodsInventory(goods.getGoodsInventory() - goodsNum);
goodsMapper.updateById(goods);
update t_goods
set goods_inventory = goods_inventory - #{goodsNum}
where id = #{goodsId}
update t_goods
set goods_inventory = goods_inventory - #{goodsNum}
where id = #{goodsId}
AND (goods_inventory - #{goodsNum}) >= 0
public String buySqlUpdate(Long goodsId, Integer goodsNum) {
//查询商品库存(该语句使用了行锁)
Goods goods = goodsMapper.queryById(goodsId);
//如果当前库存为0,提示商品已经卖光了
if (goods.getGoodsInventory() <= 0) {
return "商品已经卖光了!";
}
//此处需要判断更新操作是否成功
if (goodsMapper.updateInventory(goodsId, goodsNum) > 0) {
return "购买成功!";
}
return "库存不足!";
}
总结一下
解决方案 | 优点 | 缺点 |
---|---|---|
redis 分布式锁 |
Redis 分布式锁可以解决分布式场景下的锁问题,保证多个节点对同一资源的访问顺序和安全性,性能较高。 |
|
|
|
|
|
|
|
|
|
|
全文至此结束,再会!
点击左下角阅读原文,到 SegmentFault 思否社区 和文章作者展开更多互动和交流,“公众号后台“回复“ 入群 ”即可加入我们的技术交流群,收获更多的技术文章~
- END -
往期推荐
社区精选|面试官:你先实现个 CountDown 计时器组件吧!
社区精选|Vue 组件懒加载
社区精选|浅析微前端沙箱