Thinkphp5+Redis實現商品秒殺

環境：wamp，redis

要求：安裝WAMP，Redis，以及爲PHP安裝Redis擴展（怎麼安裝Redis能夠看看我前面寫的文章）

秒殺功能大體思路：獲取緩存列表的長度，若是長度（llen）等於0，就中止秒殺，即秒殺失敗，若是長度大於0，則繼續運行，先從緩存中移除一個元素（lpop）,再進行數據庫操做（添加訂單表，商品庫存數量減一），若是再進一我的秒殺，就再走一遍流程，循環往復。

1、安裝Redis擴展

1.查看PHP版本信息

打開phpinfo.php，查看PHP版本,個人是PHP7.3.4，還有一個須要注意Architecture x64

2.下載擴展文件

https://pecl.php.net/package/redis   

https://pecl.php.net/package/igbinary

根據本身環境，選擇合適的版本

3.解壓

解壓下載的壓縮包，並把php_redis.dll、php_redis.pdb和php_igbinary.dll、php_igbinary.pdb四個文件，移至本身PHP版本對應目錄下的ext文件夾下 E:\phpstudy_pro\Extensions\php\php7.3.4nts\ext

 

  

4.修改php.ini

添加以下代碼：

extension=php_igbinary.dll

extension=php_redis.dll

若是有這兩句能夠把前面的分號刪掉，沒有就本身添加上，要注意順序，php_igbinary.dll 要在 php_redis.dll 前面

 5.重啓Apache

重啓後，再運行phpinfo.php，查看是否安裝成功

2、數據結構

一共三張表，ab_goods商品表，ab_order訂單表，ab_log日誌表

• 商品表

 

•  訂單表

•  日誌表   記錄秒殺信息

 3、代碼

<?php
namespace app\index\controller;
use think\Controller;
use think\Db;
use think\cache\driver\Redis;

class Miaosha extends Controller
{

    private $redis = null;
    private $cachekey = null;    //緩存變量名
    private $basket = [];        //私有數組，存放商品信息

    private $store = 50;

    /**
     * 購物車初始化，傳入用戶id
     */
    public function __construct()
    {
        parent::__construct();

        $this->redis = new \Redis();        // 實例化
        $this->redis->connect('127.0.0.1','6379');
        $this->redis->auth('zxf123456');

    }

    /**
     * 秒殺初始化
     */
    public function Ms_init()
    {
        // 刪除緩存列表
        $this->redis->del($this->cachekey);

        $len = $this->redis->llen($this->cachekey);
        $count = $this->store - $len;

        for ($i=0; $i < $count; $i++) { 

            // 向庫存列表推動50個,模擬50個商品庫存
            $this->redis->lpush($this->cachekey,1);
        }

        echo "庫存初始化完成:".$this->redis->llen($this->cachekey);
    }
 

    /**
     * 秒殺入口
     */
    public function index()
    {
        $id = 1;    //商品編號
        
        if (empty($id)) {
            // 記錄失敗日誌
            return $this->writeLog(0,'商品編號不存在');    
        }

        // 計算庫存列表長度
        $count = $this->redis->llen($this->cachekey);

        // 先判斷庫存是否爲0,爲0秒殺失敗,不爲0,則進行先移除一個元素,再進行數據庫操做
        if ($count == 0) {    //庫存爲0

            $this->writeLog(0,'庫存爲0');
            echo "庫存爲0";
            exit;

        }else{
            // 有庫存
            //先移除一個列表元素
            $this->redis->lpop($this->cachekey);

            $ordersn = $this->build_order_no();    //生成訂單
            $uid = rand(0,9999);    //隨機生成用戶id
            $status = 1;
            // 再進行數據庫操做
            $data = Db::table('ab_goods')->field('count,amount')->where('id',$id)->find();    //查找商品

            if (!$data) {
                return $this->writeLog(0,'該商品不存在');
            }

            $insert_data = [
                'order_sn' => $ordersn,
                'user_id' => $uid,
                'goods_id' => $id,
                'price'    => $data['amount'],
                'status' => $status,
                'addtime' => date('Y-m-d H:i:s')
            ];

            // 訂單入庫
            $result = Db::table('ab_order')->insert($insert_data);
            // 自動減小一個庫存
            $res = Db::table('ab_goods')->where('id',$id)->setDec('count');

            if ($res) {
                echo "第".$count."件秒殺成功";
                $this->writeLog(1,'秒殺成功');
            }else{
                echo "第".$count."件秒殺失敗";
                $this->writeLog(0,'秒殺失敗');
            }
        }
    }

    /**
     * 生成訂單號
     */
    public function build_order_no()
    {
        return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
    }

    /**
     * 生成日誌  1成功 0失敗
     */
    public function writeLog($status = 1,$msg)
    {
        $data['count'] = 1;
        $data['status'] = $status;
        $data['addtime'] = date('Y-m-d H:i:s');
        $data['msg'] = $msg;
        return Db::table('ab_log')->insertGetId($data);
    }

}

4、壓力測試

使用apache壓力測試工具 AB 測試，模擬多用戶秒殺商品，模擬60秒內發起3000個請求，併發600次，秒殺50個庫存商品

AB測試相關參數說明

-r 指定接收到錯誤信息時不退出程序
-t 等待響應的最大時間
-n 指定壓力測試總共的執行次數
-c 用於指定壓力測試的併發數

　　1.初始化50個庫存，運行ms_init方法

　　2.測試   命令行：E:\phpstudy_pro\Extensions\Apache2.4.39\bin>ab -r -t 60 -n 3000 -c 1000 http://gouwuche.zxf/index/miaosha/index  

須要先進入apache的bin目錄下執行命令

 

 　　3.檢測數據庫數據

 

 日誌表狀態爲1（秒殺成功）的數據有50人，訂單表裏的訂單數也是50條，商品表裏的商品數量變成了0（測試以前是50），商品秒殺成功完成！

若是不用redis而是直接用mysql的話，商品表訂單的數量count會變成負數，而秒殺成功的人數也多餘50人，訂單表裏的訂單數量也多餘50條（新測），下面是直接用Mysql的例子；

public function sqlMs()
    {
        $id = 1;    //商品編號

        $count = 50;
        $ordersn = $this->build_order_no();    //生成訂單
        $uid = rand(0,9999);    //隨機生成用戶id
        $status = 1;
        // 再進行數據庫操做
        $data = Db::table('ab_goods')->field('count,amount')->where('id',$id)->find();    //查找商品

        // 查詢還剩多少庫存
        $rs = Db::table('ab_goods')->where('id',$id)->value('count');
        if ($rs <= 0) {
            
            $this->writeLog(0,'庫存爲0');
        }else{

            $insert_data = [
                'order_sn' => $ordersn,
                'user_id' => $uid,
                'goods_id' => $id,
                'price'    => $data['amount'],
                'status' => $status,
                'addtime' => date('Y-m-d H:i:s')
            ];

            // 訂單入庫
            $result = Db::table('ab_order')->insert($insert_data);
            // 自動減小一個庫存
            $res = Db::table('ab_goods')->where('id',$id)->setDec('count');

            if ($res) {
                echo "第".$data['count']."件秒殺成功";
                $this->writeLog(1,'秒殺成功');
            }else{
                echo "第".$data['count']."件秒殺失敗";
                $this->writeLog(0,'秒殺失敗');
            }
        }
    }