Redis 분산 캐시 및 플래시 판매 구현 방법

녹음 명령이기 때문에 AOF 파일은 RDB 파일보다 용량이 훨씬 커집니다. AOF는 동일한 키에 여러 쓰기 작업을 기록하지만 그중 마지막 쓰기 작업만 의미가 있습니다. bgrewriteaof 명령을 사용하면 최소한의 명령으로 AOF 파일 다시 쓰기 기능을 완료할 수 있습니다.

set id 1
set name nezha
set id 2

bgrewriteaof

mset name nezha id 2

Redis는 임계값이 트리거되면 자동으로 AOF 파일을 다시 작성합니다. 임계값은 redis.conf에서도 구성할 수 있습니다:

# 마지막 파일과 비교하여 AOF 파일이 증가하는 백분율은 다시 쓰기를 트리거합니다 auto-aof-rewrite-percentage 100# AOF 파일의 최소 크기는 자동 다시 쓰기를 트리거합니다 aof.-rewrite-min-size 64mb

RDB와 AOF는 각각 장단점이 있습니다. 데이터 보안 요구 사항이 높을 경우 실제 개발에서는 함께 사용되는 경우가 많습니다.

4. Redis 최적화 플래시 세일 과정

1. 플래시 세일 단계:

1. 플래시 세일 제품 재고 확인

2. 각 사람 주문 확인;

   재고를 줄입니다.

3. 주문 생성

5. 2. Redis 최적화 플래시 판매 단계:

6. 플래시 세일 쿠폰을 추가하고 쿠폰 정보를 Redis에 저장합니다. 플래시 세일 제품의 재고, 한 사람이 하나를 주문하고 사용자의 플래시 세일이 성공했는지 확인합니다.

플래시 세일이 성공하면 쿠폰 ID, 사용자 ID 및 제품 ID가 차단 대기열에 캡슐화됩니다.

비동기 작업을 활성화하고, 차단 대기열에서 정보를 지속적으로 읽고, 비동기 주문 기능을 구현합니다.

2. 3. 플래시 세일을 위한 Lua 스크립트

3. 4. 플래시 세일을 위한 Lua 스크립트 호출

   public Result seckillVoucher(Long voucherId) {
        Long userId = UserHolder.getUser().getId();
        long orderId = redisIdWorker.nextId("order");
        // 1.执行lua脚本
        Long result = stringRedisTemplate.execute(
                SECKILL_SCRIPT,
                Collections.emptyList(),
                voucherId.toString(), userId.toString(), String.valueOf(orderId)
        );
        int r = result.intValue();
        // 2.判断结果是否为0
        if (r != 0) {
            // 2.1.不为0 ，代表没有购买资格
            return Result.fail(r == 1 ? "库存不足" : "不能重复下单");
        }
        // 3.返回订单id
        return Result.ok(orderId);
    }

   로그인 후 복사
5. 스레드 풀을 통해 작업이 대기열을 차단합니다

4. // 线程池
   private static final ExecutorService SECKILL_ORDER_EXECUTOR = Executors.newSingleThreadExecutor();
   
   /**
   * 在类初始化完成后执行
   */
   @PostConstruct
   private void init() {
       SECKILL_ORDER_EXECUTOR.submit(new VoucherOrderHandler());
   }
   
   // 阻塞队列
   private BlockingQueue<VoucherOrder> orderTasks = new ArrayBlockingQueue<>(1024 * 1024);
   private class OrderHandler implements Runnable{
   
       @Override
       public void run() {
           while (true){
               try {
                   doSomething();
               } catch (Exception e) {
                   log.error("处理订单异常", e);
               }
           }
       }
   }

   로그인 후 복사

   5. Redis 기반 공유 세션 로그인

세션 기반 로그인

Redis 기반 공유 세션 로그인

public class RefreshTokenInterceptor implements HandlerInterceptor {

    private StringRedisTemplate stringRedisTemplate;

    public RefreshTokenInterceptor(StringRedisTemplate stringRedisTemplate) {
        this.stringRedisTemplate = stringRedisTemplate;
    }

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 1、获取请求头中的token
        String token = request.getHeader("authorization");
        if (StrUtil.isBlank(token)) {
            return true;
        }
        // 2、基于TOKEN获取redis中的用户
        String key  = LOGIN_USER_KEY + token;
        Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(key);
        // 3、判断用户是否存在
        if (userMap.isEmpty()) {
            return true;
        }
        // 5、将查询到的hash数据转为UserDTO
        UserDTO userDTO = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);
        // 6、存在，保存用户信息到 ThreadLocal
        UserHolder.saveUser(userDTO);
        // 7、刷新token有效期
        stringRedisTemplate.expire(key, LOGIN_USER_TTL, TimeUnit.MINUTES);
        // 8、放行
        return true;
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        // 移除用户
        UserHolder.removeUser();
    }
}