Redis 쿠폰 플래시 세일 문제를 해결하는 방법

1 쿠폰 플래시 세일 기능을 구현하려면

주문 시 두 가지 사항을 판단해야 합니다. 1. 플래시 세일의 시작 또는 종료 여부 2. 재고가 충분한지 여부

그래서 우리의 비즈니스 로직은 다음과 같습니다.

1.쿠폰ID를 통해 획득 쿠폰정보

2.플래시 세일 시작 여부 확인, 오류 메시지가 반환되지 않으면

3. 플래시 세일 종료 여부 확인, 종료된 경우 오류 메시지 반환

4. 재고가 충분한지 판단합니다

5. 충분하다면 재고를 차감합니다

6. 주문 정보를 생성하고 쿠폰 주문 테이블에 저장합니다

6.1 주문 ID 저장

6.2 사용자 ID 저장

6.3 쿠폰 ID 저장

7. 반품 주문 ID

코드 구현: (서비스 레이어 구현 클래스)

package com.hmdp.service.impl;
import com.hmdp.dto.Result;
import com.hmdp.entity.SeckillVoucher;
import com.hmdp.entity.VoucherOrder;
import com.hmdp.mapper.VoucherOrderMapper;
import com.hmdp.service.ISeckillVoucherService;
import com.hmdp.service.IVoucherOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hmdp.utils.RedisIdWorker;
import com.hmdp.utils.UserHolder;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDateTime;
/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author 虎哥
 * @since 2021-12-22
 */
@Service
public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {
    @Resource
    private ISeckillVoucherService iSeckillVoucherService;
    @Resource
    private RedisIdWorker redisIdWorker;
    @Override
    public Result seckillVoucher(Long voucherId) {
        //1.获取优惠券信息
        SeckillVoucher voucher = iSeckillVoucherService.getById(voucherId);
        //2.判断是否已经开始
        if (voucher.getBeginTime().isAfter(LocalDateTime.now())){
            Result.fail("秒杀尚未开始!");
        }
        //3.判断是否已经结束
        if (voucher.getEndTime().isBefore(LocalDateTime.now())){
            Result.fail("秒杀已经结束了!");
        }
        //4.判断库存是否充足
        if (voucher.getStock() < 1) {
            Result.fail("库存不充足!");
        }
        //5.扣减库存
        boolean success = iSeckillVoucherService.update()
                .setSql("stock = stock-1").eq("voucher_id",voucherId)
                .update();
        if (!success){
            Result.fail("库存不充足!");
        }
        //6. 创建订单
        VoucherOrder voucherOrder = new VoucherOrder();
        //6.1添加订单id
        Long orderId = redisIdWorker.nextId("order");
        voucherOrder.setId(orderId);
        //6.2添加用户id
        Long userId = UserHolder.getUser().getId();
        voucherOrder.setUserId(userId);
        //6.3添加优惠券id
        voucherOrder.setVoucherId(voucherId);
        save(voucherOrder);
        //7.返回订单id
        return Result.ok(orderId);
    }
}

2 과판매 문제(핵심)

먼저 실행해 보겠습니다. 위의 코드는 동시성이 높습니다. (jmx 툴 사용)

아래 사진은 200개의 스레드가 생성되어 순식간에 쿠폰요청이 발생한 모습입니다

그런데 집계보고서를 보면 비정상적인 값이 45.5%에 불과한 것을 알 수 있습니다. , 논리적으로 50%여야 합니다. (재고가 100개라서 여기로 요청이 200개 왔습니다.)

재고번호로 보면 -9

주문량도 있습니다. 109개 단위에 추가되어 분명히 과매도 문제가 발생했습니다.

그럼 왜 이런 문제가 발생하는 걸까요?

사진을 보고 대화하세요.

일반적인 프로세스를 따르십시오. 즉, 스레드 1이 재고를 확인한 후 재고를 차감합니다. 이때 스레드 2는 재고를 다시 확인하고 재고를 차감합니다. 문제.

과매도의 문제는 1번 주문 후 재고 확인을 해보니 1이었는데, 차감이 이루어지기 전에 2번 쓰레드도 재고를 확인해보니 역시 1이더군요. 공제가 이루어졌습니다(동시성이 높은 시나리오에서)

이로 인해 과매도 문제가 발생합니다.

이런 종류의 높은 동시성 문제에 대한 가장 일반적인 해결책은 다음과 같습니다. 잠금~

하지만 잠금에는 비관적 잠금과 낙관적 잠금이 포함됩니다.

비관적 잠금은 간단히 말해서 스레드가 반드시 발생할 것이라고 생각하고 작업이 완료되면 다음 스레드가 실행할 차례입니다(직렬 실행).

낙관적 잠금: 낙관적입니다. (스레드 안전성은 결코 발생하지 않을 것이라고 생각됩니다.) 각 데이터를 수정하기 전에는 스레드 안전성을 보장하기 위해 다른 스레드가 데이터를 수정했는지 여부를 판단합니다.

비관적 잠금은 상대적으로 간단하고 낙관적 잠금은 여기서 구현됩니다.

낙관적 잠금의 핵심은 이전 쿼리에서 얻은 데이터가 수정되었는지 확인하는 것입니다. 두 가지 일반적인 방법이 있습니다.

주의 사항: 왼쪽 테이블의 데이터는 모두 스레드 1 실행 후의 데이터입니다. ~

1. 버전번호

방식은 데이터를 수정할 때마다 버전번호 + 1을 추가하고 마지막에 where 조건을 추가하여 버전을 조회하는 단계입니다. 버전 번호는 수정 전 버전과 일치합니다

이렇게 하면 스레드 안전성을 얻을 수 있습니다~

2.CAS 방식

인벤토리 여부를 확인하기 위해 데이터베이스를 수정한 후 버전 번호를 직접 추가할 필요가 없습니다. 는 수정 전 재고입니다

과매도 문제를 해결하기 위한 코드 구현:

최종 분석에서 재고를 차감할 때 재고가 0

//5.1扣减库存
boolean success = iSeckillVoucherService.update()
.setSql("stock = stock-1").eq("voucher_id" , voucherId).gt("stock" ,0)
.update();

package com.hmdp.service.impl;
import com.hmdp.dto.Result;
import com.hmdp.entity.SeckillVoucher;
import com.hmdp.entity.VoucherOrder;
import com.hmdp.mapper.VoucherOrderMapper;
import com.hmdp.service.ISeckillVoucherService;
import com.hmdp.service.IVoucherOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hmdp.utils.RedisIdWorker;
import com.hmdp.utils.UserHolder;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDateTime;
/**
 * <p>
 *  服务实现类
 * </p>
 */
@Service
public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {
    @Resource
    private ISeckillVoucherService iSeckillVoucherService;
    @Resource
    private RedisIdWorker redisIdWorker;
    @Override
    public Result seckillVoucher(Long voucherId) {
        //1.获取优惠券信息
        SeckillVoucher voucher = iSeckillVoucherService.getById(voucherId);
        //2.判断是否已经开始
        if (voucher.getBeginTime().isAfter(LocalDateTime.now())){
            Result.fail("秒杀尚未开始!");
        }
        //3.判断是否已经结束
        if (voucher.getEndTime().isBefore(LocalDateTime.now())){
            Result.fail("秒杀已经结束了!");
        }
        //4.判断库存是否充足
        if (voucher.getStock() < 1) {
            Result.fail("库存不充足!");
        }
        //5.扣减库存
        boolean success = iSeckillVoucherService.update()
                .setSql("stock = stock-1").eq("voucher_id",voucherId).gt("stock",0)
                .update();
        if (!success){
            Result.fail("库存不充足!");
        }
        //6. 创建订单
        VoucherOrder voucherOrder = new VoucherOrder();
        //6.1添加订单id
        Long orderId = redisIdWorker.nextId("order");
        voucherOrder.setId(orderId);
        //6.2添加用户id
        Long userId = UserHolder.getUser().getId();
        voucherOrder.setUserId(userId);
        //6.3添加优惠券id
        voucherOrder.setVoucherId(voucherId);
        save(voucherOrder);
        //7.返回订单id
        return Result.ok(orderId);
    }
}

보다 큰지 확인하기 위해 where 조건을 추가합니다.

위 내용은 Redis 쿠폰 플래시 세일 문제를 해결하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!