데이터 통합 조회 방법 설계

📌 문제

• MSA에서는 각 서비스가 독립적으로 DB를 관리하기 때문에, 한 서비스에서 다른 서비스의 데이터를 직접적으로 조회할 수 없다.
• 예를 들어, 주문 목록을 조회할 때, 주문 아이템정보 제공을 위해 상품 정보를 JOIN으로 가져오지 못 하고 주문 아이템 마다 상품 서비스에 요청을 보내야 한다.
• 이 과정에서 여러 번의 API 호출이 발생하기에 성능 저하 우려가 있었다.

 

📌 방법 비교

✅ 1. 주문 아이템마다 상품 API 호출

주문 1개 → 주문 아이템1개 마다 상품 서비스 API를 호출하여 상품 정보를 받아오고 이를 합친다.

✔ 장점

• 간단하고 직관적인 방식

❌ 단점

• 주문마다 상품 정보를 별도로 API 호출하기 때문에 네트워크 요청이 많아져 성능이 저하될 수 있음.

 

✅ 2. 캐시(redis)를 이용해 주문 정보 저장

주문 + 상품 정보를 결합하여 캐시에 저장하고, 조회 시에는 캐시에서 바로 조회한다.

주문 생성 시 캐시 생성하여 각 서비스(주문, 상품, 배송, 결제 등)에서 업데이트.

✔ 장점

• 조회 시 데이터 합하는 로직(for문 사용)이 필요 없고 빠른 속도로 응답 가능.

❌ 단점

• 주문 목록은 동적으로 바뀔 수 있기 때문에, 주문이 자주 변경되는 경우 캐시 관리가 복잡해질 수 있다.
• 주문 목록은 사용자별로 저장해야 하므로, 사용자의 주문 정보를 캐시에 별도로 관리해야 한다. ➡️ 메모리 소모가 커지고, 사용자 개인정보 관리 위험이 있다.

 

✅ 3. 캐시(redis)에 상품 정보만 저장, 주문 조회 시 캐시 조회

상품 정보를 미리 캐싱(상품 생성/수정 시)하고, 주문 목록 조회 시 먼저 캐시를 조회한 후, 캐시에 없으면 상품 API를 호출(이때, 상품서비스는 상품 정보를 리턴 & 상품 정보 캐싱)

✔ 장점

• 주문 목록 조회 시 상품 정보를 빠르게 가져오며, 캐시가 없는 경우에만 외부 API 호출을 하므로 불필요한 API 호출을 줄일 수 있음.
• 여전히 반복문 사용하여 합성하는 과정이 필요하지만 인메모리 캐시는 조회 속도 자체가 빠르기 때문에 성능 부담이 덜함.

❌ 단점

• 상품 정보가 캐시에 없으면 API 호출이 발생할 수 있지만, 캐시 갱신 주기를 설정하여 성능을 보장할 수 있음.

 

📌 채택한 방법

세 번째 방법을 채택하여, 상품 정보를 캐시(Redis)로 관리하고, 주문 목록 조회 시 먼저 캐시를 조회한 후, 캐시에 없으면 상품 API를 호출하는 방식입니다.

// 고객 주문 목록 조회 (주문 + 상품 정보)
public List<OrderSummary> getCustomerOrders(OrderListRequest request) {
    List<OrderSummary> orderSummaries = new ArrayList<>(); // 응답 DTO

    // 1. 주문 DB에서 유저 주문 목록 조회
    List<Orders> orders = orderRepository.findOrdersByRequest(request);
    for (Orders order : orders) {
        OrderSummary orderSummary = new OrderSummary();
        orderSummary = objectMapper.convertValue(order, OrderSummary.class);

        // 2. 주문 상품별 상품 정보 세팅
        List<OrderItemDetail> orderItemDetails = new ArrayList<>();
        for (OrderItems orderItem : order.getOrderItems()) {
            OrderItemDetail orderItemDetail = objectMapper.convertValue(orderItem, OrderItemDetail.class);

            // 상품 캐시 조회
            CachedProduct cachedProduct = getCachedProduct(orderItem.getProductId());

            // 캐시에서 조회된 상품 정보를 주문 아이템에 매핑
            OrderItemDetail.OrderedProductInfo orderedProductInfo = mapToOrderedProductInfo(cachedProduct, orderItem.getColorId(), orderItem.getSizeId());

            orderedProductInfo.setPrice(orderItem.getPrice()); // 결제 당시 가격!!
            orderItemDetail.setOrderedProductInfo(orderedProductInfo);
            orderItemDetails.add(orderItemDetail);
        }

        orderSummary.setOrderItemDetails(orderItemDetails);
        orderSummaries.add(orderSummary);
    }

    return orderSummaries;
}

// 상품 서비스 API 호출 (FeignClient 사용)
private CachedProduct getCachedProduct(int productId) {
    CachedProduct cachedProduct = new CachedProduct();

    // 1. 캐시에서 상품 정보 조회
    cachedProduct = cacheService.getOrderedProductInfo(productId);

    // 2. 캐시에서 상품 정보가 없으면 상품 서비스 API에 요청
    // 상품 서비스에서 캐시에 저장하고 CachedProduct 형태로 리턴한다.
    if (cachedProduct == null) {
        cachedProduct = productClient.getProductForCache(productId);
    }
    return cachedProduct;
}