Redis核心技术与实战【学习笔记】 - 25.Redis 支撑秒杀场景的关键技术

简述

秒杀是一个非常经典的活动场景,比如,在双 11、618 等电商促销活动中,都会有秒杀场景。秒杀场景的业务特点是限时限量,业务系统要处理瞬时的大量高并发请求,而 Redis 就经常被用来支撑秒杀活动。

秒杀场景包含多个环节,可以分成秒杀前、秒杀中和秒杀后三个阶段,每个阶段的请求处理需求不同,Redis 并不能支撑秒杀场景的每一个环节。

Redis 具体在秒杀场景的哪个环节起到支撑作用的呢?又是如何支持的呢?清楚了解这个问题,我们才能知道再秒杀场景中,如何使用 Redis 来支撑高并发压力,并且做好秒杀场景的应对方案。


1.秒杀场景的负载特征对支撑系统的要求

秒杀活动售卖的商品通常价格非常优惠,会吸引大量用户进行抢购。但是,商品库存却量却远小于购买商品的用户数,而且会限定用户只能在一定的时间段内购买。这就给秒杀系统带来两个明显的特征。

第一个特征是瞬时并发访问量非常高
一般数据库每秒只能支撑千级别的并发请求,而 Redis 的并发处理能力(每秒处理请求数)能达到万级别,甚至更高。所以,当有大量并发请求涌入秒杀系统时,我们就需要使用 Redis 先拦截大部分请求,避免大量请求直接发送给数据库,将数据库压垮

第二个特征是读多写少,而且读操作是简单的查询操作
在秒杀场景下,用户需要先查验商品是否还有库存(也就是根据商品 ID 查询该商品的库存),只有库存有余量时,秒杀系统才能进行库存扣减和下单操作。

库存查验操作是典型的键值对查询,而 Redis 对键值对查询的高效支持,正好和这个操作要求相匹配。

不过,秒杀活动中,只有少部分用户能下单成功,所以,商品库存查询操作(读操作)要远多于库存扣减和下单操作(写操作)。

当然,实际秒杀场景通常有多个环节,刚才介绍的用户查验库存知识其中的一个环节。那么,Redis 具体可以在整个秒杀场景中哪些环节发挥作用呢?这就要说到秒杀活动的整体流程了。

2.Redis 可以在秒杀场景的哪些环节发挥作用?

秒杀活动可以分成三个阶段。在每一个阶段,Redis 发挥的作用也不一样。

第一阶段是秒杀活动前

在这个阶段,用户会不断刷新商品相亲页,这会导致详情页的瞬时请求量剧增。在这个阶段的应对方案,一般是尽量把商品详情页的页面元素静态化,然后使用 CDN 或是浏览器把这些静态化元素缓存起来。这样一来,秒杀前的大量请求可以直接由 CDN 或是浏览器缓存服务,不会达到服务器了,这就减轻了服务器端的压力。

在这个阶段,有 CDN 和浏览器缓存服务请求就足够了,还不需要使用 Redis。

第二阶段是秒杀活动开始

此时,大量用户点击商品详情页上的秒杀按钮,会产生大量的并发请求查询库存。一旦某个请求查询到有库存,紧接着系统就会进行库存扣减。然后,系统会生成实际订单,并进行后续处理,例如订单支付和物流服务。如果请求查询不到库存,就会返回。用户通常会继续点击秒杀按钮,继续查询库存。

简单来说,这个阶段的操作就是三个:库存查验、库存扣减和订单处理。因为每个秒杀请求都会查询库存,而请求只有查询到库存余量后,后续的库存扣减和订单处理才会被执行。所以,这个阶段中最大的压力都在库存查验上。

为了支撑大量高并发的库存查验请求,我们需要在每个环节使用 Redis 保存库存量,这样一来,可以直接从 Redis 中读取库存并进行查验。

那么,库存扣减和订单处理是否都可以交给后端数据库来执行呢?

其实,订单处理可以在数据库中执行,但库存扣减操作,不能交给后端数据库处理。

在数据库中处理订单的原因比较简单,我先说明下。订单处理会设计支付、商品出库、物流操作等多个关联操作,这些操作本身涉及数据库的多张数据库表,要保证处理的事务性,需要在数据库中完成。而且,订单处理时的请求压力以及不大了,数据库可以支撑这些订单处理请求。

那为啥库存扣减操作不能再数据库执行呢?这是因为,一旦请求查询到有库存,就意味着发送该请求的用户获得了商品的购买资格,用户就会下单了。同时,商品的库存余量也需要减少一个。如果我们把库存扣减的操作放到数据库执行,会带来两个问题。

  1. 额外的开销:Redis 保存了库存量,而库存量的的最新值又是在数据库中维护,所以所以数据库更新后,还需要和 Redis 进行同步,这个过程增加了额外的操作逻辑,也带来了额外的开销。
  2. 下单量超过实际库存量,出现超售:由于数据库的处理速度较慢,不能及时更新库存余量,这会导致大量库存查验的请求读取到旧的库存值,并进行下单。此时就会出现下单数量大于实际的库存量,导致出现超售,这就不符合业务层的要求了。

所以,我们需要在 Redis 中进行库存扣减。具体的操作是,当库存查验完成后,一旦库存有余量,我们就立即在 Redis 扣减库存。而且,为了避免请求查询到旧值,库存查询和库存扣减这两个操作需要保证原子性。

第三阶段就是秒杀活动结束后

在这个阶段,可能还会有部分用户刷新商品详情页,尝试等待有其他用户退单。而已经成功的下单用户会刷新订单详细,更新订单的进展。不过,这个阶段中的用户请求量以及下降很多了,服务器端一般都能支撑,就不重点讨论了。

小结

秒杀场景开始前后,高并发压力没有那么大,我们不需要使用 Redis,但在秒杀中,需要查验和扣减商品库存,库存查验面临大量的高并发请求,而库存扣减有需要和库存查验一起执行,以保证原子性。这就是秒杀对 Redis 的需求。

在这里插入图片描述

3. Reids 的哪些方法可以支撑秒杀场景?

秒杀场景对 Redis 操作的根本要求有两个。

  1. 支持高并发。Redis 本身高速处理请求的特性可以支持高并发。而且,如果有多个秒杀商品,我们可以使用切片集群,用不同的实例保存不同商品的库存,这样就避免使用单个实例导致所有的秒杀请求都集中在一个实例上的问题了。不过,需要注意的是,当使用切片集群时,我们要先使用 CRC 算法计算不同秒杀商品 key 对应的 Slot,然后,我们再分配 Solt 和实例对应关系时,才能把不同秒杀商品对应的 Slot 分配到不同的实例上。
  2. 保证库存查验和扣减原子性执行。可以使用 Redis 的原子操作或是分布式锁这两个功能特性来支撑。

先来看下 Redis 是如何基于原子操作来支撑秒杀场景的。

4.基于原子操作支撑秒杀场景

在秒杀场景中,一个商品的库存对应两个信息,分别是总库存量和已秒杀量。这种数据模型正好是一个 key(商品 ID )对应了两个属性(总库存量和已秒杀量),所以,我们可以使用一个 Hash 类型的键值对来保存的两个信息,如下所示:

key: itemID
value: {total: N, ordered: M}

其中,itemID 是商品的编号,total 是总库存量,ordered 是已秒杀量。

因为库存查验和库存扣减这两个操作要保证一起执行,一个直接的方法就是使用 Redis 的原子操作。可以使用 Lua 脚本。因为库存查验和扣减是两个操作,无法用一条命令来完成,所有需要用 Lua 脚本原子性地执行这两个操作。

//获取商品库存信息
local counts = redis.call("HMGET", KEYS[1], "total", "ordered");
//将总库存转换为数值
local total = tonumber(counts[1])
//将已被秒杀的库存转换为数值
local ordered = tonumber(counts[2])
//如果将当前请求的库存量加上已秒杀的库存量仍小于总库存量,就可以更新库存
if ordered + k <= total then//更新已秒杀的库存量,ordered加上kredis.call("HINCRBY", KEYS[1],"ordered", k)return k
end return 0

有了 Lua 脚本后,我们就可以在 Redis 客户端,使用 EVAL 命令来执行这个脚本了。

最后,客户端会根据脚本的返回值,来确定秒杀是成功还是失败了。如果返回值是 k,就是成功了;如果是 0,就是失败。

到这里,学习了如何使用原子性的 Lua 脚本来实现库存查验和库存扣减。其实,要想保证库存查验和扣减这两个操作的原子性,我们还有另一种方法,就是使用分布式锁来保证多个客户端能互斥执行这两个操作。接下来,我们就来看下如何使用分布式锁来支撑秒杀场景。

5.基于分布式锁来支撑秒杀场景

使用分布式锁来支撑秒杀场景的具体做法是,先让客户端向 Redis 申请分布式锁,只有拿到锁的客户端才能执行库存查验和库存扣减。这样一来,大量的秒杀请求就会争夺分布式锁时过滤掉。而且,库存查验和扣减也不使用原子操作了,因为多个客户端只有一个客户端能够拿到锁,已经保证了客户端并发访问的互斥性。

你可以看下下面的伪代码,它显示了分布式锁来执行库存查验和扣减的过程。

//使用商品ID作为key
key = itemID
//使用客户端唯一标识作为value
val = clientUniqueID
//申请分布式锁,Timeout是超时时间
lock = acquireLock(key, val, Timeout)
//当拿到锁后,才能进行库存查验和扣减
if(lock = true) {//库存查验和扣减availStock = DECR(key, k)//库存已扣减完了,释放锁,返回秒杀失败if(availStock < 0) {releaseLock(key,val)return error}//库存扣减成功,释放锁else {releaseLock(key,val)//处理订单}
}
//没有拿到锁,直接返回
else return

在使用分布式锁时,客户端需要先想 Redis 请求锁,只有请求到了锁,才能进行库存查验等操作,这样一来,客户端在争抢分布式锁时,大部分秒杀请求本身会因为抢不到分布式锁而被拦截。

我们可以使用切片集群中的不同实例来分别保存分布式锁和商品库存信息。使用这种方式保存后,秒杀请求会首先访问到分布式锁的实例。如果客户端没有拿到锁,这些客户端就不会查询商品库存,这样就可以减轻保存库存信息的实例的压力了。

小结

Redis 在秒杀场景中有 2 个负载特征,分别是瞬时高并发请求和读多写少。Redis 良好的并发处理能力,以及高效的键值对读写特性,正好可以满足秒杀场景的需求。

在秒杀场景中,可以通过前端 CDN 和浏览器缓存拦截大量秒杀前的请求。在实际秒杀活动中进行时,库存查验和库存扣减是承受巨大压力的两个操作,同时,两个操作的执行需要保证原子性。Redis 的原子操作和分布式锁都可以有效的支撑秒杀场景。

当然,对于秒杀场景来说,只用 Redis 是不够的。秒杀系统是一个系统的工程,Redis 实现了对库存查验和扣减环节的支撑,除此之外,还有 4 个环节需要我们处理好。

  1. 前端静态页面设计。秒杀页面上能静态化处理的页面元素,我们都要尽量静态化,这样可以充分利用 CDN 或浏览器缓存服务秒杀开始前的请求。
  2. 请求拦截和流控。在秒杀系统的接入层,对恶意请求进行拦截,例如使用黑名单禁止恶意 IP 进行访问。如果 Redis 系统的访问压力过大,为了避免实例崩溃,我们也要在接入层进行限流,控制进入秒杀系统的请求数量。
  3. 库存信息过期时间处理。Redis 中保存的库存信息其实是数据库的缓存,为了避免缓存击穿问题,我们不要给库存信息设置过期时间
  4. 数据库订单异常处理。如果数据库没能成功处理订单,可以增加订单重试机制,保证订单最终能被处理成功。

再给你一个小建议:秒杀活动带来的请求流量巨大,我们需要把秒杀商品的库存信息用单独的 Redis 实例保存,而不要和日常业务系统的数据保存在同一个实例上,这样可以避免干扰业务的正常运行

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

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

相关文章

2.4日总结

第一题&#xff1a;选数 题解&#xff1a;思路还是很简单的&#xff0c;只需要想清楚dfs里的函数都是什么就可以了&#xff0c;还有一个简单的判断素数的函数&#xff0c;这题真没啥难度&#xff0c;就是属于基础题吧&#xff0c;请看AC代码 #include <stdio.h> #includ…

【c/python】GtkGrid

一、GtkGrid GtkGrid 是 GTK (GIMP Toolkit) 中的一个基础容器构件&#xff08;widget&#xff09;&#xff0c;它可以用来安排其他构件在一个灵活的多行多列的网格中。每个加入网格的构件都可以占据一个或多个行和列。由于 GtkGrid 提供了在二维空间中安排构件的方式&#xf…

YOLOv5独家改进:上采样算子 | 超轻量高效动态上采样DySample,效果秒杀CAFFE,助力小目标检测

💡💡💡本文独家改进:一种超轻量高效动态上采样DySample, 具有更少的参数、FLOPs,效果秒杀CAFFE和YOLOv5网络中的nn.Upsample 💡💡💡在多个数据集下验证能够涨点,尤其在小目标检测领域涨点显著。 收录 YOLOv5原创自研 https://blog.csdn.net/m0_63774211/cate…

多输入多输出 | Matlab实现PSO-LSTM粒子群优化长短期记忆神经网络多输入多输出预测

多输入多输出 | Matlab实现PSO-LSTM粒子群优化长短期记忆神经网络多输入多输出预测 目录 多输入多输出 | Matlab实现PSO-LSTM粒子群优化长短期记忆神经网络多输入多输出预测预测效果基本介绍程序设计参考资料 预测效果 基本介绍 Matlab实现PSO-LSTM粒子群优化长短期记忆神经网络…

2 物理层(一):数据通信的基本概念

目录 目标1 数据通信的基本概念1.1 数据通信的基本概念1、数据2、信息3、信号4、信道5、通信和数据通信6、数据通信网7、码元和码字8、数据分组9、基带传输、频带传输和宽带传输基带传输频带传输宽带传输 1.2 数据通信的主要技术指标1.3 数据通信系统1、数据通信系统基本模型编…

【ARM 嵌入式 编译系列 2.7 -- GCC 编译优化参数详细介绍】

文章目录 GCC 编译优化概述常用优化等级-O1 打开的优化选项-O2 打开的优化选项-O3 打开的优化选项-Os 打开的优化选项优化技术使用优化选项的注意事项GCC 编译优化概述 GCC(GNU Compiler Collection)包含了用于C、C++、Objective-C、Fortran、Ada和Go等语言的编译器。在编译…

能和ai聊天的软件有吗?分享4款智能软件!

随着科技的飞速发展&#xff0c;人工智能&#xff08;AI&#xff09;已经渗透到我们生活的方方面面。如今&#xff0c;我们只需一款软件&#xff0c;就能与AI进行流畅的对话。今天&#xff0c;就让我们一起揭开这些神秘软件的神秘面纱&#xff0c;看看它们如何让我们的沟通变得…

ONLYOFFICE:一站式办公,探索高效办公新境界

写在前面ONLYOFFICE 介绍ONLYOFFICE 有哪些优势ONLYOFFICE 文档 8.0 发布如何体验 ONLYOFFICEONLYOFFICE 文档部分页面截图 写在前面 在当今这样一个数字化时代&#xff0c;办公软件已经成为我们日常工作中不可或缺的一部分&#xff0c;熟练使用 Office、WPS、腾讯文档、金山文…

搜大学英语题,用哪个软件好?哪款大学搜题工具好用? #媒体#职场发展#媒体

大学生除了学习专业知识外&#xff0c;还应该关注和学习一些软技能&#xff0c;如沟通能力、团队合作和领导力等&#xff0c;以提升自己的综合素质。 1.好大学在线 好大学在线是上海交通大学拥有的中国顶尖慕课平台。 依托该平台&#xff0c;上海交通大学与百度及金智教育实…

机器学习 | 基于网格搜索的SVM超参数调节

机器学习模型被定义为一个数学模型&#xff0c;其中包含许多需要从数据中学习的参数。然而&#xff0c;有一些参数&#xff0c;称为超参数&#xff0c;这些参数不能直接学习。它们通常是由人类在实际训练开始前根据直觉或经验和试验选择的。这些参数通过提高模型的性能&#xf…

网络协议梳理

1 引言 在计算机网络中要做到有条不紊地交换数据&#xff0c;就必须遵守一些事先约定好的规则。这些规则明确规定了所交换的数据的格式以及有关的同步问题。这里所说的同步不是狭义的&#xff08;即同频或同频同相&#xff09;而是广义的&#xff0c;即在一定的条件下应当发生什…

每日一题——LeetCode1403.非递增顺序的最小子序列

方法一 个人方法&#xff1a; 按题目要求&#xff0c;尽可能先取出nums里最大的值&#xff0c;这样才能满足子序列尽可能短且元素之和最大 var minSubsequence function(nums) {nums.sort((a,b)>a-b)let sum1nums.reduce((a,b)>ab,0),sum20,res[]while(sum1>sum2){…

【并发编程】原子累加器

&#x1f4dd;个人主页&#xff1a;五敷有你 &#x1f525;系列专栏&#xff1a;并发编程 ⛺️稳重求进&#xff0c;晒太阳 JDK8之后有专门做累加的类&#xff0c;效率比自己做快数倍以上 累加器性能比较 参数是方法 // supplier 提供者 无中生有 ()->结果// func…

golang并发安全-sync.Once

什么是sync.Once sync.Once 是 Go 语言中的一种同步原语&#xff0c;用于确保某个操作或函数在并发环境下只被执行一次。它只有一个导出的方法&#xff0c;即 Do&#xff0c;该方法接收一个函数参数。在 Do 方法被调用后&#xff0c;该函数将被执行&#xff0c;而且只会执行一…

Excel——高级筛选匹配条件提取数据

一、筛选多条件 Q&#xff1a;筛选多个条件&#xff0c;并将筛选出的内容复制到其他区域 点击任意一个单元格 点击【数据】——【筛选】——【高级筛选】 选择【将筛选结果复制到其他位置】——在【列表区域】 鼠标选择对应的区域位置&#xff0c;条件区域一定要单独写出来&a…

政安晨:示例演绎Python的函数与获取帮助的方法

调用函数和定义我们自己的函数&#xff0c;并使用Python内置的文档&#xff0c;是成为一位Pythoner的开始。 通过我的上篇文章&#xff0c;相信您已经看过并使用了print和abs等函数。但是Python还有许多其他函数&#xff0c;并且定义自己的函数是Python编程的重要部分。 在本…

【51单片机】LED的三个基本项目(LED点亮&LED闪烁&LED流水灯)(3)

前言 大家好吖&#xff0c;欢迎来到 YY 滴单片机系列 &#xff0c;热烈欢迎&#xff01; 本章主要内容面向接触过单片机的老铁 主要内容含&#xff1a; 欢迎订阅 YY滴C专栏&#xff01;更多干货持续更新&#xff01;以下是传送门&#xff01; YY的《C》专栏YY的《C11》专栏YY的…

将xyz格式的GRACE数据转成geotiff格式

我们需要将xyz格式的文件转成geotiff便于成图&#xff0c;或者geotiff转成xyz用于数据运算&#xff0c;下面介绍如何实现这一操作&#xff0c;采用GMT和matlab两种方法。 1.GMT转换 我们先准备一个xyz文件&#xff0c;这里是一个降水文件。在gmt中采用以下的语句实现xyz转grd…

java synchronized浅析

介绍synchronized synchronized 是Java编程语言中的一个关键字&#xff0c;用于实现线程间的同步。在多线程环境下&#xff0c;它确保了共享资源在同一时刻只能被一个线程访问或修改&#xff0c;从而避免了因多个线程并发操作同一数据而导致的数据不一致和竞态条件。 synchroni…

070:vue+cesium: 利用canvas设置径向渐变色材质

相关API参考: https://cesium.com/learn/cesiumjs/ref-doc/ColorMaterialProperty.html 第070个 点击查看专栏目录 本示例的目的是介绍如何在vue+cesium中设置线性渐变色的材质,这里使用canvas的辅助方法。 直接复制下面的 vue+cesium源代码,操作2分钟即可运行实现效果. …