介绍/* *
*添加商品数量到商品队列
* @param int美元couponId优惠券ID
*/函数addCoupons (couponId美元)
{//1 .初始化复述,连接
复述,美元=new复述();
如果(! $复述→连接(& # 39;127.0.0.1 # 39;,6379)){
trigger_error(& # 39;复述,连接出的错! ! ! & # 39;,E_USER_ERROR);
其他}{
回声& # 39;连接正常& lt; br> & # 39;;
}//根据优惠券ID从数据库中查询该优惠券的库存量//$ sql=把≡駃d,股票从优惠券id={$ couponId}“;
股票=10美元;//假设10就是我们从数据库中查询出的该优惠券在数据库中的库存量//我们现在将这10个库存放入到以该商品ID为键的复述,链表中,有几件库存,就存入多少1次,链表长度代表商品库存数
($ i=0;美元我& lt;美元的股票;$我+ +){
复述→美元lPush(“秒杀:“。美元couponId !”: stock", 1);
}
复述→美元close ();
}
couponId=11211美元;
addCoupons ($ couponId); //设置链表有效期是两分钟
复述→美元到期(& # 39;关键# 39;,120年), /* *
*抢优惠券(秒杀)
* @param int美元couponId商品ID
* @param int uid用美元户ID
* @return bool
*/函数秒杀(couponId, uid美元)
{//1 .初始化复述,连接
复述,美元=new复述();
如果(! $复述→连接(& # 39;127.0.0.1 # 39;,6379)){
trigger_error(& # 39;复述,连接出的错! ! ! & # 39;,E_USER_ERROR);
其他}{
回声& # 39;连接正常& lt; br> & # 39;;
}//将已经成功抢购的用户添加到该以该商品ID为键的集合(组)中//如果用户已经在集合中,说明用户已经成功秒杀过一次了,不允许再次参与秒杀
如果(复述→美元sIsMember(& # 39;秒杀:& # 39;。美元couponId # 39;公司:uid # 39;, uid美元)){
回声& # 39;秒杀失败& # 39;;
返回错误;
}//秒杀商品的库存的关键
$关键=& # 39;秒杀:& # 39;。美元couponId # 39;公司:股票# 39;;//从以该优惠券ID为键的链表中弹出一个值,如果有值,证明优惠券还有库存
isSockNotEmpty=复述→美元lPop(关键);//判断库存,如果库存大于0,则减库存,将该成功秒杀用户加入哈希表,如果小于等于0,秒杀结束
如果($ isSockNotEmpty !=1) {
回声& # 39;秒杀已结束& # 39;;
返回错误;
}//抢券成功,将优惠券ID和UID放入到队列中,由一个单独的进程队列来消费队列里的数据,向用户推送抢到的优惠券
复述→美元lPush (& # 39; couponOrder& # 39;,美元couponId强生# 39;+ & # 39;美元uid);//将成功抢券的用户记录到集合中,防止被已抢过的用户再次秒杀
复述→美元大块漂浮植物(& # 39;秒杀:& # 39;。美元couponId # 39;公司:uid # 39;, uid美元);
复述→美元close ();
返回true;
}
couponId=11211美元;
$ uid=mt_rand (100);
秒杀(couponId, uid美元); //此处代码省略//根据自己的业务场景看看是入数据库还是放入rabbitMQ消息队列中消费
小编这次要给大家分享的是PHP +复述,链表如何解决高并发下商品超卖问题,文章内容丰富,感兴趣的小伙伴可以来了解一下,希望大家阅读完这篇文章之后能够有所收获。
<强>实现原理
使用复述,链表来做,因为流行操作是原子的,即使有很多用户同时到达,也是依次执行,推荐使用。
第一步,先将商品库存入队列
我们调用该方法,然后查看复述,链表中已经添加了10个元素
第二步,抢购开始,设置库存的缓存周期
这一步根据自己的业务来定,如果业务规定,这个优惠券就放出2分钟给用户抢,那么就通过<代码>到期()方法给链表设置一个有效期,即使是在有效期内没有抢完仍然有库存也不让用户抢了(由于我们公司业务不对优惠券抢券设置有效期,所以这一步我不需要做)
第三步,客户端执行瞬时抢购操作
第四步,将成功秒杀的用户入数据库持久化数据,对于并发量不是很大的抢购,我们可以在第三步成功抢购后直接将信息写入数据库,对于并发量比较大的可以放入RabbitMQ消息队列中消费(推荐使用RabbitMQ队列而不是复述,是因为RabbitMQ可以保证消息百分之百的被消费,而复述,就相对没有那么稳定与可靠)
现在我们使用ab工具模拟高并发下的抢券行为(2000次请求数,100年并发量)
ab - n - c 100 www.test.com/PHP +复述,链表如何解决高并发下商品超卖问题
