PHP+Redis連結串列解決高併發下商品超賣問題
阿新 • • 發佈:2020-09-10
今天我們來聊一下使用Redis連結串列來解決高併發商品超賣問題。
實現原理
使用redis連結串列來做,因為pop操作是原子的,即使有很多使用者同時到達,也是依次執行,推薦使用。
實現步驟
第一步,先將商品庫存入佇列
/**
* 搶優惠券(秒殺)
* @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的連結串列中彈出一個值,如果有值(>0),證明優惠券還有庫存,則減庫存,將該成功秒殺使用者加入雜湊表,如果小於等於0,秒殺結束
if ($redis->lPop($key) != 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);
我們呼叫該方法,然後檢視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資訊。