🧑🏻‍💻 Lettuce 란?

<aside> 💡 고성능, 확장 가능, 스레드 안전한 레디스 자바 클라이언트

</aside>

• Spring-data-redis에서는 Lettuce가 기본 제공 방식
• sentx 메서드를 통해 사용자가 직접 스핀락 형태를 구성
• Lock이 점유 시도를 실패시, 계속 Lock 점유를 시도 ⇒ Redis에 부하 발생
• 만료시간을 제공하고 있지 않기 때문에 Lock을 잡고 있는 상태에서 장애 발생시 다른 서버들에서는 Lock을 점유할 수 없음

Lettuce 진행

Lettuce 전체 코드

1. Redis를 위한 implementation을 추가

   //Redis
   implementation 'org.springframework.boot:spring-boot-starter-data-redis'
   

2. 부모 트랜잭션과 자식 트랜잭션을 따로 작성한다.

   //부모 트랜잭션
   @Transactional
   public void stockLock(String pgToken, Long memberId){
       String redisLockKey = orderProductWithLettuceLock(pgToken, memberId);
       redisRepository.unlock(redisLockKey);
   }
   

   //자식트랜잭션
       @Transactional(propagation = Propagation.REQUIRES_NEW)
       public String orderProductWithLettuceLock(String pgToken, Long memberId) {
   		' ' ' ' '
   
           //Lettuce Lock
           String redisLockKey = REDIS_LOCK_KEY_PREFIX + productId;
           while (!redisRepository.lock(redisLockKey)) {
               try {
                   Thread.sleep(500);
               } catch (InterruptedException e) {
                   throw new RuntimeException(e);
               }
           }
   
           Product product = productRepository.findById(Long.valueOf(productId))
               .orElseThrow(() -> new ProductNotFoundException(ErrorCode.PRODUCT_NOT_FOUND));
   
           if (product.getStock() == 0) {
               throw new ProductOutOfStockException(ErrorCode.PRODUCT_OUT_OF_STOCK);
           }
   
   // 결제 승인 요청 api
   //     kaKaoPaymentService.payInfo(pgToken, memberId, Long.valueOf(productId), tid);  
           product.saleProduct();
           paymentHistoryRepository.save(paymentHistory);
           return redisLockKey;
       }
   

🚀 트러블 슈팅

1. 불필요한 로직 수행 방어

• lock이 걸리지 않은 최초의 Thread가 는 product는 재고가 0이 아니다.
• 하지만, 최초의 Thread가 성공하여 재고가 감소되면, 그 다음 Thread는 결제 승인 요청 api로 가지 않고 exception으로 처리하는 것이 불필요한 작업을 막는 방법이다.

Product product = productRepository.findById(Long.valueOf(productId))
        .orElseThrow(() -> new ProductNotFoundException(ErrorCode.PRODUCT_NOT_FOUND));

    if (product.getStock() == 0) {
        throw new ProductOutOfStockException(ErrorCode.PRODUCT_OUT_OF_STOCK);
  }

2. 부모-자식 트랜잭션으로 분리

• 서비스 코드에서 @Transactional 어노테이션을 붙이면, 기본적으로 propagation type이 REQUIRED이다.

• 현재 lettuce 서비스 코드에서는 부모트랜잭션이 REQUIRED , 자식 트랜잭션이 REQUIRES_NEW 이다.

  • 부모트랜잭션과 자식 트랜잭션이 각자 새로운 트랜잭션을 만든다.
  • 부모 → 자식 → 부모 순으로 진행
    • Lock을 획득한 최초의 자식 트랜잭션이 재고를 감소시킨 후 redisKey와 같이 부모 트랜잭션으로 이동
    • 부모트랜잭션에서는 해당 redisKey에 해당하는 lock을 unlock한다.
  • 불필요한 로직 수행 방어를 해둔 덕분에, 최초 이후의 트랜잭션은 자식 메소드에 들어와서도 exception으로 걸러진다.

  

  출처 : https://deveric.tistory.com/86