설명

• 상품주문 EPIC

Redis

• Redis 분산락 구현
• Reds 환경 구성

서비스

• DB Reactive Spring Data 구현
• Orders GET, POST METHOD 개발
• 작성한 코드 분석해서 공부
• 분산락을 획득 후, DB 에 데이터를 저장한다.
• 상품 테이블에 재고를 (-) 한다.
• USER, 상품 ID 를 맵핑하는 History 를 저장한다.
• DB 작업이 끝나면 분산락 Release
• 위에 작성한 코드 모두가 비동기인지 체크

개발

• Orders GET, POST METHOD 개발
• 작성한 코드 분석해서 공부
• 분산락을 획득 후, DB 에 데이터를 저장한다.
• 상품 테이블에 재고를 (-) 한다.
• USER, 상품 ID 를 맵핑하는 History 를 저장한다.
• DB 작업이 끝나면 분산락 Release
• 위에 작성한 코드 모두가 비동기인지 체크

docker-compose 이용해서 Redis 환경 세팅

상품주문 했는데 getAllOrders quantity 가 0으로 나오는 현상

개요

• 상품 데이터 미리 만들어놓기
• 동시성 요청 시, 재고만큼 User, Product Mapping 이 생겼는지 체크

초기 데이터 적재 방법

• src/main/resources 에 schema.sql 파일과 data.sql 파일을 만든다.

sql source

-- schema.sql
CREATE TABLE product (
    id INT PRIMARY KEY,
    name VARCHAR(100),
    stock INT
);


-- data.sql
INSERT INTO product (id, name, stock) VALUES (1, 'MacBook', 1000);
INSERT INTO product (id, name, stock) VALUES (2, 'IPhone', 2000);

테스트

• 주문 시, 재고 관리랑 상품주문 테이블에 데이터 적재 여부 확인
• 주문 시, 재고 보다 구매 수량을 초과해서 주문할 시, 예외 확인
• 재고 100 , 구매 수량 1000으로 주문 시, product 은 예외가 발생하는데 product_order 는 데이터가 쌓이네?

할일

• redis client lettuce -> redisson 교체
• 링크 를 보면 redisson 이 나은거 같음

• 서비스 layer return 을 dto 로 변환. Mono, Flux 로 안해도 될거 같음
• 이렇게 생각했는데 막상 예제 소스를 보니 service layer return 값이 Mono, Flux 네

개요

• SETNX 를 통해 KEY 를 저장한 후, DEL 명령어를 통해 락을 해제한다.
• 2개의 명령어는 원자성을 보장하는 명령어이다.

할일

• 패키지 위치를 어떻게 잡아야지?
• 어느 부분에 annotation 을 걸어야 하나?
• 테스트는 어떻게 하지?

source

@Component
class DistributedLock(
    private val reactiveRedisTemplate: ReactiveRedisTemplate<String, String>,
    @Value("\${redis.lock.timeout}") private val timeout: Long
) {
    fun acquireLock(key: String): Mono<Boolean> {
        // Redis의 SETNX 명령어를 사용하여 락을 획득합니다. (원자성 보장)
        // key : 저장할 키, "" : 저장 value, timeout : TTL 
        return reactiveRedisTemplate.opsForValue().setIfAbsent(key, "", Duration.ofMillis(timeout))
    }
    fun releaseLock(key: String): Mono<Boolean> {
        // Redis의 DEL 명령어를 사용하여 락을 해제합니다. (원자성 보장)
        return reactiveRedisTemplate.delete(key)
    }
}

할일

• 분산락 내가 제대로 개발했는지 검토
• 분산락 공통 annotation 으로 처리 - aop 이용해서
• 분산락 잡을 때, key 상수로 처리

• 상품 주문 시, 재고 관리 로직 추가

할일

• 테스트 시나리오 생각해보기
• 현재 schema.sql 에 아래와 같이 데이터가 들어있음
• k6 시나리오 작성할 때, product1001 ~ 1005 까지 10개씩 주문하도록 하기
• 그런 뒤, order(주문) 테이블에는 150개의 count 가 맞는지 확인
• product 테이블에는 재고가 0인지 확인

  ('product1001', 'Product A', 100),
  ('product1002', 'Product B', 200),
  ('product1003', 'Product C', 300),
  ('product1004', 'Product D', 400),
  ('product1005', 'Product E', 500);

• k6 테스트 돌렸을 때, 동시성 문제 안생기는지 체크

초기 프로젝트 세팅

• redis 세팅
• docker 세팅
• webflux 세팅

상품 주문 후, product 데이터 getAllOrders api 작성

-> h2 접근해서 데이터 확인으로 대체