首頁 > 資料庫 > Redis > 如何使用Redis鍊錶解決高並發商品超賣問題

如何使用Redis鍊錶解決高並發商品超賣問題

王林
發布: 2023-05-27 13:01:19
轉載
1143 人瀏覽過

實作原理

使用redis鍊錶來做,因為pop操作是原子的,即使有很多使用者同時到達,也是依序執行,建議使用。

實作步驟

第一步,先將商品庫存入佇列

/**
 * 添加商品数量到商品队列
 * @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 &#39;连接正常<br>&#39;;
    }

    //根据优惠券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個元素

如何使用Redis鍊錶解決高並發商品超賣問題

第二步,搶購開始,設定庫存的快取週期

這一步依照自己的業務來定,如果業務規定,這個優惠券就放出2分鐘給用戶搶,那麼就透過expire()方法給鍊錶設定一個有效期,即使是在有效期內沒有搶完仍然有庫存也不讓用戶搶了(由於我們公司業務不對優惠券搶券設定有效期,所以這一步我不需要做)

//设置链表有效期是两分钟
$redis->expire(&#39;key&#39;, 120);
登入後複製

第三步,客戶端執行瞬時搶購操作

/**
 * 抢优惠券(秒杀)
 * @param int $couponId 商品ID
 * @param int $uid 用户ID
 * @return bool
 */
function secKill($couponId, $uid)
{
    //1.初始化Redis连接
    $redis = new Redis();
    if (!$redis->connect(&#39;127.0.0.1&#39;, 6379)) {
        trigger_error(&#39;Redis连接出错!!!&#39;, E_USER_ERROR);
    } else {
        echo &#39;连接正常<br>&#39;;
    }

    //将已经成功抢购的用户添加到该以该商品ID为key的集合(set)中
    //如果用户已经在集合中,说明用户已经成功秒杀过一次了,不允许再次参与秒杀
    if ($redis->sIsMember(&#39;secKill:&#39;.$couponId.&#39;:uid&#39;, $uid)) {
        echo &#39;秒杀失败&#39;;
        return false;
    }

    //秒杀商品的库存key
    $key = &#39;secKill:&#39;.$couponId.&#39;:stock&#39;;

    //从以该优惠券ID为key的链表中弹出一个值,如果有值,证明优惠券还有库存
    $isSockNotEmpty = $redis->lPop($key);

    //判断库存,如果库存大于0,则减库存,将该成功秒杀用户加入哈希表,如果小于等于0,秒杀结束
    if ($isSockNotEmpty != 1) {
        echo &#39;秒杀已结束&#39;;
        return false;
    }

    //抢券成功,将优惠券ID和UID放入到队列中,由一个单独的进程队列来消费队列里的数据,向用户推送抢到的优惠券
    $redis->lPush(&#39;couponOrder&#39;, $couponId.&#39;+&#39;.$uid);

    //将成功抢券的用户记录到集合中,防止被已抢过的用户再次秒杀
    $redis->sAdd(&#39;secKill:&#39;.$couponId.&#39;:uid&#39;, $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的資訊了,這些資訊可以由佇列消費。

如何使用Redis鍊錶解決高並發商品超賣問題

同時,用戶搶券集合裡也保存了10個用戶的UID資訊。

如何使用Redis鍊錶解決高並發商品超賣問題

以上是如何使用Redis鍊錶解決高並發商品超賣問題的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:yisu.com
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板