Redis 트랜잭션 대신 Redisson 분산락을 활용하여 재고 감소 로직 구현

[daadaadaah]

Why

• 다음 작업을 묶어서 처리해야 됩니다. 즉, 1번째 명령어 실행 결과에 따라 2번째 명령어 실행 여부가 결정이 되는데,

int inventoryAfterDecrease = inventoryCommandRepository.decreaseByAmount(dealProductUuid, orderQuantity); // 1번째 명령어

int inventoryBeforeDecrease = orderQuantity + inventoryAfterDecrease;

if (inventoryBeforeDecrease > 0 && inventoryBeforeDecrease < orderQuantity && outOfStockHandlingOption == OutOfStockHandlingOption.PARTIAL_ORDER) {
    inventoryCommandRepository.set(dealProductUuid, 0); // 2번째 명령어
}

• 이를 트랜잭션으로 처리하게 되면, 제가 의도한 대로 1번째 명령어 실행 결과에 따라 2번째 명령어 실행 여부가 결정을 할 수 없습니다.
• 왜냐하면, Redis의 트랜잭션은 1번째 명령어와 2번째 명령어를 queue에 담겨 배치 처리되기 떄문입니다.

private int[] decreaseInventoryInAdvance(UUID dealProductUuid, int orderQuantity, OutOfStockHandlingOption outOfStockHandlingOption) {
        final int[] inventoryAfterDecrease = new int[1];

        redisTemplate.execute(new SessionCallback<List<Object>>() {
            @Override
            public List<Object> execute(RedisOperations operations) throws DataAccessException {
                try {
                    operations.multi();

                    inventoryAfterDecrease[0] = inventoryCommandRepository.decreaseByAmount(dealProductUuid, orderQuantity); // 1번째 명령어

                    int inventoryBeforeDecrease = orderQuantity + inventoryAfterDecrease[0];

                    if (inventoryBeforeDecrease < orderQuantity && outOfStockHandlingOption == OutOfStockHandlingOption.PARTIAL_ORDER) {
                        inventoryCommandRepository.set(dealProductUuid, 0);  // 2번째 명령어
                    }

                    return operations.exec(); 
                } catch (Exception e) {
                    operations.discard();
                    throw e;
                }
            }
        });

        return inventoryAfterDecrease;
    }

• 그래서, 여러 명령어를 원자성 있게 처리하는 동시에 명령어들이 배치로 처리되지 않고 개별 처리 될 수 있는 분산락을 사용했습니다.

Comment

• InventoryCommandRepository 추가 #56 (comment) 이때 재시도로직 코멘트 주셔서 재시도 로직도 포함시켰습니다.

[f-lab-TJ]

인벤토리 재고를 get해서 미리 확인하지 않는 이유가 있을까요? 재고가 0이 되어 있는 경우에는 decrease를 하면 안될것 같네요.