第一种使用Redis LIST做队列(List的Lpop操作是原子性的)
生成库存队列
<?php
public function fillStock(){
$redis = new \Redis();
$redis->connect("redis",6379);
$redis->auth("hengda");
$redis->select(1);
for ($i = 0;$i < 1000;$i++){
$redis->lPush("shop_list",rand(1000000000,99999999999999));
}
}
抢购消费队列
<?php
public function purchase(){
$redis = new \Redis();
$redis->connect("redis",6379);
$redis->auth("hengda");
$redis->select(1);
if(!$redis->lPop("shop_list")){
return response_json(1,["msg"=>"已结束"],"success");
}
//TODO 生成订单队列
}
第二种使用Redis执行Lua脚本(执行脚本的eval操作是原子性的)
<?php
public function purchaseLua(){
$redis = new \Redis();
$redis->connect("redis",6379);
$redis->auth("hengda");
$redis->select(1);
$lua_script = <<<LUA
local shop_num_exit = redis.call("get","shop_num");
if shop_num_exit == "0"
then
return false;
else
return redis.call("decr","shop_num");
end
LUA;
$result = $redis->eval($lua_script);
if($result === false){
return response_json(1,["msg"=>"已结束"],"success");
}
//TODO 生成订单对列
}