当前位置:首页 > PHP > 正文内容

php redis队列实现秒杀 , php用redis 实现秒杀功能

高老师6年前 (2020-01-26)PHP3109

为什么使用队列?因为pop取队列具有原子性。假如我们需要秒杀一个商品id,我们先将商品的库存保存到一个队列。例如:

<?php

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

//定义商品Id
$good_id = 1;

//定义商品的库存数量
$count = 10;

//为商品定义一个库存队列key
$seckillKey = '2021_1_26_seckill_' . $good_id;

//向当前商品队列写入库存
for ($i = 1; $i <= $count; $i++)
{
    $redis->lPush($seckillKey, $i);
}

echo "商品id:{$good_id}的商品队列设置成功";

将商品id1的库存10件全部保存到队列。

然后创建一个前台的秒杀的脚本,如下:

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

//获取用户要秒杀的商品id
$good_id = $_GET['id'] ?? 0;
if(empty($good_id))
{
    die('请传递正确的商品id');
}

//商品库存队列key
$seckillKey = '2021_1_26_seckill_' . $good_id;

//从库存队列提取库存
$stock = $redis->lPop($seckillKey);
if (!$stock)
{
    die('秒杀失败,库存不足!');
}
else
{
    echo '秒杀成功' . PHP_EOL;

    //todo()
    //创建订单,减少库存
}

多个商品可以创建多个队列

扫描二维码推送至手机访问。

版权声明:本文由高久峰个人博客发布,如需转载请注明出处。

本文链接:https://blog.20230611.cn/post/118.html

分享给朋友:

“php redis队列实现秒杀 , php用redis 实现秒杀功能” 的相关文章

 php文件锁解决高并发

php文件锁解决高并发

前面的文章对于高并发下单商品导致商品库存为负值的问题请先阅读再阅读本篇文章一定对您有帮助,建议亲手测试较好。加上文件锁后的下单处理代码:【一】.阻塞模式:(如果其他进程已经加锁文件,当前进程会一直等其他进程解锁文件后继续执行)<?php //连接数据库 $con=mysqli_connect(...

php抽奖概率算法

php抽奖概率算法

<?php /*  *算法学习自百度.只是学习和记录  */ header("Content-type:text/html;charset=utf-8"); //1.设置奖项,id是奖项id,name是中奖名称,v是中奖概率 $arr =&n...

 php header属性,php header 详解,php header的作用

php header属性,php header 详解,php header的作用

header() 函数向客户端发送原始的 HTTP 报头。(官方解释)通俗的讲header函数将参数中的字符串作为服务端的响应头来返回给客户端。什么是服务端的响应头?打开谷歌浏览器看看network中的请求response header信息即可。更多的参数百度response header即可浏览器...

php创建webservice,php搭建webservice,php编写webservice

php创建webservice,php搭建webservice,php编写webservice

第一步:服务端文件<?php $wsdlfile='webservice.wsdl'; ini_set('soap.wsdl_cache_enabled','0');    //关闭WSDL缓存 //001...

PHP中的ArrayAccess用法详解

PHP中的ArrayAccess用法详解

php arrayaccess 官方的说法是让你能以数组的形式访问对象,对于这种php内置接口一直不太明白有什么用,坚持多看文章,终于理解,特来分享,思路不同,更易于理解。(1).创建一个学生类,并且实现arrayaccess 接口。<?php class  studen...

php finally使用

php finally使用

<?php /**  * @throws Exception  */ function curl() {     throw  new \Exception('err...