这篇文章主要介绍了PHP+Redis链表解决高并发下商品超卖问题，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下。

上一篇文章聊了一下使用Redis事务来解决高并发商品超卖问题，今天我们来聊一下使用Redis链表来解决高并发商品超卖问题。

实现原理

使用redis链表来做，因为pop操作是原子的，即使有很多用户同时到达，也是依次执行，推荐使用。

实现步骤

第一步，先将商品库存入队列

1. /** 
2.  * 添加商品数量到商品队列 
3.  * @param int $couponId 优惠券ID 
4.  */ 
5. function addCoupons($couponId) 
6. { 
7.  //1.初始化Redis连接 
8.  $redis = new Redis(); 
9.  if (!$redis->connect('127.0.0.1', 6379)) { 
10.  trigger_error('Redis连接出错！！！', E_USER_ERROR); 
11.  } else { 
12.  echo '连接正常<br>'; 
13.  } 
14.  
15.  //根据优惠券ID从数据库中查询该优惠券的库存量 
16.  //$sql = "select id, stock from coupon where id = {$couponId}"; 
17.  $stock = 10; //假设10就是我们从数据库中查询出的该优惠券在数据库中的库存量 
18.  
19.  //我们现在将这10个库存放入到以该商品ID为key的redis链表中,有几件库存，就存入多少次1，链表长度代表商品库存数 
20.  for($i = 0; $i < $stock; $i++) { 
21.  $redis->lPush("secKill:".$couponId.":stock", 1); 
22.  } 
23.  
24.  $redis->close(); 
25. } 
26. $couponId = 11211; 
27. addCoupons($couponId); 

我们调用该方法，然后查看redis,链表中已经添加了10个元素

第二步，抢购开始，设置库存的缓存周期

这一步根据自己的业务来定，如果业务规定，这个优惠券就放出2分钟给用户抢，那么就通过expire()方法给链表设置一个有效期，即使是在有效期内没有抢完仍然有库存也不让用户抢了(由于我们公司业务不对优惠券抢券设置有效期，所以这一步我不需要做)

//设置链表有效期是两分钟
$redis->expire('key', 120);

第三步，客户端执行瞬时抢购操作

1. /** 
2.  * 抢优惠券(秒杀) 
3.  * @param int $couponId 商品ID 
4.  * @param int $uid 用户ID 
5.  * @return bool 
6.  */ 
7. function secKill($couponId, $uid) 
8. { 
9.  //1.初始化Redis连接 
10.  $redis = new Redis(); 
11.  if (!$redis->connect('127.0.0.1', 6379)) { 
12.  trigger_error('Redis连接出错！！！', E_USER_ERROR); 
13.  } else { 
14.  echo '连接正常<br>'; 
15.  } 
16.  
17.  //将已经成功抢购的用户添加到该以该商品ID为key的集合(set)中 
18.  //如果用户已经在集合中，说明用户已经成功秒杀过一次了，不允许再次参与秒杀 
19.  if ($redis->sIsMember('secKill:'.$couponId.':uid', $uid)) { 
20.  echo '秒杀失败'; 
21.  return false; 
22.  } 
23.  
24.  //秒杀商品的库存key 
25.  $key = 'secKill:'.$couponId.':stock'; 
26.  
27.  //从以该优惠券ID为key的链表中弹出一个值，如果有值，证明优惠券还有库存 
28.  $isSockNotEmpty = $redis->lPop($key); 
29.  
30.  //判断库存，如果库存大于0，则减库存，将该成功秒杀用户加入哈希表，如果小于等于0，秒杀结束 
31.  if ($isSockNotEmpty != 1) { 
32.  echo '秒杀已结束'; 
33.  return false; 
34.  } 
35.  
36.  //抢券成功，将优惠券ID和UID放入到队列中，由一个单独的进程队列来消费队列里的数据，向用户推送抢到的优惠券 
37.  $redis->lPush('couponOrder', $couponId.'+'.$uid); 
38.  
39.  //将成功抢券的用户记录到集合中，防止被已抢过的用户再次秒杀 
40.  $redis->sAdd('secKill:'.$couponId.':uid', $uid); 
41.  $redis->close(); 
42.  return true; 
43. } 
44.  
45. $couponId = 11211; 
46. $uid = mt_rand(1, 100); 
47. secKill($couponId, $uid); 

第四步，将成功秒杀的用户入数据库持久化数据，对于并发量不是很大的抢购，我们可以在第三步成功抢购后直接将信息写入数据库，对于并发量比较大的可以放入RabbitMQ消息队列中消费(推荐使用RabbitMQ队列而不是redis是因为RabbitMQ可以保证消息百分之百的被消费，而redis就相对没有那么稳定与可靠)

//此处代码省略

//根据自己的业务场景看看是入数据库还是放入rabbitMQ消息队列中消费

现在我们使用ab工具模拟高并发下的抢券行为(2000次请求数，100并发量)

ab -n 2000 -c 100 www.test.com/

然后我们通过Redis Desktop Manager来查看Redis的结果

同样的，couponOrder队列里已经有了10份包含用户uid和优惠券id的信息了，这些信息可以由队列消费。

同时，用户抢券集合里也保存了10个用户的UID信息。

Tags: PHP+Redis PHP高并发

分享到：