上一篇文章聊了一下使用Redis事務來解決高併發商品超賣問題,今天咱們來聊一下使用Redis鏈表來解決高併發商品超賣問題。php
實現原理
使用redis鏈表來作,由於pop操做是原子的,即便有不少用戶同時到達,也是依次執行,推薦使用。html
實現步驟
第一步,先將商品庫存入隊列redis
/** * 添加商品數量到商品隊列 * @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個元素sql
第二步,搶購開始,設置庫存的緩存週期shell
這一步根據本身的業務來定,若是業務規定,這個優惠券就放出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信息。