Redis リンク リストを使用して、同時実行性の高い過剰販売製品の問題を解決する方法

実装原則

これを行うには、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 &#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 個の要素がリンク リスト

2 番目のステップは、急ぎ購入を開始し、在庫のキャッシュ サイクルを設定することです。

このステップは、自社のビジネスに応じて決定されます。ビジネスが規定している場合、このクーポンはユーザーが取得できるように 2 分後にリリースされ、expire() メソッドを使用してリンク リストの有効期間を設定します。有効期限があり、まだ在庫があり、ユーザーはそれを取得することはできません (当社の事業ではクーポンを取得しないため、クーポンによって有効期間が設定されるため、この手順を実行する必要はありません)

//设置链表有效期是两分钟
$redis->expire('key', 120);

3 番目のステップでは、クライアントはインスタント スナップアップ操作を実行します。

/**
 * 抢优惠券(秒杀)
 * @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 &#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);

4 番目のステップでは、成功したフラッシュ セール ユーザーがデータベースに入力され、データが永続化されます。これは、同時実行があまり大きくない購入の場合です。 3 番目のステップで購入が成功した後、情報をデータベースに直接書き込むことができます。同時実行性が比較的大きい購入の場合、消費のために RabbitMQ メッセージ キューに入れることができます (redis の代わりに RabbitMQ キューを使用することをお勧めします) RabbitMQ はメッセージが 100% 消費されることを保証できますが、redis は比較的安定性と信頼性に劣ります)

//此处代码省略
//根据自己的业务场景看看是入数据库还是放入rabbitMQ消息队列中消费

今度は、ab ツールを使用して、高い同時実行 (リクエスト 2000、同時実行 100) でのクーポン取得動作をシミュレートします

ab -n 2000 -c 100 www.test.com/

次に、Redis Desktop Manager を使用して Redis の結果を表示します

同様に、couponOrder キューにはユーザー uid とクーポン ID を含む情報がすでに 10 件あります。この情報はキュー Consumption で使用できます。 。

#同時に、10 人のユーザーの UID 情報もユーザー クーポン コレクションに保存されます。

以上がRedis リンク リストを使用して、同時実行性の高い過剰販売製品の問題を解決する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。