上一篇文章聊了一下使用redis事務(wù)來解決高并發(fā)商品超賣問題，今天我們來聊一下使用redis鏈表來解決高并發(fā)商品超賣問題。
實(shí)現(xiàn)原理
使用redis鏈表來做，因?yàn)閜op操作是原子的，即使有很多用戶同時(shí)到達(dá)，也是依次執(zhí)行，推薦使用。
實(shí)現(xiàn)步驟
第一步，先將商品庫存入隊(duì)列
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
/** * 添加商品數(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ù)庫中查詢該優(yōu)惠券的庫存量 //$sql = "select id, stock from coupon where id = {$couponid}"; $stock = 10; //假設(shè)10就是我們從數(shù)據(jù)庫中查詢出的該優(yōu)惠券在數(shù)據(jù)庫中的庫存量 //我們現(xiàn)在將這10個(gè)庫存放入到以該商品id為key的redis鏈表中,有幾件庫存，就存入多少次1，鏈表長度代表商品庫存數(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è)元素
第二步，搶購開始，設(shè)置庫存的緩存周期
這一步根據(jù)自己的業(yè)務(wù)來定，如果業(yè)務(wù)規(guī)定，這個(gè)優(yōu)惠券就放出2分鐘給用戶搶，那么就通過expire()方法給鏈表設(shè)置一個(gè)有效期，即使是在有效期內(nèi)沒有搶完仍然有庫存也不讓用戶搶了(由于我們公司業(yè)務(wù)不對優(yōu)惠券搶券設(shè)置有效期，所以這一步我不需要做)
|
1
2
|
//設(shè)置鏈表有效期是兩分鐘$redis->expire('key', 120); |
第三步，客戶端執(zhí)行瞬時(shí)搶購操作
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
/** * 搶優(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ò)！！！', e_user_error); } else { echo '連接正常<br>'; } //將已經(jīng)成功搶購的用戶添加到該以該商品id為key的集合(set)中 //如果用戶已經(jīng)在集合中，說明用戶已經(jīng)成功秒殺過一次了，不允許再次參與秒殺 if ($redis->sismember('seckill:'.$couponid.':uid', $uid)) { echo '秒殺失敗'; return false; } //秒殺商品的庫存key $key = 'seckill:'.$couponid.':stock'; //從以該優(yōu)惠券id為key的鏈表中彈出一個(gè)值，如果有值，證明優(yōu)惠券還有庫存 $issocknotempty = $redis->lpop($key); //判斷庫存，如果庫存大于0，則減庫存，將該成功秒殺用戶加入哈希表，如果小于等于0，秒殺結(jié)束 if ($issocknotempty != 1) { echo '秒殺已結(jié)束'; return false; } //搶券成功，將優(yōu)惠券id和uid放入到隊(duì)列中，由一個(gè)單獨(dú)的進(jìn)程隊(duì)列來消費(fèi)隊(duì)列里的數(shù)據(jù)，向用戶推送搶到的優(yōu)惠券 $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); |
第四步，將成功秒殺的用戶入數(shù)據(jù)庫持久化數(shù)據(jù)，對于并發(fā)量不是很大的搶購，我們可以在第三步成功搶購后直接將信息寫入數(shù)據(jù)庫，對于并發(fā)量比較大的可以放入rabbitmq消息隊(duì)列中消費(fèi)(推薦使用rabbitmq隊(duì)列而不是redis是因?yàn)閞abbitmq可以保證消息百分之百的被消費(fèi)，而redis就相對沒有那么穩(wěn)定與可靠)
|
1
2
|
//此處代碼省略//根據(jù)自己的業(yè)務(wù)場景看看是入數(shù)據(jù)庫還是放入rabbitmq消息隊(duì)列中消費(fèi) |
現(xiàn)在我們使用ab工具模擬高并發(fā)下的搶券行為(2000次請求數(shù)，100并發(fā)量)
|
1
|
ab -n 2000 -c 100 www.test.com/ |
然后我們通過redis desktop manager來查看redis的結(jié)果
同樣的，couponorder隊(duì)列里已經(jīng)有了10份包含用戶uid和優(yōu)惠券id的信息了，這些信息可以由隊(duì)列消費(fèi)。
同時(shí)，用戶搶券集合里也保存了10個(gè)用戶的uid信息。
到此這篇關(guān)于php+redis鏈表解決高并發(fā)下商品超賣問題(實(shí)現(xiàn)原理及步驟)的文章就介紹到這了,更多相關(guān)php redis解決高并發(fā)下商品超賣內(nèi)容請搜索服務(wù)器之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持服務(wù)器之家！
原文鏈接：https://www.cnblogs.com/itbsl/p/13424432.html
