上一篇文章聊了一下使用Redis事務來解決高并發商品超賣問題,今天我們來聊一下使用Redis鏈表來解決高并發商品超賣問題。
實現原理
使用redis鏈表來做,因為pop操作是原子的,即使有很多用戶同時到達,也是依次執行,推薦使用。
實現步驟
第一步,先將商品庫存入隊列
/**
* 添加商品數量到商品隊列
* @param int $couponId 優惠券ID
*/
function addCoupons($couponId)
{
//1.初始化Redis連接
$redis = new Redis();
if (!$redis->connect('127.0.0.1', 6379)) {
trigger_error('Redis連接出錯!!!', E_USER_ERROR);
} else {
echo '連接正常br>';
}
//根據優惠券ID從數據庫中查詢該優惠券的庫存量
//$sql = "select id, stock from coupon where id = {$couponId}";
$stock = 10; //假設10就是我們從數據庫中查詢出的該優惠券在數據庫中的庫存量
//我們現在將這10個庫存放入到以該商品ID為key的redis鏈表中,有幾件庫存,就存入多少次1,鏈表長度代表商品庫存數
for($i = 0; $i $stock; $i++) {
$redis->lPush("secKill:".$couponId.":stock", 1);
}
$redis->close();
}
$couponId = 11211;
addCoupons($couponId);
我們調用該方法,然后查看redis,鏈表中已經添加了10個元素

第二步,搶購開始,設置庫存的緩存周期
這一步根據自己的業務來定,如果業務規定,這個優惠券就放出2分鐘給用戶搶,那么就通過expire()
方法給鏈表設置一個有效期,即使是在有效期內沒有搶完仍然有庫存也不讓用戶搶了(由于我們公司業務不對優惠券搶券設置有效期,所以這一步我不需要做)
//設置鏈表有效期是兩分鐘
$redis->expire('key', 120);
第三步,客戶端執行瞬時搶購操作
/**
* 搶優惠券(秒殺)
* @param int $couponId 商品ID
* @param int $uid 用戶ID
* @return bool
*/
function secKill($couponId, $uid)
{
//1.初始化Redis連接
$redis = new Redis();
if (!$redis->connect('127.0.0.1', 6379)) {
trigger_error('Redis連接出錯!!!', E_USER_ERROR);
} else {
echo '連接正常br>';
}
//將已經成功搶購的用戶添加到該以該商品ID為key的集合(set)中
//如果用戶已經在集合中,說明用戶已經成功秒殺過一次了,不允許再次參與秒殺
if ($redis->sIsMember('secKill:'.$couponId.':uid', $uid)) {
echo '秒殺失敗';
return false;
}
//秒殺商品的庫存key
$key = 'secKill:'.$couponId.':stock';
//從以該優惠券ID為key的鏈表中彈出一個值,如果有值,證明優惠券還有庫存
$isSockNotEmpty = $redis->lPop($key);
//判斷庫存,如果庫存大于0,則減庫存,將該成功秒殺用戶加入哈希表,如果小于等于0,秒殺結束
if ($isSockNotEmpty != 1) {
echo '秒殺已結束';
return false;
}
//搶券成功,將優惠券ID和UID放入到隊列中,由一個單獨的進程隊列來消費隊列里的數據,向用戶推送搶到的優惠券
$redis->lPush('couponOrder', $couponId.'+'.$uid);
//將成功搶券的用戶記錄到集合中,防止被已搶過的用戶再次秒殺
$redis->sAdd('secKill:'.$couponId.':uid', $uid);
$redis->close();
return true;
}
$couponId = 11211;
$uid = mt_rand(1, 100);
secKill($couponId, $uid);
第四步,將成功秒殺的用戶入數據庫持久化數據,對于并發量不是很大的搶購,我們可以在第三步成功搶購后直接將信息寫入數據庫,對于并發量比較大的可以放入RabbitMQ消息隊列中消費(推薦使用RabbitMQ隊列而不是redis是因為RabbitMQ可以保證消息百分之百的被消費,而redis就相對沒有那么穩定與可靠)
//此處代碼省略
//根據自己的業務場景看看是入數據庫還是放入rabbitMQ消息隊列中消費
現在我們使用ab工具模擬高并發下的搶券行為(2000次請求數,100并發量)
ab -n 2000 -c 100 www.test.com/
然后我們通過Redis Desktop Manager來查看Redis的結果
同樣的,couponOrder隊列里已經有了10份包含用戶uid和優惠券id的信息了,這些信息可以由隊列消費。

同時,用戶搶券集合里也保存了10個用戶的UID信息。

到此這篇關于PHP+Redis鏈表解決高并發下商品超賣問題(實現原理及步驟)的文章就介紹到這了,更多相關php redis解決高并發下商品超賣內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家!
您可能感興趣的文章:- PHP下用Swoole實現Actor并發模型的方法
- 淺談并發處理PHP進程間通信之System V IPC
- 淺談并發處理PHP進程間通信之外部介質
- 詳解PHP中curl_multi并發的實現
- php多進程并發編程防止出現僵尸進程的方法分析
- PHP高并發和大流量解決方案整理
- PHP 并發場景的幾種解決方案
- php多進程模擬并發事務產生的問題小結
- 淺談Swoole并發編程的魅力