秒杀项目 超卖问题 详解
秒杀项目中的超卖问题详解
秒杀场景是一种高并发场景,用户在短时间内大量涌入抢购有限的商品。超卖问题指的是由于系统设计不合理,导致实际售出的商品数量超过库存数量。
1. 为什么会出现超卖问题?
超卖问题通常由以下原因引发:
1.1 数据库操作的非原子性
- 在高并发情况下,多个用户同时读取库存数据,并进行库存更新操作时,可能出现竞争条件,导致超卖。
- 示例:
- 用户A和用户B同时读取库存(10件),两者都认为可以购买,分别减库存后库存变成-1。
1.2 缓存和数据库的不一致
- 使用缓存加速库存读取,但高并发场景下,缓存未及时同步到数据库,可能导致库存更新延迟,从而产生超卖。
1.3 分布式系统中的并发问题
- 多个服务节点同时处理秒杀请求,但未对库存操作进行全局控制,导致并发超卖。
1.4 数据库事务隔离级别不足
- 如果数据库的事务隔离级别未正确配置,可能导致“脏读”或“幻读”,从而出现库存超卖。
2. 解决超卖问题的方案
2.1 数据库层面的优化
2.1.1 乐观锁
- 利用数据库表的版本号(
version字段)来控制并发更新。 - 实现方式:
- 更新库存时检查版本号:
UPDATE product SET stock = stock - 1, version = version + 1 WHERE id = ? AND version = ?; - 如果
version不匹配,说明库存已被其他请求更新,当前操作失败,需重新尝试。
- 更新库存时检查版本号:
- 优点:
- 性能较高,适合高并发场景。
- 缺点:
- 重试次数多时性能会下降。
2.1.2 悲观锁
- 使用数据库的锁机制,在操作库存时对行数据加锁,其他事务需等待当前事务完成后才能操作。
- 实现方式:
- 使用
SELECT ... FOR UPDATE语句锁定库存行:SELECT stock FROM product WHERE id = ? FOR UPDATE; - 更新库存:
UPDATE product SET stock = stock - 1 WHERE id = ?;
- 使用
- 优点:
- 数据一致性强。
- 缺点:
- 性能较差,不适合高并发场景。
2.1.3 事务隔离级别
- 配置数据库的事务隔离级别为
SERIALIZABLE,防止幻读和脏读。 - 优点:
- 保证强一致性。
- 缺点:
- 并发性能下降严重,不推荐用于高并发秒杀场景。
2.2 缓存层面的优化
2.2.1 预减库存
- 在请求到达后,直接在缓存中预减库存,后续再异步同步到数据库。
- 实现方式:
- 用户请求时先检查缓存中的库存,减库存后再写入消息队列或直接更新数据库。
- 示例(Redis 执行 Lua 脚本):
if redis.call("get", KEYS[1]) > 0 thenreturn redis.call("decr", KEYS[1]) elsereturn -1 end
- 优点:
- 减少数据库访问,性能高。
- 缺点:
- 缓存与数据库之间可能存在数据不一致问题。
2.2.2 热点数据分片
- 将秒杀的热点数据分片到多个缓存节点上,降低单节点的压力。
- 示例:
- 将库存按商品 ID 分片存储在不同的 Redis 节点。
2.3 应用层的并发控制
2.3.1 分布式锁
- 使用分布式锁(如 Redis 的
SETNX)确保同一时间只有一个线程能操作库存。 - 实现方式:
- 用户请求时获取锁:
SET lock_key value NX EX 30 - 释放锁时验证锁归属权,避免误删:
if redis.call("get", KEYS[1]) == ARGV[1] thenreturn redis.call("del", KEYS[1]) elsereturn 0 end
- 用户请求时获取锁:
- 优点:
- 保证数据一致性。
- 缺点:
- 高并发时分布式锁的性能可能成为瓶颈。
2.3.2 队列削峰
- 使用消息队列对秒杀请求进行排队,削减高并发压力。
- 实现方式:
- 用户请求被写入消息队列(如 Kafka、RabbitMQ)。
- 后端服务按顺序消费队列中的请求,依次处理库存更新。
- 优点:
- 降低数据库和缓存的直接压力。
- 缺点:
- 用户需要等待请求排队,延迟增加。
2.4 限流与降级
2.4.1 接口限流
- 限制单位时间内的请求数量,防止瞬时流量涌入系统。
- 实现方式:
- 使用令牌桶算法或漏桶算法:
RateLimiter rateLimiter = RateLimiter.create(1000); // 每秒允许1000个请求 if (rateLimiter.tryAcquire()) {// 处理秒杀请求 } else {// 拒绝请求 }
- 使用令牌桶算法或漏桶算法:
2.4.2 服务降级
- 当秒杀流量超出系统处理能力时,返回“秒杀失败”提示或静态页面,保护系统。
- 示例:
- 配置熔断器(如 Hystrix)来自动降级。
2.5 秒杀整体架构优化
-
前端拦截:
- 在前端对用户的秒杀请求频率进行限制。
- 采用验证码防止恶意刷单。
-
动态库存划分:
- 秒杀开始前,将库存按比例划分到多个节点或分区中,降低竞争。
-
异步通知:
- 用户下单后,系统通过异步方式通知秒杀结果,减轻实时响应压力。
-
冷启动优化:
- 提前将秒杀商品的库存加载到缓存中,减少数据库请求。
3. 解决方案的对比
| 方案 | 优点 | 缺点 | 适用场景 |
|---|---|---|---|
| 乐观锁 | 性能较高,适合高并发 | 重试次数过多可能降低性能 | 数据库为主的秒杀系统 |
| 悲观锁 | 数据一致性好 | 性能较差,容易锁等待 | 低并发秒杀或事务性操作 |
| 缓存预减库存 | 性能高,降低数据库压力 | 缓存与数据库可能不一致 | 高并发秒杀场景 |
| 分布式锁 | 保证一致性 | 性能可能成为瓶颈 | 小规模高并发场景 |
| 消息队列(队列削峰) | 防止数据库和缓存被瞬时流量打垮 | 增加请求延迟 | 超高并发秒杀场景 |
| 限流与降级 | 简单易用,保护系统 | 用户体验下降 | 流量异常高峰时 |
4. 实践案例
秒杀实现步骤
- 初始化库存:
- 提前将秒杀商品库存加载到 Redis。
- 用户抢购:
- 用户请求先检查 Redis 中的库存,并通过 Lua 脚本原子性减库存。
- 异步下单:
- 秒杀成功的用户请求写入消息队列,后续异步处理订单。
- 同步数据库:
- 消费消息队列,完成订单创建和数据库库存扣减。
示例架构
- 前端:Nginx 限流 + 验证码。
- 中间层:Redis + Lua 脚本预减库存。
- 后端:Kafka 消息队列削峰。
- 数据存储:MySQL 乐观锁更新库存。
5. 总结
秒杀项目中的超卖问题需要从多个层次进行优化,包括数据库、缓存、应用层和架构设计:
- 数据库层:采用乐观锁或悲观锁保证事务一致性。
- 缓存层:使用 Redis 预减库存,减少数据库压力。
- 应用层:通过分布式锁、限流、降级等手段控制并发。
- 架构层:引入消息队列削峰,提高系统的吞吐能力。
合理的设计可以在保证数据一致性的前提下,实现高并发场景下的稳定秒杀体验。
相关文章:
秒杀项目 超卖问题 详解
秒杀项目中的超卖问题详解 秒杀场景是一种高并发场景,用户在短时间内大量涌入抢购有限的商品。超卖问题指的是由于系统设计不合理,导致实际售出的商品数量超过库存数量。 1. 为什么会出现超卖问题? 超卖问题通常由以下原因引发:…...
Linux系统编程之进程控制
概述 在Linux系统中,创建一个新的进程后,如何对该进程进行有效的控制,是一项非常重要的操作。控制进程状态的操作主要包括:进程的执行、进程的等待、进程的终止等。下面,我们将逐个进行介绍。 进程的执行 创建进程后&a…...
集合的相关性质与定义
集合 集合 集合描述了一组对象的集合,而映射描述了集合之间的对应关系。 集合 集合是由一组无序的,互不相同的对象组成的整体,集合中的对象称为元素或成员。集合可以用大括号{}表示,元素之间用逗号进行分隔。 定义: 集合 A …...
pytest自定义命令行参数
实际使用场景:pytest运行用例的时候,启动mitmdump进程试试抓包,pytest命令行启动的时候,传入mitmdump需要的参数(1)抓包生成的文件地址 (2)mitm的proxy设置 # 在pytest的固定文件中…...
c++预编译头文件
文章目录 c预编译头文件1.使用g编译预编译头文件2.使用visual studio进行预编译头文件2.1visual studio如何设置输出预处理文件(.i文件)2.2visual studio 如何设置预编译(初始创建空项目的情况下)2.3 visual studio打开输出编译时…...
YOLOv8模型pytorch格式转为onnx格式
一、YOLOv8的Pytorch网络结构 model DetectionModel((model): Sequential((0): Conv((conv): Conv2d(3, 64, kernel_size(3, 3), stride(2, 2), padding(1, 1))(act): SiLU(inplaceTrue))(1): Conv((conv): Conv2d(64, 128, kernel_size(3, 3), stride(2, 2), padding(1, 1))(a…...
电子课程开发中的典型误区
创建一个有效的电子课程需要仔细的规划和执行,但常见的错误可能会破坏其成功。以下是开发人员应该避免的一些典型陷阱: 1.缺乏明确的目标 如果没有明确的学习目标,课程可能会缺乏重点,让学习者不确定自己应该实现什么。明确、可衡…...
Docker 逃逸突破边界
免责声明 本博客文章仅供教育和研究目的使用。本文中提到的所有信息和技术均基于公开来源和合法获取的知识。本文不鼓励或支持任何非法活动,包括但不限于未经授权访问计算机系统、网络或数据。 作者对于读者使用本文中的信息所导致的任何直接或间接后果不承担任何…...
残差连接,就是当某一偏导等于0时,加上x偏导就是1,这样乘以1保证不失效
目录 残差连接,就是当某一偏导等于0时,加上x偏导就是1,这样乘以1保证不失效 残差连接中F(x)一般代表什么,将F(x)变为F(x) +x,这样不是改变了函数 本身的性质 F(x)=F(x) +x F(x)偏导若==0;偏导连乘就是0,这样就梯度消失了 F(x) +x;求偏导时x导数是1,保证不丢失F(x)…...
博泽Brose EDI项目案例
Brose 是一家德国的全球性汽车零部件供应商,主要为全球汽车制造商提供机电一体化系统和组件,涵盖车门、座椅调节系统、空调系统以及电动驱动装置等。Brose 以其高质量的创新产品闻名,在全球拥有多个研发和生产基地,是全球第五大家…...
从科举到高考,人才选拔制度的变革与发展
一、引言 在人类历史的长河中,人才选拔机制始终是推动社会进步与文明传承的关键环节。古代科举制度与现代高考制度,分别在各自的时代背景下承担着筛选人才的重任,二者虽皆关乎教育与人才进阶之路,却有着诸多本质性的区别与独特的…...
利用Docker一键发布Nginx-Tomcat-MySQL应用集群
Docker简介,可以看上一篇文章: 为什么互联网公司离不开Docker容器化,它到底解决了什么问题?-CSDN博客 Docker体系结构 docker核心就是镜像和容器: 镜像就是应用程序的安装文件,包含了所有需要的资源&…...
关于数据库数据国际化方案
方案一:每个表设计一个翻译表 数据库国际化的应用场景用到的比较少,主要用于对数据库的具体数据进行翻译,在需要有大量数据翻译的场景下使用,举个例子来说,力扣题目的中英文切换。参考方案可见: https://b…...
【系统架构设计师】高分论文:论信息系统的安全与保密设计
更多内容请见: 备考系统架构设计师-专栏介绍和目录 文章目录 摘要正文摘要 本人所在工作单位承担了我市城乡智慧建设工程综合管理平台项目的开发工作。我有幸参与了本项目,并担任架构师一职,全面负责项目的需求分析和系统设计等工作。城乡智慧建设工程综合管理平台项目包括…...
使用Tauri创建桌面应用
当前是在 Windows 环境下 1.准备 系统依赖项 Microsoft C 构建工具WebView2 (Windows10 v1803 以上版本不用下载,已经默认安装了) 下载安装 Rust下载安装 Rust 需要重启终端或者系统 重新打开cmd,键入rustc --version,出现 rust 版本号&…...
【docker】docker compose多容器部署
Docker Compose 的详细讲解与实际应用 什么是 Docker Compose? Docker Compose 是一个工具,用于定义和运行多容器 Docker 应用。 通过一个 docker-compose.yml 文件,可以同时启动多个服务,简化多容器管理。 Docker Compose 的核心…...
JS +CSS @keyframes fadeInUp 来定义载入动画
JSCSS 更完美展现 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>跳动加载指示器</title>&l…...
Seatunnel解决ftp读取json文件无法读取数组以及格式化之后的json无法解析的问题
问题原因 在JsonRead这个方法里面 在源码中使用的逻辑是读取一行 然后把这个json进行解析 但是这样存在一个问题 比如如果json的格式是这样的 { name:“zhangsan”, age:25 } 如果是这样的话 第一行读到的内容就是 { 显然 一个 { 并不是一个…...
Elasticsearch在liunx 中单机部署
下载配置 1、下载 官网下载地址 2、上传解压 tar -zxvf elasticsearch-XXX.tar.gz 3、新建组和用户 (elasticsearch 默认不允许root账户) #创建组 es groupadd es #新建用户 useradd ryzhang -g es 4、更改文件夹的用户权限 chown -R ryzhang …...
深入探索 HarmonyOS 的 Navigation 组件:灵活的页面管理与动态导航
在移动应用开发中,页面的跳转和导航一直是核心功能之一。对于 HarmonyOS 开发者来说,Navigation 组件提供了一个强大的工具来实现灵活的页面管理和导航体验。今天,我们将深入探讨如何使用 HarmonyOS 中的 Navigation 组件来管理页面跳转、工具…...
业务系统对接大模型的基础方案:架构设计与关键步骤
业务系统对接大模型:架构设计与关键步骤 在当今数字化转型的浪潮中,大语言模型(LLM)已成为企业提升业务效率和创新能力的关键技术之一。将大模型集成到业务系统中,不仅可以优化用户体验,还能为业务决策提供…...
java_网络服务相关_gateway_nacos_feign区别联系
1. spring-cloud-starter-gateway 作用:作为微服务架构的网关,统一入口,处理所有外部请求。 核心能力: 路由转发(基于路径、服务名等)过滤器(鉴权、限流、日志、Header 处理)支持负…...
Admin.Net中的消息通信SignalR解释
定义集线器接口 IOnlineUserHub public interface IOnlineUserHub {/// 在线用户列表Task OnlineUserList(OnlineUserList context);/// 强制下线Task ForceOffline(object context);/// 发布站内消息Task PublicNotice(SysNotice context);/// 接收消息Task ReceiveMessage(…...
安宝特方案丨XRSOP人员作业标准化管理平台:AR智慧点检验收套件
在选煤厂、化工厂、钢铁厂等过程生产型企业,其生产设备的运行效率和非计划停机对工业制造效益有较大影响。 随着企业自动化和智能化建设的推进,需提前预防假检、错检、漏检,推动智慧生产运维系统数据的流动和现场赋能应用。同时,…...
前端导出带有合并单元格的列表
// 导出async function exportExcel(fileName "共识调整.xlsx") {// 所有数据const exportData await getAllMainData();// 表头内容let fitstTitleList [];const secondTitleList [];allColumns.value.forEach(column > {if (!column.children) {fitstTitleL…...
最新SpringBoot+SpringCloud+Nacos微服务框架分享
文章目录 前言一、服务规划二、架构核心1.cloud的pom2.gateway的异常handler3.gateway的filter4、admin的pom5、admin的登录核心 三、code-helper分享总结 前言 最近有个活蛮赶的,根据Excel列的需求预估的工时直接打骨折,不要问我为什么,主要…...
什么是库存周转?如何用进销存系统提高库存周转率?
你可能听说过这样一句话: “利润不是赚出来的,是管出来的。” 尤其是在制造业、批发零售、电商这类“货堆成山”的行业,很多企业看着销售不错,账上却没钱、利润也不见了,一翻库存才发现: 一堆卖不动的旧货…...
新能源汽车智慧充电桩管理方案:新能源充电桩散热问题及消防安全监管方案
随着新能源汽车的快速普及,充电桩作为核心配套设施,其安全性与可靠性备受关注。然而,在高温、高负荷运行环境下,充电桩的散热问题与消防安全隐患日益凸显,成为制约行业发展的关键瓶颈。 如何通过智慧化管理手段优化散…...
Rust 异步编程
Rust 异步编程 引言 Rust 是一种系统编程语言,以其高性能、安全性以及零成本抽象而著称。在多核处理器成为主流的今天,异步编程成为了一种提高应用性能、优化资源利用的有效手段。本文将深入探讨 Rust 异步编程的核心概念、常用库以及最佳实践。 异步编程基础 什么是异步…...
现有的 Redis 分布式锁库(如 Redisson)提供了哪些便利?
现有的 Redis 分布式锁库(如 Redisson)相比于开发者自己基于 Redis 命令(如 SETNX, EXPIRE, DEL)手动实现分布式锁,提供了巨大的便利性和健壮性。主要体现在以下几个方面: 原子性保证 (Atomicity)ÿ…...
