Redis에서 플래시 세일 시스템을 구현하는 방법

1. 디자인 아이디어

플래시 킬링 시스템은 1초에 수만 건의 요청이 들어올 수 있다는 특징이 있습니다. 어떤 조치를 취하지 않으면 시스템이 몇 분 안에 무너질 수 있습니다. 플레이할 수 있는 플래시 킬 시스템을 설계하는 방법에 대해 논의해 보겠습니다.

1. 현재 제한:

우선, 비즈니스 로직에 관계없이 다음과 같은 가장 간단한 인터페이스가 있는 경우:

@GetMapping("/test")
public String test() {
 return "success";
}

이 인터페이스는 매우 간단하고 로직이 없지만, 동시에 서버도 충돌할 것입니다. 따라서 동시성이 높은 시스템이 가장 먼저 해야 할 일은 전류 흐름을 제한하는 것입니다. Springcloud 프로젝트는 전류 제한을 위해 hystrix를 사용할 수 있고, springcloud alibaba는 전류 제한을 위해 sentinel을 사용할 수 있습니다. springcloud가 아닌 프로젝트는 어떻습니까? Guava는 전류를 제한할 수 있는 RateLimiter 도구 클래스를 제공합니다. 주로 Leaky Bucket 알고리즘과 Token Bucket 알고리즘이 포함됩니다.

• 물통 새기 알고리즘: 구멍이 있는 물통에 수도꼭지 아래에 물이 채워져 있습니다. 하지만 수도꼭지의 물이 너무 많으면 조만간 물통에 담긴 물이 넘치게 됩니다. 오버플로가 제한됩니다. 이는 업로드 및 다운로드 속도를 제한하는 데 적합합니다.

• 토큰 버킷 알고리즘: 요청이 들어올 때마다 먼저 버킷에서 토큰을 가져와야 합니다. 토큰을 얻지 못하면 요청이 차단됩니다. 이는 전류 제한, 즉 QPS 제한에 적합합니다.

여기에서는 토큰 버킷 알고리즘을 사용하여 흐름을 제한해야 합니다. 토큰을 얻지 못한 경우 "너무 많은 사람이 들어갈 수 없습니다"라는 메시지가 직접 반환됩니다.

2. 사용자가 로그인되어 있는지 확인:

흐름 제한의 첫 번째 단계 후에 들어오는 요청은 사용자가 로그인되어 있는지 확인해야 합니다. 이 프로젝트는 JWT를 사용합니다. 즉, 먼저 로그인 인터페이스를 요청하고 토큰을 반환합니다. 로그인 후 다른 모든 인터페이스를 요청하면 요청 헤더에 토큰을 가져오고 토큰을 통해 사용자 정보를 얻을 수 있습니다. 사용자 정보를 얻지 못한 경우 사용자에게 다시 로그인하라는 메시지가 표시됩니다. 토큰이 잘못되었습니다.

3. 상품 품절 여부 확인:

처음 두 단계의 인증을 통과한 경우 상품이 품절되었는지 확인해야 합니다. 품절된 경우 "죄송합니다. 상품이 있습니다. 매진되었습니다'라는 메시지가 반환됩니다. 제품이 매진되었는지 확인하기 위해 데이터베이스를 확인할 수는 없습니다. 그렇지 않으면 매우 느려질 것입니다. 제품 ID를 키로 사용하여 사전을 사용하여 제품 ID를 저장할 수 있습니다. 항목이 매진된 경우 해당 값을 True로 설정하고, 그렇지 않으면 False로 설정합니다.

4. 플래시 세일에 참여하는 제품을 redis에 추가합니다.

먼저 ISINREDIS的key，表示商品是否已经加到redis中了，避免每个请求进来都重复此操作。如果ISINREDIS值为false，表示redis中还没有秒杀商品。那么就查询出所有参加秒杀的商品，商品id作为key，商品库存作为value，存到redis中，同时将商品id作为key，false作为value，放到第三步的map中，表示该商品没有售完。最后将ISINREDIS 값을 true로 설정합니다. 이는 플래시 세일에 참여하는 모든 제품이 Redis에 추가되었음을 의미합니다.

5. 재고 보류:

redis의 감소 기능을 사용하여 상품 수량을 줄이고 감소된 가치를 판단합니다. 자체 감소 후 결과가 0 미만인 경우 해당 상품이 매진되었음을 의미하며, 맵의 해당 상품 ID 값이 true로 설정되고 "늦었어요. 상품이 판매되었습니다"라는 메시지가 표시됩니다. 매진'이라는 메시지가 반환됩니다.

6. 플래시 세일이 반복되는지 확인:

사용자의 플래시 세일이 성공하면 플래시 세일 주문이 데이터베이스에 저장된 후 사용자 ID와 제품 ID가 키로 사용되며 true가 저장됩니다. redis에서는 사용자가 이미 제품을 플래시했음을 나타냅니다. 따라서 여기서는 사용자 ID와 제품 ID를 기반으로 redis로 이동하여 플래시 세일이 반복되는지 확인합니다. 그렇다면 "플래시 세일을 반복하지 마십시오"라는 프롬프트가 반환됩니다.

7. 비동기 처리:

위 검증을 통과하면 플래시 세일이 처리될 수 있습니다. 플래시 판매 요청이 있을 때마다 재고를 공제하고 주문을 생성하면 속도가 매우 느려질 뿐만 아니라 데이터베이스 충돌이 발생할 수도 있습니다. 따라서 비동기식으로 처리할 수 있습니다. 즉, 위의 확인을 통과한 후 사용자 ID와 제품 ID가 메시지로 MQ에 전송되고 "대기열" 프롬프트가 사용자에게 즉시 반환됩니다. 그런 다음 MQ의 소비자 측에서 메시지를 사용하고, 사용자 ID와 제품 ID를 가져오고, 제품 ID를 기반으로 재고를 쿼리하여 충분한 재고를 다시 확인한 다음 반짝 세일을 반복할지 여부도 결정할 수 있습니다. 판정 통과 후 데이터베이스를 운영하고, 재고를 차감하고, 플래시 판매 주문을 생성합니다. 재고 공제와 깜짝 판매 주문 생성은 동일한 거래에 있어야 합니다.

8. 과매도 문제:

과매도 문제는 상품의 마이너스 재고입니다. 예를 들어 재고가 1이라면 10명의 사용자가 동시에 즉시 판매하게 되며, 재고를 판단하면 모두 1이므로 10명이 성공적으로 주문할 수 있으며 최종 재고는 -9가 됩니다. 어떻게 해결하나요? 사실 이 시스템에서는 이런 문제가 전혀 발생하지 않을 것이다. 왜냐하면 초기에 redis를 사용하여 사전에 재고를 줄이는데 사용하고, redis 명령 코어 모듈은 싱글 쓰레드로 되어 있어서 과매도가 되지 않는다는 것을 보장할 수 있기 때문이다. Redis를 사용하지 않는 경우 제품에 버전 필드를 추가할 수도 있습니다. 매번 인벤토리를 공제하기 전에 버전을 확인하기 위해 SQL에 조건을 추가하세요. 즉, 버전이 방금 찾은 버전과 동일해야 합니다.

 

二、核心代码

@RestController
@RequestMapping("/seckill")
public class SeckillController {
 
 @Autowired
 private UserService userService;
 @Autowired
 private SeckillService seckillService;
 @Autowired
 private RabbitMqSender mqSender;
 
 // 用来标记商品是否已经加入到redis中的key
 private static final String ISINREDIS = "isInRedis";
 
 // 用goodsId作为key，标记该商品是否已经卖完
 private Map<integer> seckillOver = new HashMap<integer>();
 
 // 用RateLimiter做限流，create(10)，可以理解为QPS阈值为10
 private RateLimiter rateLimiter = RateLimiter.create(10);
 
 @PostMapping("/{sgId}")
 public JsonResult> seckillGoods(@PathVariable("sgId") Integer sgId, HttpServletRequest httpServletRequest){
  
  // 1. 如果QPS阈值超过10，即1秒钟内没有拿到令牌，就返回“人太多了，挤不进去”的提示
  if (!rateLimiter.tryAcquire(1, TimeUnit.SECONDS)) {
   return new JsonResult(SeckillGoodsEnum.TRY_AGAIN.getCode(), SeckillGoodsEnum.TRY_AGAIN.getMessage());
  }
  
  // 2. 检查用户是否登录（用户登录后，访问每个接口都应该在请求头带上token，根据token再去拿user）
  String token = httpServletRequest.getHeader("token");
  String userId = JWT.decode(token).getAudience().get(0);
  User user = userService.findUserById(Integer.valueOf(userId));
  if (user == null) {
   return new JsonResult(SeckillGoodsEnum.INVALID_TOKEN.getCode(), SeckillGoodsEnum.INVALID_TOKEN.getMessage());
  }
  
  // 3. 如果商品已经秒杀完了，就不执行下面的逻辑，直接返回商品已秒杀完的提示
  if (!seckillOver.isEmpty() && seckillOver.get(sgId)) {
   return new JsonResult(SeckillGoodsEnum.SECKILL_OVER.getCode(), SeckillGoodsEnum.SECKILL_OVER.getMessage());
  }
  
  // 4. 将所有参加秒杀的商品信息加入到redis中
  if (!RedisUtil.isExist(ISINREDIS)) {
   List<seckillgoods> goods = seckillService.getAllSeckillGoods();
   for (SeckillGoods seckillGoods : goods) {
    RedisUtil.set(String.valueOf(seckillGoods.getSgId()), seckillGoods.getSgSeckillNum());
    seckillOver.put(seckillGoods.getSgId(), false);
   }
   RedisUtil.set(ISINREDIS, true);
  }
  
  // 5. 先自减，预扣库存，判断预扣后库存是否小于0，如果是，表示秒杀完了
  Long stock = RedisUtil.decr(String.valueOf(sgId));
  if (stock (SeckillGoodsEnum.SECKILL_OVER.getCode(), SeckillGoodsEnum.SECKILL_OVER.getMessage());
  }
  
  // 6. 判断是否重复秒杀（成功秒杀并创建订单后，会将userId和goodsId作为key放到redis中）
  if (RedisUtil.isExist(userId + sgId)) {
   return new JsonResult(SeckillGoodsEnum.REPEAT_SECKILL.getCode(), SeckillGoodsEnum.REPEAT_SECKILL.getMessage());
  }
  
  // 7. 以上校验都通过了，就将当前请求加入到MQ中，然后返回“排队中”的提示
  String msg = userId + "," + sgId;
  mqSender.send(msg);
  return new JsonResult(SeckillGoodsEnum.LINE_UP.getCode(), SeckillGoodsEnum.LINE_UP.getMessage());
 }

}
</seckillgoods></integer></integer>

     

三、压测

用jmeter模拟并发请求，测试高并发情况下系统能否扛得住。由于只有一个id为1的商品，所以商品id固定写死1。但是每个用户都要先请求登录接口获取到token才能进行秒杀请求，有点儿麻烦，所以可以先把jwt模块注释掉，把userId当成参数传进去。jmeter配置如下图：

jmeter压测配置

jmeter压测配置

위 내용은 Redis에서 플래시 세일 시스템을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!