1. 程式人生 > >PHP+Redis連結串列解決高併發下商品超賣問題

PHP+Redis連結串列解決高併發下商品超賣問題

[TOC] [上一篇](https://www.cnblogs.com/itbsl/p/13418176.html)文章聊了一下使用**Redis事務**來解決高併發商品超賣問題,今天我們來聊一下使用**Redis連結串列**來解決高併發商品超賣問題。 ### 實現原理 使用redis連結串列來做,因為pop操作是原子的,即使有很多使用者同時到達,也是依次執行,推薦使用。 ### 實現步驟 第一步,先將商品庫存入佇列 ```php /** * 新增商品數量到商品佇列 * @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 '連線正常
'; } //根據優惠券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個元素 ![](https://img2020.cnblogs.com/blog/720430/202008/720430-20200803090640504-1669479363.png) 第二步,搶購開始,設定庫存的快取週期 這一步根據自己的業務來定,如果業務規定,這個優惠券就放出2分鐘給使用者搶,那麼就通過`expire()`方法給連結串列設定一個有效期,即使是在有效期內沒有搶完仍然有庫存也不讓使用者搶了(由於我們公司業務不對優惠券搶券設定有效期,所以這一步我不需要做) ```php //設定連結串列有效期是兩分鐘 $redis->expire('key', 120); ``` 第三步,客戶端執行瞬時搶購操作 ```php /** * 搶優惠券(秒殺) * @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 '連線正常
'; } //將已經成功搶購的使用者新增到該以該商品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就相對沒有那麼穩定與可靠) ```php //此處程式碼省略 //根據自己的業務場景看看是入資料庫還是放入rabbitMQ訊息佇列中消費 ``` 現在我們使用ab工具模擬高併發下的搶券行為(2000次請求數,100併發量) ```shell ab -n 2000 -c 100 www.test.com/ ``` 然後我們通過Redis Desktop Manager來檢視Redis的結果 同樣的,couponOrder佇列裡已經有了10份包含使用者uid和優惠券id的資訊了,這些資訊可以由佇列消費。 ![](https://img2020.cnblogs.com/blog/720430/202008/720430-20200803090657101-1766804426.png) 同時,使用者搶券集合裡也儲存了10個使用者的UID資訊。 ![](https://img2020.cnblogs.com/blog/720430/202008/720430-20200803090706098-1348320282.png) 轉載請註明原文連結:https://www.cnblogs.com/itbsl/p/13424