怎么在Thinkphp5中使用Redis實現(xiàn)一個商品秒殺功能

今天就跟大家聊聊有關(guān)怎么在Thinkphp5中使用Redis實現(xiàn)一個商品秒殺功能，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

一、安裝Redis擴展

1.查看PHP版本信息

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

2.下載擴展文件

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

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

根據(jù)自己環(huán)境，選擇合適的版本

3.解壓

解壓下載的壓縮包，并把php_redis.dll、php_redis.pdb和php_igbinary.dll、php_igbinary.pdb四個文件，移至自己PHP版本對應(yīng)目錄下的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，查看是否安裝成功

二、數(shù)據(jù)結(jié)構(gòu)

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

商品表

訂單表

日志表 記錄秒殺信息

三、代碼

<?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 = []; //私有數(shù)組，存放商品信息

 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,則進行先移除一個元素,再進行數(shù)據(jù)庫操作
 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;
 // 再進行數(shù)據(jù)庫操作
 $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);
 }

}

四、壓力測試

使用apache壓力測試工具 AB 測試，模擬多用戶秒殺商品，模擬60秒內(nèi)發(fā)起3000個請求，并發(fā)600次，秒殺50個庫存商品

AB測試相關(guān)參數(shù)說明

• -r 指定接收到錯誤信息時不退出程序

• -t 等待響應(yīng)的最大時間

• -n 指定壓力測試總共的執(zhí)行次數(shù)

• -c 用于指定壓力測試的并發(fā)數(shù)

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  

　　3.檢測數(shù)據(jù)庫數(shù)據(jù)

日志表狀態(tài)為1（秒殺成功）的數(shù)據(jù)有50人，訂單表里的訂單數(shù)也是50條，商品表里的商品數(shù)量變成了0（測試之前是50），商品秒殺成功完成！

如果不用redis而是直接用mysql的話，商品表訂單的數(shù)量count會變成負數(shù)，而秒殺成功的人數(shù)也多余50人，訂單表里的訂單數(shù)量也多余50條（新測），下面是直接用Mysql的例子；

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

 $count = 50;
 $ordersn = $this->build_order_no(); //生成訂單
 $uid = rand(0,9999); //隨機生成用戶id
 $status = 1;
 // 再進行數(shù)據(jù)庫操作
 $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,'秒殺失敗');
 }
 }
 }

看完上述內(nèi)容，你們對怎么在Thinkphp5中使用Redis實現(xiàn)一個商品秒殺功能有進一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道，感謝大家的支持。