高并发--秒杀--Redis

朱雀 2023-07-24 14:43 166阅读 0赞

原文网址：[高并发--秒杀--Redis\_IT利刃出鞘的博客-CSDN博客][--_--Redis_IT_-CSDN]

# 其他网址 #

[php - 使用redis秒杀出现产品超发现象求解？ - SegmentFault 思否][php - _redis_ - SegmentFault]  
[使用redis秒杀出现产品超发现象求解？ - 知乎][redis_ -]  
[redis解决“高并发定时秒杀”库存误差问题\_数据库\_qq\_40854036的博客-CSDN博客][redis_qq_40854036_-CSDN]

# 简介 #

本处以秒杀场景为例说明高并发的Redis使用情况。

# **适合高并发的方法** #

## list（队列） ##

**其他网址**

> [用Redis轻松实现秒杀系统\_数据库\_zxc456733的博客-CSDN博客][Redis_zxc456733_-CSDN]
> 
> 《深入浅出Spring Boot 2.x》=> 15.2.4 使用Redis处理高并发

**思路**

> 1.  把秒杀请求压入队列：**RPUSH key value** （当插入的秒杀请求数达到上限时，停止所有后续插入。）
> 2.  同时，从队列获得用户请求的用户ID等并进行处理
>     
>     1.  后台启动多个工作线程，使用**LPOP key** 或 **LRANGE key start end**
>     2.  每完成一条秒杀记录的处理，就执行减库存操作：Decr/Decrby key （详见下方）
> 3.  所有库存处理完毕，就结束该商品的本次秒杀，关闭工作线程，也不再接收秒杀请求。
> 4.  将数据同步到磁盘（数据库）：可以使用定时任务

## 原子增减 ##

主要是这几个命令：incr、incrby、decr、decrby

**逻辑**：

> 1，调用 incrby ，此时返回数字为减少后的数字。  
> 2，如果此时返回小于 0，返回库存不足。否则就成功获取到库存。  
> 3，如果用户下单失败，需要用 lua 脚本操作。内容为判断库存是否小于 0 ，小于 0 时直接将新库存 set 进去，否则还是用 incr 自增。要加库存也是用这个脚本的逻辑。

**示例**

>     local nowNum = redis.call("get","STOCK_KEY")
>     if (nowNum == nil or nowNum < 0) then
>         redis.call("set","STOCK_KEY",INCR)
>         return INCR
>     end
>     return redis.call("incrby","STOCK_KEY",INCR)
> 
> INCR 为要返还的库存或新增库存数

**注意**

> 如果是减库存，要用decrby count\_key 1。incrby count\_key -1 会出现负值，用这种方式的话得采用lua脚本的方式，先要判断count\_key的值是否>0 才继续扣减，这样才能防止超卖。

# **不适合高并发的方法** #

## 锁 ##

**其他网址**

> Redis-秒杀watch 出现超卖\_pythonluo的专栏-CSDN博客

**分析**：

> Redis事务是**乐观锁**，它不能锁住操作，仅仅只是监听事务内的key是否已经被操作过。  
> 之所以会超发，是因为你代码中 获取库存-减少库存-放入新库存数 这期间不是原子性的。  
> 比如 A 获取是库存为 100，B 获取时库存为 100，两方经过计算之后得到的剩余库存数都是99，然后 set 到 Redis 去，所以最后的结果是99。  
> 当然，你可以给“获取库存-减少库存-放入新库存数”过程**加锁，但是在秒杀高并发下，系统会卡死**。解决办法是，用 Redis 原生的 hincrby 或 incrby 方法，该方法用于原子性操作 Hash 对象中的数字自增或自减。（见上方）

**使用锁的超发例子**

>     <?php  
>     header("content-type:text/html;charset=utf-8");  
>     $redis = new redis();  
>     $result = $redis->connect('10.10.10.119', 6379);  
>     $mywatchkey = $redis->get("mywatchkey");  
>     $rob_total = 100;   //抢购数量  
>     if($mywatchkey<$rob_total){  
>         $redis->watch("mywatchkey");  
>         $redis->multi();  
>           
>         //设置延迟，方便测试效果。  
>         sleep(5);  
>         //插入抢购数据  
>         $redis->hSet("mywatchlist","user_id_".mt_rand(1, 9999),time());  
>         $redis->set("mywatchkey",$mywatchkey+1);  
>         $rob_result = $redis->exec();  
>         if($rob_result){  
>             $mywatchlist = $redis->hGetAll("mywatchlist");  
>             echo "抢购成功！<br/>";  
>             echo "剩余数量：".($rob_total-$mywatchkey-1)."<br/>";  
>             echo "用户列表：<pre>";  
>             var_dump($mywatchlist);  
>         }else{  
>             echo "手气不好，再抢购！";exit;  
>         }  
>     }  
>     ?>

# Redis Cluster撑不住怎么办 #

若客户很多。即使部署了Redis Cluster，仍然撑不住，那该怎么办呢？ 下面，我们具体分析下，还有哪些情况会压垮我们架构在Redis（Cluster）上的秒杀系统。

**脚本攻击**

> 如现在有很多抢火车票的软件。它们会自动发起http请求。一个客户端一秒会发起很多次请求。如果有很多用户使用了这样的软件，就可能会直接把我们的交换机给压垮了。
> 
> 这个问题其实属于网络问题的范畴，和我们的秒杀系统不在一个层面上。因此不应该由我们来解决。很多交换机都有防止一个源IP发起过多请求的功能。开源软件也有不少能实现这点。如linux上的TC可以控制。流行的Web服务器Nginx（它也可以看做是一个七层软交换机）也可以通过配置做到这一点。一个IP，一秒钟我就允许你访问我2次，其他软件包直接给你丢了，你还能压垮我吗？

**交换机撑不住了**

> 可能你们的客户并发访问量实在太大了，交换机都撑不住了。 这也有办法。我们可以用多个交换机为我们的秒杀系统服务。 原理就是DNS可以对一个域名返回多个IP，并且对不同的源IP，同一个域名返回不同的IP。如网通用户访问，就返回一个网通机房的IP；电信用户访问，就返回一个电信机房的IP。也就是用**CDN**了！  
> 我们可以部署多台交换机为不同的用户服务。 用户通过这些交换机访问后面数据中心的Redis Cluster进行秒杀作业。

[--_--Redis_IT_-CSDN]: https://knife.blog.csdn.net/article/details/105471553
[php - _redis_ - SegmentFault]: https://segmentfault.com/q/1010000007165163
[redis_ -]: https://www.zhihu.com/question/51583361?sort=created
[redis_qq_40854036_-CSDN]: https://blog.csdn.net/qq_40854036/article/details/80664543
[Redis_zxc456733_-CSDN]: https://blog.csdn.net/zxc456733/article/details/78864986