Redis - 优惠卷秒杀

news2024/11/25 15:32:44

场景分析

为了避免对数据库造成压力,我们在新增优惠卷的时候,可以将优惠卷的信息储存在Redis中,这样用户抢购的时候访问优惠卷信息,通过Redis读取信息。
在这里插入图片描述
抢购流程
在这里插入图片描述

业务分析

既然在新增优惠卷的时候,我们只需要id和库存信息,那么这个时候我们需要说选择Redis中Stringt数据类型,以id作为键,此时我们在进行抢劵的时候,通过id可以直接查询到对应的库存信息,进行判断。
此时我们会面临一下场景:

  1. 出现超卖问题
  2. 不能保证一人一单

超卖问题

锁结构选型:

在这里插入图片描述
读多写少的场景:
选择乐观锁。因为读操作不会加锁,可以提高系统的并发性能。写操作通过版本号或条件更新来避免冲突。
写操作频繁且并发量高的场景
选择悲观锁。悲观锁通过加锁机制可以有效避免并发冲突,保证数据的一致性和正确性。
性能和一致性权衡:
在性能和一致性之间需要权衡。如果一致性要求非常高,且系统能够接受较低的并发性能,选择悲观锁。如果系统需要高性能,并且能够接受偶尔的冲突重试,选择乐观锁。
由于这个优惠卷抢票属于,读多写少这种场景,那么我们选型的话选择乐观锁会比较合适。

数据库乐观锁解决超卖问题
超卖问题分析

在这里插入图片描述
假设我们现在库存store = 1 ,那么此时线程一 判断之后 store > 0 那么这个时候线程一开始进行库存缩减,但是此时库存还没开始在数据库中扣减,此时线程二开始查询,发现 store > 0,那么线程二也认定自己抢票成功,开始扣减库存,那么此时就会出现store 减少了两次,那么库存就变成了-1,假设在线程二查询之后,线程一库存扣减之前,线程三又进行了判断,那么此时库存就又变成了-2。这是超卖问题的一个场景。
乐观锁,版本号法:
在这里插入图片描述
版本号法:也就是说引入一个新的字段用来检测当前我查询到的version,和我修改时的version是否是同一个,这样的话保证不会出现超卖问题,但是同样,会出现大量失败情况导致错误率极高。不推荐使用
CAS方案:
比较我查询到的库存值跟我更新后的库存值判断。但是这种情况也会出现上述的那种限制,所以我们只要判断扣减前的库存是否大于0即可,那么这种情况效率高,且不会出现大幅度失败。这个主要还是依靠mysql自身的行级锁机制进行的。属于悲观锁的一种范畴。
MySQL 中的行级锁可以确保同一行的数据在同一时间只能被一个事务修改,从而避免了并发更新导致的数据不一致问题。在代码中,当多个线程同时尝试更新同一行数据时,MySQL 会自动对该行数据加锁,以确保只有一个线程能够成功执行更新操作,其他线程会被阻塞直到锁释放。
这种方案解决较上一种方案会好一点,但依旧不是好的解决方案,因为对于这种场景下,阻塞依旧是不可避免的。

 boolean voucherId1 = iSeckillVoucherService.update()
         .setSql("stock = stock - 1")
         .eq("voucher_id", voucherId)
         .gt("stock", 0)
         .update();

一人一单问题

我们只需要用户下单之后,把用户订单信息,存入Redis中,只需要到时候读取这个信息判断有多少次下单即可。

// 这个位置采用优惠卷id 和 用户 id作为键,储存对应的信息,避免抢其他票时出现误判
String keyUserOrder = "user:order:" + voucherId + user.getId();
Integer count = 0;
try{
    count  = Integer.valueOf(stringRedisTemplate.opsForValue().get(keyUserOrder));
    if (count >= 1) {
        return Result.fail("用户已购买");
    }
}catch (Exception e){
    log.error("第一次抢票");
}
// 这个是抢票成功时,将订单信息保存。值自增用来判断是否是第一次购买
Long orderCount = stringRedisTemplate.opsForValue().increment(keyUserOrder, 1);
新的实现思路

既然是抢劵,那我确实无法避免这个内容。我可以说实现一个优惠卷池,将这个内容存入Redis中,抢到的话就生成订单,这样的话也没有超卖问题。只不过还得解决一人一单。效率较上面这种会更好一点。

实现步骤
  • 初始化优惠券池:将每张优惠券的信息预先存入Redis。
  • 抢券逻辑:用户请求时,从Redis中获取一张优惠券。
  • 生成订单:抢到优惠券后,生成订单并将订单信息和优惠券信息关联起来。
  • 一人一单检查:确保同一用户不能重复抢券。
代码示例

以下是一个简单的代码实现示例:
初始化优惠券池:

// 初始化优惠券池,将100张优惠券信息存入Redis
String voucherPoolKey = "voucher:pool";
for (int i = 1; i <= 100; i++) {
    // 假设优惠券信息是一个简单的字符串,这里可以是更复杂的对象
    stringRedisTemplate.opsForList().leftPush(voucherPoolKey, "voucher_" + i);
}

抢券逻辑

public Result grabVoucher(Long voucherId, Long userId) {
    // Redis中的键
    String voucherPoolKey = "voucher:pool";
    String userOrderKey = "user:order:" + voucherId + ":" + userId;

    // 检查用户是否已经抢过
    if (Boolean.TRUE.equals(stringRedisTemplate.hasKey(userOrderKey))) {
        return Result.fail("用户已购买");
    }

    // 从Redis中弹出一张优惠券
    String voucher = stringRedisTemplate.opsForList().rightPop(voucherPoolKey);
    if (voucher == null) {
        return Result.fail("优惠券已抢完");
    }

    // 抢券成功,生成订单
    // 这里假设订单生成成功,实际应用中需要加入订单生成逻辑
    String orderInfo = "order_for_" + voucher + "_by_user_" + userId;

    // 记录用户抢券信息
    stringRedisTemplate.opsForValue().set(userOrderKey, orderInfo);

    return Result.ok("抢券成功", orderInfo);
}

订单生成
实际的订单生成过程可能涉及复杂的业务逻辑和数据库操作,这里简化为成功后记录用户抢券信息。

一人一单的实现
在用户抢券前,检查用户是否已经抢过,通过Redis键的存在性判断。

// 检查用户是否已经抢过
if (Boolean.TRUE.equals(stringRedisTemplate.hasKey(userOrderKey))) {
    return Result.fail("用户已购买");
}
优点
  • 高效处理并发:Redis的高吞吐量和低延迟使得这种方案在高并发场景下表现出色。
  • 避免超卖:优惠券从Redis中弹出后即减少,确保不会超卖。
  • 简单实现一人一单:通过Redis键值对存储和检查用户抢券信息,轻松实现一人一单的限制。
  • 简化订单生成:在抢券成功后,立即生成订单并将信息存储在Redis中,减少了数据库操作的复杂性。

或者我感觉这个并发场景比较大的情况下,使用RabbitMQ削峰填谷,做限流也可以。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1694109.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

CS 下载安装详解

目录 CS简介&#xff1a; CS下载地址&#xff1a; CS的安装&#xff1a; CS简介&#xff1a; CS为目前渗透中常用的一款工具&#xff0c;它的强大在于控制windows木马&#xff0c;CS主要控制windows木马。 CS下载地址&#xff1a; 链接&#xff1a;https://pan.baidu.com/…

并发编程笔记7--并发编程基础

1、线程简介 1.1、什么是线程 现代操作系统中运行一个程序&#xff0c;会为他创建一个进程。而每一个进程中又可以创建许多个线程。现代操作系统中线程是最小的调度单元。 两者关系&#xff1a;一个线程只属于一个进程&#xff0c;而一个进程可以拥有多个线程。线程是一个轻量…

循环进阶-素数回文数的个数c++

题目描述 计算鸭请你帮忙求1到n之间&#xff08;包括 n&#xff09;&#xff0c;既是素数又是回文数的整数有多少个。 输入 一个大于1小于1000的整数n。 输出 1到n之间的素数回文数个数。 样例输入 23 样例输出 5 分析 这道题就是怎样判断素数和怎样判断回文数的结合…

clion读取文件设置为读取当前目录下的文件

1.问题 使用vs读取文件时一切正常 但是同样的代码在clion中无法正常执行 原因 原因&#xff1a;clion的源文件找不到input.txt文件的位置 需要设置工作目录&#xff0c;例如此时input.txt在当前目录下&#xff0c;那么就设置 设置当前文件的工作目录为$FileDir$即可&am…

Unity面试八股文之基础篇

文章目录 前言1. Unity的生命周期加载第一个场景Editor在第一次帧更新之前帧之间更新顺序协程销毁对象时退出时 2. Unity 协程和线程,进程的区别3. 本地坐标系 世界坐标系4. 碰撞器和触发器的区别后话 前言 开设这个栏目的博文会写一些有关unity的面试题目&#xff0c;在面试的…

清理mysql binglog文件

mysql随着使用时间的推移&#xff0c;binglog文件会越来越大&#xff0c;比如我们的oa系统&#xff0c;上线4年多了&#xff0c;最近总有磁盘空间满影响系统正常使用的情况出现。检查后发现binglog是罪归祸首。 binglog文件最好不要采用应删除的方式清理&#xff0c;如下方式可…

【数据结构与算法】之堆的应用——堆排序及Top_K问题!

目录 1、堆排序 2、Top_K问题 3、完结散花 个人主页&#xff1a;秋风起&#xff0c;再归来~ 数据结构与算法 个人格言&#xff1a;悟已往之不谏&#xff0c;知来者犹可追 克心守己&#xff0c;律己则安&#xff01; 1、堆排序 对一个无序的数组…

使用OpenCV dnn c++加载YOLOv8生成的onnx文件进行目标检测

在网上下载了60多幅包含西瓜和冬瓜的图像组成melon数据集&#xff0c;使用 LabelMe 工具进行标注&#xff0c;然后使用 labelme2yolov8 脚本将json文件转换成YOLOv8支持的.txt文件&#xff0c;并自动生成YOLOv8支持的目录结构&#xff0c;包括melon.yaml文件&#xff0c;其内容…

HACL-Net:基于MRI的胎盘植入谱诊断的分层注意力和对比学习网络

文章目录 HACL-Net: Hierarchical Attention and Contrastive Learning Network for MRI-Based Placenta Accreta Spectrum Diagnosis摘要方法实验结果 HACL-Net: Hierarchical Attention and Contrastive Learning Network for MRI-Based Placenta Accreta Spectrum Diagnosis…

世界上首位AI程序员诞生,AI将成为人类的对手吗?

3月13日&#xff0c;世界上第一位AI程序员Devin诞生&#xff0c;不仅能自主学习新技术&#xff0c;自己改Bug&#xff0c;甚至还能训练和微调自己的AI模型&#xff0c;表现已然远超GPT-4等“顶流选手”。 AI的学习速度如此之快&#xff0c;人类的教育能否跟上“机器学习”的速…

2、xss-labs之level2

1、打开页面 2、传入xss代码 payload&#xff1a;<script>alert(xss)</script>&#xff0c;发现返回<script>alert(xss)</script> 3、分析原因 打开f12&#xff0c;没什么发现 看后端源码&#xff0c;在这form表单通过get获取keyword的值赋给$str&am…

《拯救大学生课设不挂科第三期之Windows下安装Dev C++(VC 6.0上位替代)与跑通Hello World程序C/C++版教程》【官方笔记】

背景&#xff1a; 大学老师使用的VC6.0(VC 6.0)太老了&#xff0c;老师为什么用VC6.0&#xff0c;象漂亮认为是高校缺乏鲶鱼刺激。很大一部分高校已经与市场脱节&#xff0c;这也是为什么很多同学毕业后想要入行计算机基本都得自己重新回炉打造一次&#xff0c;这和高校的老旧…

OpenStack平台Keystone组件的使用

1. 规划节点 安装基础服务的服务器规划 IP地址 主机名 节点 192.168.100.10 controller Openstack控制节点 2. 基础准备 使用机电云共享的单节点的openstack系统&#xff0c;自行修改虚拟网络编辑器、网络适配器&#xff0c;系统用户名&#xff1a;root&#xff0c;密…

在Github上寻找安装ROS软件包

1、创建一个功能包 并下载git sudo apt install git 2、找到自己想在github上要克隆的包 复制此链接 3、克隆到本地 git clone 链接 4.scripts目录用于放置脚本文件和python程序 使用脚本安装编译需要的依赖库 5、下载完成后&#xff0c;在~catkin_ws目录下运行catkin_make进…

电脑键盘如何练习盲打?

电脑键盘如何练习盲打&#xff1f;盲打很简单&#xff0c;跟着我做&#xff0c;今天教会你。 请看【图1】&#xff1a; 【图1】中&#xff0c;红色方框就是8个基准键位&#xff0c;打字时我们左右手的8个手指就是放在这8个基准键位上&#xff0c;F键和J键上各有一个小突起&…

FTP协议——BFTPD安装(Linux)

1、简介 BFTPD&#xff0c;全称为 Brutal File Transfer Protocol Daemon&#xff0c;是一个用于Unix和类Unix系统的轻量级FTP服务器软件。它的设计理念是提供一个简单、快速、安全的FTP服务器解决方案&#xff0c;特别适用于需要低资源占用的环境。 2、步骤 环境&#xff1…

网络爬虫原理及其应用

你是否想知道Google 和 Bing 等搜索引擎如何收集搜索结果中显示的所有数据。这是因为搜索引擎对其档案中的所有页面建立索引&#xff0c;以便它们可以根据查询返回最相关的结果。网络爬虫使搜索引擎能够处理这个过程。 本文重点介绍了网络爬虫的重要方面、网络爬虫为何重要、其…

卷积神经网络CNN动态演示和输出特征图计算公式

目录 一、卷积运算 1、卷积&#xff08;Convolution&#xff09; 2、填充&#xff08;Padding&#xff09; &#xff08;1&#xff09;Valid Padding &#xff08;2&#xff09;Same Padding 3、步长 4、卷积核大小为什么一般为奇数奇数&#xff1f; 5、卷积核kernel和…

蓝桥杯杨辉三角

PREV-282 杨辉三角形【第十二届】【蓝桥杯省赛】【B组】 &#xff08;二分查找 递推&#xff09;&#xff1a; 解析&#xff1a; 1.杨辉三角具有对称性&#xff1a; 2.杨辉三角具有一定规律 通过观察发现&#xff0c;第一次出现的地方一定在左部靠右的位置&#xff0c;所以从…

驱动编译报error: negative width in bit-field ‘<anonymous>’错误

错误如下图所示&#xff1a; 代码如下&#xff1a; 问题点&#xff1a;module_param的其他用户的权限参数上。 在Linux中&#xff0c;文件权限由读(r)、写(w)、执行(x)权限组成&#xff0c;分别对应数值4、2、1。 第一位0是占位符&#xff0c;在这里没有意义&#xff0c;因为…