当前位置:首页 > PHP教程 > php高级应用 > 列表

PHP+Redis事务解决高并发下商品超卖问题(推荐)

发布:smiling 来源: PHP粉丝网  添加日期:2022-03-21 11:10:03 浏览: 评论:0 

对于一些有一定用户量的电商网站,如果只是单纯的使用关系型数据库(如MySQL、Oracle)来做抢购,对数据库的压力是非常大的,而且如果不使用好数据库的锁机制,还会导致商品、优惠券超卖的问题。

我所在的公司也遇到了同样的问题,问题发生在优惠券被超量抢购上,在问题发生后我们开始想办法解决问题,由于自己使用redis比较多,我准备使用redis来解决这个问题。

利用redis的高性能和事务特性来解决线上优惠券被超库存抢购的问题,下面我给出我临时解决这个问题的第一版的伪代码,去掉了一些细节:

  1. /** 
  2.  * 抢优惠券(秒杀) 
  3.  * @param int $couponId 商品ID 
  4.  * @param int $uid 用户ID 
  5.  * @return bool 
  6.  */ 
  7. function secKill($couponId$uid
  8.  //1.初始化Redis连接 
  9.  $redis = new Redis(); 
  10.  if (!$redis->connect('127.0.0.1', 6379)) { 
  11.  trigger_error('Redis连接出错!!!', E_USER_ERROR); 
  12.  } else { 
  13.  echo '连接正常<br>'
  14.  } 
  15.  
  16.  //秒杀商品的库存key 
  17.  $key = 'secKill:'.$couponId.':stock'
  18.  $redis->watch($key); 
  19.  
  20.  //获取库存 
  21.  $stock = $redis->get($key); 
  22.  
  23.  //秒杀未开始,表示库存为null 
  24.  if (!$stock && !is_numeric($stock)) { 
  25.  echo '秒杀未开始'
  26.  return false; 
  27.  } 
  28.  
  29.  //判断库存,如果库存大于0,则减库存,将该成功秒杀用户加入哈希表,如果小于等于0,秒杀结束 
  30.  if ($stock <= 0) { 
  31.  echo '秒杀已结束'
  32.  return false; 
  33.  } 
  34.  
  35.  //用户已经成功秒杀过一次了,不允许再次参与秒杀 
  36.  if ($redis->sIsMember('secKill:'.$couponId.':uid'$uid)) { 
  37.  echo '秒杀失败'
  38.  return false; 
  39.  } 
  40.  
  41.  //代码走到这里,说明该用户是第一次参与秒杀,将库存减一,然后把这个人放到已抢到的集合表 
  42.  //multi(),返回一个redis对象,并进入multi-mode模式,一旦进入multi-mode模式,以后调用的所有方法都会返回相同的对象, 
  43.  //直到exec()方法被调用。 
  44.  $result = $redis->multi()->decr($key)->sAdd('secKill:'.$couponId.':uid'$uid)->exec(); 
  45.  
  46.  if (emptyempty($result)) {//事务被取消 
  47.  echo '秒杀失败'
  48.  return false; 
  49.  } 
  50.  
  51.  //抢券成功,将优惠券ID和UID放入到队列中,由一个单独的进程队列来消费队列里的数据,向用户推送抢到的优惠券 
  52.  $redis->lPush('couponOrder'$couponId.'+'.$uid); 
  53.  
  54.  $redis->close(); 
  55.  return true; 
  56.  
  57. $couponId = 11211; 
  58. $uid = mt_rand(1, 100); 
  59. secKill($couponId$uid); 

首先,我模拟设置优惠券ID为11211的优惠券库存为10个。

PHP+Redis事务解决高并发下商品超卖问题(推荐)

然后,我们使用ab工具来模拟1000次请求,50并发量来测试

ab -n 1000 -c 50 www.test.com/

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

couponOrder队列里已经有了10个用户的信息了

PHP+Redis事务解决高并发下商品超卖问题(推荐)

并且优惠券的剩余数量也是0了,不再是负数了

PHP+Redis事务解决高并发下商品超卖问题(推荐)

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

PHP+Redis事务解决高并发下商品超卖问题(推荐)

上面这串代码解决了两个问题:

解决了瞬时的大量查询到数据库上给数据库造成很大压力的问题,流量都被拦截在了redis缓存层

解决了优惠券被超库存抢购的问题

但是,这段代码也存在一定的问题:

没有使用redis连接池,频繁创建新的redis有一定的性能影响

由于使用了事务,每一次并发请求中只会有一个用户抢券成功,该并发请求中的其它用户都会失败,只能等第二次并发

同样还是事务导致的库存遗留问题,如果有10个商品,1000次请求每次200并发量,5次并发请求就完成了1000次请求,但是只会有5个用户成功抢到,如果没有后续的请求,会导致库存还有5份存量

提示:在消费队列里,如果优惠券发放失败,一定要立即记录并短信通知运营管理人员,看看是否能重发或者通过后台手动定向推送给用户。

所以,后续我又使用了lua脚本和redis配合一起来解决了这个问题。具体代码,我会后续整理处理补充完整。

Tags: PHP+Redis事务解决 PHP商品超卖

分享到: