为什么使用队列?因为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()
//创建订单,减少库存
}多个商品可以创建多个队列
代码1:for循环批量插入100W数据<?php set_time_limit(0); $servername = "localhost"; $username = "root"; $password ...
通过http推送消息给socket,socket服务再向客户端推送<?php /* * Socket推送 * 请用守护进程方式启动php msgservice.php & (socket只...
php官方的超全局变量$_SERVER['PHP_SELF']也能直接获取,只不过如果url参数太多也会获取。下面提供一个方法获取/* * 获取当前PHP文件名称 */ if (!function_exists('phpself...
项目中使用服务来执行webservice,由于对方系统api不稳定,经常导致服务崩溃,只能重启,一个月差不多要重启一次。初期的解决办法是捕获异常,然后continue掉。<?php try { $url = 'http...
xmlrpc协议是通过http请求xml数据进行通信。webservice中和它相同的是soap。soap调用的确很简单,但是创建wsdl太繁琐,效率低下。xmlrpc很好的解决这个问题。(1).创建xmlrpc服务端(求和函数api)function getSum($method,$ar...
【一】.介绍session由于HTTP是无状态的请求,创建一个会话需要保持必须需要身份标识。当用户第一次访问,PHP会为用户创建一个唯一的sessionid,并将sessionid通过cookie发送给浏览器,并在服务器的临时文件创建一个以sessionid为名的文件用来保存这个sessionid保...