您好,登錄后才能下訂單哦!
小編這次要給大家分享的是PHP+Redis鏈表如何解決高并發(fā)下商品超賣問(wèn)題,文章內(nèi)容豐富,感興趣的小伙伴可以來(lái)了解一下,希望大家閱讀完這篇文章之后能夠有所收獲。
實(shí)現(xiàn)原理
使用redis鏈表來(lái)做,因?yàn)閜op操作是原子的,即使有很多用戶同時(shí)到達(dá),也是依次執(zhí)行,推薦使用。
實(shí)現(xiàn)步驟
第一步,先將商品庫(kù)存入隊(duì)列
/** * 添加商品數(shù)量到商品隊(duì)列 * @param int $couponId 優(yōu)惠券ID */ function addCoupons($couponId) { //1.初始化Redis連接 $redis = new Redis(); if (!$redis->connect('127.0.0.1', 6379)) { trigger_error('Redis連接出錯(cuò)!??!', E_USER_ERROR); } else { echo '連接正常<br>'; } //根據(jù)優(yōu)惠券ID從數(shù)據(jù)庫(kù)中查詢?cè)搩?yōu)惠券的庫(kù)存量 //$sql = "select id, stock from coupon where id = {$couponId}"; $stock = 10; //假設(shè)10就是我們從數(shù)據(jù)庫(kù)中查詢出的該優(yōu)惠券在數(shù)據(jù)庫(kù)中的庫(kù)存量 //我們現(xiàn)在將這10個(gè)庫(kù)存放入到以該商品ID為key的redis鏈表中,有幾件庫(kù)存,就存入多少次1,鏈表長(zhǎng)度代表商品庫(kù)存數(shù) for($i = 0; $i < $stock; $i++) { $redis->lPush("secKill:".$couponId.":stock", 1); } $redis->close(); } $couponId = 11211; addCoupons($couponId);
我們調(diào)用該方法,然后查看redis,鏈表中已經(jīng)添加了10個(gè)元素
第二步,搶購(gòu)開(kāi)始,設(shè)置庫(kù)存的緩存周期
這一步根據(jù)自己的業(yè)務(wù)來(lái)定,如果業(yè)務(wù)規(guī)定,這個(gè)優(yōu)惠券就放出2分鐘給用戶搶,那么就通過(guò)expire()
方法給鏈表設(shè)置一個(gè)有效期,即使是在有效期內(nèi)沒(méi)有搶完仍然有庫(kù)存也不讓用戶搶了(由于我們公司業(yè)務(wù)不對(duì)優(yōu)惠券搶券設(shè)置有效期,所以這一步我不需要做)
//設(shè)置鏈表有效期是兩分鐘 $redis->expire('key', 120);
第三步,客戶端執(zhí)行瞬時(shí)搶購(gòu)操作
/** * 搶優(yōu)惠券(秒殺) * @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連接出錯(cuò)!?。?#39;, E_USER_ERROR); } else { echo '連接正常<br>'; } //將已經(jīng)成功搶購(gòu)的用戶添加到該以該商品ID為key的集合(set)中 //如果用戶已經(jīng)在集合中,說(shuō)明用戶已經(jīng)成功秒殺過(guò)一次了,不允許再次參與秒殺 if ($redis->sIsMember('secKill:'.$couponId.':uid', $uid)) { echo '秒殺失敗'; return false; } //秒殺商品的庫(kù)存key $key = 'secKill:'.$couponId.':stock'; //從以該優(yōu)惠券ID為key的鏈表中彈出一個(gè)值,如果有值,證明優(yōu)惠券還有庫(kù)存 $isSockNotEmpty = $redis->lPop($key); //判斷庫(kù)存,如果庫(kù)存大于0,則減庫(kù)存,將該成功秒殺用戶加入哈希表,如果小于等于0,秒殺結(jié)束 if ($isSockNotEmpty != 1) { echo '秒殺已結(jié)束'; return false; } //搶券成功,將優(yōu)惠券ID和UID放入到隊(duì)列中,由一個(gè)單獨(dú)的進(jìn)程隊(duì)列來(lái)消費(fèi)隊(duì)列里的數(shù)據(jù),向用戶推送搶到的優(yōu)惠券 $redis->lPush('couponOrder', $couponId.'+'.$uid); //將成功搶券的用戶記錄到集合中,防止被已搶過(guò)的用戶再次秒殺 $redis->sAdd('secKill:'.$couponId.':uid', $uid); $redis->close(); return true; } $couponId = 11211; $uid = mt_rand(1, 100); secKill($couponId, $uid);
第四步,將成功秒殺的用戶入數(shù)據(jù)庫(kù)持久化數(shù)據(jù),對(duì)于并發(fā)量不是很大的搶購(gòu),我們可以在第三步成功搶購(gòu)后直接將信息寫(xiě)入數(shù)據(jù)庫(kù),對(duì)于并發(fā)量比較大的可以放入RabbitMQ消息隊(duì)列中消費(fèi)(推薦使用RabbitMQ隊(duì)列而不是redis是因?yàn)镽abbitMQ可以保證消息百分之百的被消費(fèi),而redis就相對(duì)沒(méi)有那么穩(wěn)定與可靠)
//此處代碼省略 //根據(jù)自己的業(yè)務(wù)場(chǎng)景看看是入數(shù)據(jù)庫(kù)還是放入rabbitMQ消息隊(duì)列中消費(fèi)
現(xiàn)在我們使用ab工具模擬高并發(fā)下的搶券行為(2000次請(qǐng)求數(shù),100并發(fā)量)
ab -n 2000 -c 100 www.test.com/
然后我們通過(guò)Redis Desktop Manager來(lái)查看Redis的結(jié)果
同樣的,couponOrder隊(duì)列里已經(jīng)有了10份包含用戶uid和優(yōu)惠券id的信息了,這些信息可以由隊(duì)列消費(fèi)。
同時(shí),用戶搶券集合里也保存了10個(gè)用戶的UID信息。
看完這篇關(guān)于PHP+Redis鏈表如何解決高并發(fā)下商品超賣問(wèn)題的文章,如果覺(jué)得文章內(nèi)容寫(xiě)得不錯(cuò)的話,可以把它分享出去給更多人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。