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분 동안 쿠폰을 공개한다고 규정한 경우 다음을 통해 링크된 목록에 대한 유효 기간을 설정하십시오. 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 &#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가 메시지를 100% 소비하도록 보장할 수 있는 반면 redis는 상대적으로 안정성과 신뢰성이 떨어집니다.)

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

이제 ab 도구를 사용하여 높은 동시성(요청 2000개, 동시성 100개)에서 쿠폰 가져오기 동작을 시뮬레이션합니다

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

그런 다음 Redis Desktop Manager를 사용하여 Redis 결과를 봅니다

마찬가지로 쿠폰 주문 대기열에는 이미 사용자 uid와 쿠폰 ID를 포함하는 10개의 정보가 있으며 대기열에서 사용할 수 있습니다.

동시에 사용자 10명의 UID 정보도 사용자 쿠폰 컬렉션에 저장됩니다.

위 내용은 Redis 연결 목록을 사용하여 동시성이 높은 제품 과매출 문제를 해결하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!