本文解決上文第一個(gè)問(wèn)題，即超賣(mài)問(wèn)題，主要是通過(guò)redis鎖機(jī)制控制并發(fā)
只有獲得鎖的進(jìn)程才能進(jìn)行商品秒殺活動(dòng)，否則都排隊(duì)等待，所有的操作（鎖機(jī)制，用戶(hù)購(gòu)買(mǎi)記錄等）都基于redis實(shí)現(xiàn)，最后再持久化到數(shù)據(jù)庫(kù)中

php代碼更改如下

/**
     * 開(kāi)始搶購(gòu)
     * @author jinanav 2021年10月5日21:54:07
     * @return
     */
    public function index(){
        //持久化數(shù)據(jù)
        $this->persistence();exit();

        $redis = new \Redis();
        $redis->connect("127.0.0.1");
        //初始化數(shù)據(jù)
//        for ($i = 0; $i < 10;$i++){
//            $redis->lPush("orderseckill",1);
//        }
//        $redis->set("seckillTotal",10);
//        $redis->del("lock");
        //var_dump($redis->get("seckillTotal"));
        //登錄流程假定統(tǒng)
        $uid = Request::get("uid");
        //固定商品id
        $gId = 1;
        $lockId = md5(uniqid().rand(100,999));
        //監(jiān)聽(tīng)key
        $redis->watch("seckillTotal");
        //循環(huán)搶鎖,進(jìn)行并發(fā)控制
        while (($total = intval($redis->get("seckillTotal"))) > 0){
            //開(kāi)啟redis事務(wù)
            $redis->multi();
            //開(kāi)始上鎖
            if($redis->set("lock",$lockId, array('nx', 'ex' => 10))){
                //講商品id與用戶(hù)id寫(xiě)入到隊(duì)列中
                $guid = $gId."_".$uid;
                //推入到隊(duì)列中（也可以用rabbitMQ實(shí)現(xiàn)）
                $redis->lPush("seckill",$guid);
                $redis->set("seckillTotal",$total - 1);
                //解鎖
//                if($redis->get("lock") == $lockId){
//                    $redis->del("lock");
//                }
                //為了保證解鎖過(guò)程的原子性，推薦使用以下方式釋放鎖
                $script = 'if redis.call("get","lock") == "'.$lockId.'"
                    then
                        return redis.call("del","lock")
                    else
                        return 0
                    end ';
                $redis->eval($script);
                //提交redis事務(wù)
               if( $redis->exec()){
                   $this->success("搶購(gòu)成功");
               }
    
               
            }
            //睡眠50毫秒
            usleep(50000);

        }
        $this->error("沒(méi)有搶到任何商品");
    }

    /**
     * 數(shù)據(jù)持久化
     * @author jinanav 2021/10/6 1:07
     * @return
     */
    public function persistence(){
        $redis = new \Redis();
        $redis->connect("127.0.0.1");
        $queue = "seckill";
        while($redis->lLen($queue)){
            $guid = $redis->rPop($queue);
            if(!empty($guid)){
                $dataArray = explode("_",$guid);
                $uid = $dataArray[1];
                $goods = Db::name("goods")->where(['id'=>$dataArray[0]])->find();
                try {
                    Db::startTrans();
                    Db::name('order')->insert([
                        'order_num' => md5(uniqid().time().rand(10,99)),
                        'total_cash'=> $goods['price'],
                        'user_id'   => $uid,
                        'title'     => $goods['goods_title'],
                        'g_u_id'    => $guid
                    ]);
                    Db::name("goods")->where(['id'=>$goods['id']])->update(['seckill_inventory'=>$goods['seckill_inventory']-1]);
                    Db::commit();
                }catch (\Exception $e){
                    Db::rollback();
                }
            }
        }
        $this->success("入庫(kù)成功");

    }

看go并發(fā)1000個(gè)用戶(hù)進(jìn)行秒殺活動(dòng)

image.png

查看數(shù)據(jù)庫(kù)結(jié)果

10條數(shù)據(jù)，，沒(méi)有超賣(mài)

image.png

利用redis鎖機(jī)制實(shí)現(xiàn)了并發(fā)控制，但是，明顯編碼程度略復(fù)雜，下一文將用go的協(xié)成實(shí)現(xiàn)并發(fā)控制，編碼更簡(jiǎn)單，更易理解

其實(shí)也可以通過(guò)redis的隊(duì)列實(shí)現(xiàn)并發(fā)控制，由于隊(duì)列的操作是原子性的(可以提前生成令牌列表總數(shù)，令牌消耗盡了說(shuō)明商品也搶購(gòu)?fù)炅?，一堆請(qǐng)求過(guò)來(lái)依舊是要排隊(duì)的，代碼如下

    /**
     * 開(kāi)始搶購(gòu)
     * @author jinanav 2021年10月5日21:54:07
     * @return
     */
    public function index(){
        //持久化數(shù)據(jù)
        //$this->persistence();exit();

        $redis = new \Redis();
        $redis->connect("127.0.0.1");
        //初始化數(shù)據(jù)
//        for ($i = 0; $i < 10;$i++){
//            $redis->lPush("orderseckill",1);
//        }
//        var_dump($redis->lLen("orderseckill"));
//        exit();
        //登錄流程假定統(tǒng)
        $uid = Request::get("uid");
        //固定商品id
        $gId = 1;

        if($redis->lPop("orderseckill")){
            //講商品id與用戶(hù)id寫(xiě)入到隊(duì)列中
            $guid = $gId."_".$uid;
            //推入到隊(duì)列中（也可以用rabbitMQ實(shí)現(xiàn)）
            $redis->lPush("seckill",$guid);
            $this->success("搶購(gòu)成功");
        }else{
            $this->error("沒(méi)有搶到任何商品");
        }
        $this->error("沒(méi)有搶到任何商品");
    }

go模仿100個(gè)用戶(hù)進(jìn)行請(qǐng)求

image.png

數(shù)據(jù)庫(kù)結(jié)果

image.png