例1，入隊操作：

<?php $redis = new Redis(); $redis->connect('127.0.0.1',6379); while(True){try{$value = 'value_'.date('Y-m-d H:i:s');$redis->LPUSH('key1',$value);sleep(rand()%3);echo $value."\n";}catch(Exception $e){echo $e->getMessage()."\n";} } ?>?

例2，出隊操作：

<?php $redis = new Redis(); $redis->pconnect('127.0.0.1',6379); while(True){try{echo $redis->LPOP('key1')."\n";}catch(Exception $e){echo $e->getMessage()."\n";}sleep(rand()%3); } ?>

----------------------------------------------------------------------------------------------------------------------------

一 生產(chǎn)者producer部分

--------------------------------producer 部分注釋------------------------------------------------------------

用戶在頁面請求之后, 獲取到用戶uid , 跳轉(zhuǎn)到這個加入隊列的方法 (這里直接在producer中模擬了多個uid)

在方法內(nèi)部判斷redis隊列長度是否已經(jīng)達到要求, 如果沒有超出, 則執(zhí)行加入隊列的操作 (這里為了簡潔,沒有封裝成方法)

注: producer.php沒有進行數(shù)據(jù)庫的操作,只有接受uid和其他值的操作, 數(shù)據(jù)庫操作一律放在消費者consumer.php中

--------------------------------producer 注釋結(jié)束-----------------------------------------------------------------------

生產(chǎn)者代碼 producer.php:<?php//連接redis數(shù)據(jù)庫 $redis = new Redis(); $redis->connect('127.0.0.1',6379); $redis_name = 'secKill3';//模擬100人請求秒殺(高壓力) for ($i = 0; $i < 100; $i++) {$uid = rand(10000000, 99999999);//獲取當前隊列已經(jīng)擁有的數(shù)量,如果人數(shù)少于十,則加入這個隊列$num = 10;if ($redis->lLen($redis_name) < $num) {$redis->rPush($redis_name, $uid);echo $uid . "秒殺成功"."<br>";} else {//如果當前隊列人數(shù)已經(jīng)達到10人,則返回秒殺已完成echo "秒殺已結(jié)束<br>";} } //關(guān)閉redis連接 $redis->close();

注: 執(zhí)行完producer.php文件,本地redis數(shù)據(jù)庫第0號數(shù)據(jù)庫中應(yīng)該有一個鍵名為"secKill3"的List隊列,像這樣

二 消費者consumer部分

------------------------------消費者部分注釋---------------------------------------------

消費者一直讀取redis數(shù)據(jù)庫中指定隊列,一有值,立即取出,并進行相應(yīng)數(shù)據(jù)庫操作

------------------------------消費者部分注釋結(jié)束----------------------------------------

消費者代碼 consumer.php

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

注: 執(zhí)行完consumer.php之后,數(shù)據(jù)庫對應(yīng)數(shù)據(jù)表應(yīng)該有數(shù)值

到此,秒殺結(jié)束

備注:

用到的student數(shù)據(jù)表結(jié)構(gòu)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)

原文：https://blog.csdn.net/m_nanle_xiaobudiu/article/details/80479666?

總結(jié)

以上是生活随笔為你收集整理的php中使用redis队列操作实例代码的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。