摘要：基于的消息隊(duì)列實(shí)現(xiàn)固定庫存商品搶購商品總庫存需要在后臺(tái)寫入到庫存隊(duì)里中提前寫入獲取庫存并減一寫入隊(duì)列搶購成功售賣完畢基于上面的基礎(chǔ)解決購買數(shù)量存儲(chǔ)，超時(shí)不支付訂單取消訂單并恢復(fù)庫存商品總庫存需要在后臺(tái)寫入到庫存隊(duì)里中提前寫入

//商品總庫存需要在后臺(tái)寫入到庫存隊(duì)里中,提前寫入
$redis = new Redis();
$redis->connect("127.0.0.1",6379);
$redis->auth("alloc");
$redis->select(1);
//獲取庫存并減一寫入隊(duì)列
$k = $redis->lPop("sale_count");
echo $k;
if($k>1){
    if($k-1 == 0){
        $redis->del("sale_count");
    }else{
        $redis->lPush("sale_count",$k-1);
    }
    echo "搶購成功！";
}else{
    echo "售賣完畢！";
}

connect("127.0.0.1", 6379);
$redis->auth("alloc");
$redis->select(1);
//
$user_id = rand(1, 10000);//隨機(jī)模擬用戶ID 不去重復(fù)了實(shí)際情況下沒有重復(fù)的
$buy_num = rand(1, 9);//隨機(jī)模擬購買數(shù)量
//獲取庫存并減一寫入隊(duì)列
$k = $redis->lPop("sale_count");
if ($k > 1) {
    if ($k - $buy_num <= 0) {
        exit("庫存不足");
    }else{
        
        $redis->rPush("get_good_list", $user_id);//將搶到順序插入隊(duì)列,在守護(hù)進(jìn)程1中處理
        $redis->setex($user_id, 1800, $buy_num);//設(shè)置超時(shí)時(shí)間30分鐘
        $redis->rPush("sale_count", $k - $buy_num);
        
    } 
    
    echo "搶購成功！，請五分鐘內(nèi)支付";
} else {
    echo "售賣完畢！";
}

connect("127.0.0.1", 6379);
$redis->auth("alloc");
$redis->select(1);
//while (1){
    $user_id = $redis->lPop("get_good_list");
    if($user_id){
        //獲取購買數(shù)量
        $buy_num = $redis->get($user_id);
        //創(chuàng)建訂單
        $order_no = createOder($user_id,$buy_num);
        //設(shè)置訂單超時(shí)時(shí)間
        $redis->setex($order_no,300,1);//5分鐘未支付通知Daemon2.php

    }
//}

connect("127.0.0.1", 6379);
$redis->auth("alloc");
$redis->select(1);
//不超時(shí)
$redis->setOption(Redis::OPT_READ_TIMEOUT, -1);
//創(chuàng)建事件監(jiān)聽，__keyevent@1__:expired，數(shù)字1代表數(shù)據(jù)庫序號(hào)
$redis->psubscribe(array("__keyevent@1__:expired"), "keyCallback");
// 回調(diào)函數(shù),這里寫處理邏輯
function keyCallback($redis, $pattern, $chan, $order_no){
    //獲取訂單信息 獲取購買數(shù)量
    $buy_num = getOderInfo($order_no);
    //關(guān)閉訂單
    closeOrder();
    //加入庫存
    $redis->rPush("sale_count",$redis->lPop("sale_count")+$buy_num);
}