利用redis List隊列簡單實現秒殺 PHP代碼實現

一 生產者producer部分

 

--------------------------------producer 部分註釋------------------------------------------------------------

用戶在頁面請求以後, 獲取到用戶uid , 跳轉到這個加入隊列的方法 (這裏直接在producer中模擬了多個uid)

在方法內部判斷redis隊列長度是否已經達到要求, 若是沒有超出, 則執行加入隊列的操做 (這裏爲了簡潔,沒有封裝成方法)

注: producer.php沒有進行數據庫的操做,只有接受uid和其餘值的操做, 數據庫操做一概放在消費者consumer.php中

--------------------------------producer 註釋結束-----------------------------------------------------------------------

 

生產者代碼 producer.php:

<?php
 
//鏈接redis數據庫
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
$redis_name = 'secKill3';
 
//模擬100人請求秒殺(高壓力)
for ($i = 0; $i < 100; $i++) {
    $uid = rand(10000000, 99999999);
    //獲取當前隊列已經擁有的數量,若是人數少於十,則加入這個隊列
    $num = 10;
    if ($redis->lLen($redis_name) < $num) {
        $redis->rPush($redis_name, $uid);
        echo $uid . "秒殺成功"."<br>";
    } else {
        //若是當前隊列人數已經達到10人,則返回秒殺已完成
        echo "秒殺已結束<br>";
    }
}
//關閉redis鏈接
$redis->close();
 

　

注: 執行完producer.php文件,本地redis數據庫第0號數據庫中應該有一個鍵名爲"secKill3"的List隊列,像這樣

 

二 消費者consumer部分

 

------------------------------消費者部分註釋---------------------------------------------

消費者一直讀取redis數據庫中指定隊列,一有值,當即取出,並進行相應數據庫操做

------------------------------消費者部分註釋結束----------------------------------------

 

消費者代碼 consumer.php

 

<?php
 
//設置redis數據庫鏈接及鍵名
$redis = new Redis();
$redis->connect('127.0.0.1');
$key = 'secKill3';//redis數據庫key [注:默認redis數據庫選擇第0號數據庫]
 
//PDO鏈接mysql數據庫
$dsn = "mysql:dbname=test;host=127.0.0.1";
$pdo = new PDO($dsn, 'root', '123456');
 
 //死循環
//從隊列最前頭取出一個值,判斷這個值是否存在,取出時間和uid,保存到數據庫
//數據庫插入失敗時,要有回滾機制
//注: rpush 和lpop是一對
 
while(1) {
    //從隊列最前頭取出一個值
    $uid = $redis->lPop($key);
    //判斷值是否存在
    if(!$uid || $uid == 'nil'){
        sleep(2);
        continue;
    }
    //生成訂單號
    $orderNum = build_order_no($uid);
    //生成訂單時間
    $timeStamp = time();
    //構造插入數組
    $user_data = array('uid'=>$uid,'time_stamp'=>$timeStamp,'order_num'=>$orderNum);
    //將數據保存到數據庫
    $sql = "insert into student (uid,time_stamp,order_num) values (:uid,:time_stamp,:order_num)";
    $stmt = $pdo->prepare($sql);
    $res = $stmt->execute($user_data);
    //數據庫插入數據失敗,回滾
    if(!$res){
        $redis->rPush($key,$uid);
    }
}
 
//生成惟一訂單號
function build_order_no($uid){
    return  substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8).$uid;
}

 

注: 執行完consumer.php以後,數據庫對應數據表應該有數值

到此,秒殺結束

 

備註:

用到的student數據表結構sql

 

CREATE TABLE `student`  (
  `uid` int(10) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT 'uid',
  `username` varchar(20) NOT NULL DEFAULT '',
  `time_stamp` int(11) NOT NULL DEFAULT 0,
  `order_num` bigint(20) UNSIGNED NOT NULL DEFAULT 0,
  PRIMARY KEY (`uid`) USING BTREE,
  key (time_stamp)
) ENGINE = MyISAM default charset=utf8;