Feature/catalog caching (#20)

* feat: 상품 조회 결과를 캐시로 관리하는 서비스 로직 추가

* feat: 상품 조회하는 서비스 로직에 Cache Aside 패턴 적용

Author: minor7295

apps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogProductFacade.java

@@ -28,10 +28,12 @@
 public class CatalogProductFacade {
     private final ProductRepository productRepository;
     private final BrandRepository brandRepository;
+    private final ProductCacheService productCacheService;
 
     /**
      * 상품 목록을 조회합니다.
      * <p>
+     * Redis 캐시를 확인하고, 캐시에 없으면 DB에서 조회한 후 캐시에 저장합니다.
      * 배치 조회를 통해 N+1 쿼리 문제를 해결합니다.
      * </p>
      *
@@ -42,11 +44,24 @@ public class CatalogProductFacade {
      * @return 상품 목록 조회 결과
      */
     public ProductInfoList getProducts(Long brandId, String sort, int page, int size) {
+        // sort 기본값 처리 (컨트롤러와 동일하게 "latest" 사용)
+        String normalizedSort = (sort != null && !sort.isBlank()) ? sort : "latest";
+        
+        // 캐시에서 조회 시도
+        ProductInfoList cachedResult = productCacheService.getCachedProductList(brandId, normalizedSort, page, size);
+        if (cachedResult != null) {
+            return cachedResult;
+        }
+        
+        // 캐시에 없으면 DB에서 조회
         long totalCount = productRepository.countAll(brandId);
-        List<Product> products = productRepository.findAll(brandId, sort, page, size);
+        List<Product> products = productRepository.findAll(brandId, normalizedSort, page, size);
 
         if (products.isEmpty()) {
-            return new ProductInfoList(List.of(), totalCount, page, size);
+            ProductInfoList emptyResult = new ProductInfoList(List.of(), totalCount, page, size);
+            // 캐시 저장
+            productCacheService.cacheProductList(brandId, normalizedSort, page, size, emptyResult);
+            return emptyResult;
         }
 
         // ✅ 배치 조회로 N+1 쿼리 문제 해결
@@ -74,17 +89,32 @@ public ProductInfoList getProducts(Long brandId, String sort, int page, int size
             })
             .toList();
 
-        return new ProductInfoList(productsInfo, totalCount, page, size);
+        ProductInfoList result = new ProductInfoList(productsInfo, totalCount, page, size);
+        
+        // 캐시 저장
+        productCacheService.cacheProductList(brandId, normalizedSort, page, size, result);
+        
+        return result;
     }
 
     /**
      * 상품 정보를 조회합니다.
+     * <p>
+     * Redis 캐시를 먼저 확인하고, 캐시에 없으면 DB에서 조회한 후 캐시에 저장합니다.
+     * </p>
      *
      * @param productId 상품 ID
      * @return 상품 정보와 좋아요 수
      * @throws CoreException 상품을 찾을 수 없는 경우
      */
     public ProductInfo getProduct(Long productId) {
+        // 캐시에서 조회 시도
+        ProductInfo cachedResult = productCacheService.getCachedProduct(productId);
+        if (cachedResult != null) {
+            return cachedResult;
+        }
+        
+        // 캐시에 없으면 DB에서 조회
         Product product = productRepository.findById(productId)
             .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "상품을 찾을 수 없습니다."));
 
@@ -98,7 +128,12 @@ public ProductInfo getProduct(Long productId) {
         // ProductDetail 생성 (Aggregate 경계 준수: Brand 엔티티 대신 brandName만 전달)
         ProductDetail productDetail = ProductDetail.from(product, brand.getName(), likesCount);
 
-        return new ProductInfo(productDetail);
+        ProductInfo result = new ProductInfo(productDetail);
+        
+        // 캐시에 저장
+        productCacheService.cacheProduct(productId, result);
+        
+        return result;
     }
 
 }

apps/commerce-api/src/main/java/com/loopers/application/catalog/ProductCacheService.java

@@ -0,0 +1,154 @@
+package com.loopers.application.catalog;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.time.Duration;
+
+/**
+ * 상품 조회 결과를 Redis에 캐시하는 서비스.
+ * <p>
+ * 상품 목록 조회와 상품 상세 조회 결과를 캐시하여 성능을 향상시킵니다.
+ * </p>
+ * <p>
+ * <b>캐시 전략:</b>
+ * <ul>
+ *   <li><b>상품 목록:</b> 첫 3페이지만 캐시하여 메모리 사용량 최적화</li>
+ *   <li><b>상품 상세:</b> 모든 상품 상세 정보 캐시</li>
+ * </ul>
+ * </p>
+ *
+ * @author Loopers
+ */
+@Service
+@RequiredArgsConstructor
+public class ProductCacheService {
+
+    private static final String CACHE_KEY_PREFIX_LIST = "product:list:";
+    private static final String CACHE_KEY_PREFIX_DETAIL = "product:detail:";
+    private static final Duration CACHE_TTL = Duration.ofMinutes(1); // 1분 TTL
+
+    private final RedisTemplate<String, String> redisTemplate;
+    private final ObjectMapper objectMapper;
+
+    /**
+     * 상품 목록 조회 결과를 캐시에서 조회합니다.
+     * <p>
+     * 페이지 번호와 관계없이 캐시를 확인하고, 캐시에 있으면 반환합니다.
+     * 캐시에 없으면 null을 반환하여 DB 조회를 유도합니다.
+     * </p>
+     *
+     * @param brandId 브랜드 ID (null이면 전체)
+     * @param sort 정렬 기준
+     * @param page 페이지 번호
+     * @param size 페이지당 상품 수
+     * @return 캐시된 상품 목록 (없으면 null)
+     */
+    public ProductInfoList getCachedProductList(Long brandId, String sort, int page, int size) {
+        try {
+            String key = buildListCacheKey(brandId, sort, page, size);
+            String cachedValue = redisTemplate.opsForValue().get(key);
+            
+            if (cachedValue == null) {
+                return null;
+            }
+            return objectMapper.readValue(cachedValue, new TypeReference<ProductInfoList>() {});
+        } catch (Exception e) {
+            return null;
+        }
+    }
+
+    /**
+     * 상품 목록 조회 결과를 캐시에 저장합니다.
+     * <p>
+     * 첫 3페이지인 경우에만 캐시에 저장합니다.
+     * </p>
+     *
+     * @param brandId 브랜드 ID (null이면 전체)
+     * @param sort 정렬 기준
+     * @param page 페이지 번호
+     * @param size 페이지당 상품 수
+     * @param productInfoList 캐시할 상품 목록
+     */
+    public void cacheProductList(Long brandId, String sort, int page, int size, ProductInfoList productInfoList) {
+        // 3페이지까지만 캐시 저장
+        if (page > 2) {
+            return;
+        }
+        
+        try {
+            String key = buildListCacheKey(brandId, sort, page, size);
+            String value = objectMapper.writeValueAsString(productInfoList);
+            redisTemplate.opsForValue().set(key, value, CACHE_TTL);
+        } catch (Exception e) {
+            // 캐시 저장 실패는 무시 (DB 조회로 폴백 가능)
+        }
+    }
+
+    /**
+     * 상품 상세 조회 결과를 캐시에서 조회합니다.
+     *
+     * @param productId 상품 ID
+     * @return 캐시된 상품 정보 (없으면 null)
+     */
+    public ProductInfo getCachedProduct(Long productId) {
+        try {
+            String key = buildDetailCacheKey(productId);
+            String cachedValue = redisTemplate.opsForValue().get(key);
+            
+            if (cachedValue == null) {
+                return null;
+            }
+            return objectMapper.readValue(cachedValue, new TypeReference<ProductInfo>() {});
+        } catch (Exception e) {
+            return null;
+        }
+    }
+
+    /**
+     * 상품 상세 조회 결과를 캐시에 저장합니다.
+     *
+     * @param productId 상품 ID
+     * @param productInfo 캐시할 상품 정보
+     */
+    public void cacheProduct(Long productId, ProductInfo productInfo) {
+        try {
+            String key = buildDetailCacheKey(productId);
+            String value = objectMapper.writeValueAsString(productInfo);
+            redisTemplate.opsForValue().set(key, value, CACHE_TTL);
+        } catch (Exception e) {
+            // 캐시 저장 실패는 무시 (DB 조회로 폴백 가능)
+        }
+    }
+
+    /**
+     * 상품 목록 캐시 키를 생성합니다.
+     *
+     * @param brandId 브랜드 ID (null이면 "all")
+     * @param sort 정렬 기준
+     * @param page 페이지 번호
+     * @param size 페이지당 상품 수
+     * @return 캐시 키
+     */
+    private String buildListCacheKey(Long brandId, String sort, int page, int size) {
+        String brandPart = brandId != null ? "brand:" + brandId : "brand:all";
+        // sort가 null이면 기본값 "latest" 사용 (컨트롤러와 동일한 기본값)
+        String sortValue = sort != null ? sort : "latest";
+        return String.format("%s%s:sort:%s:page:%d:size:%d", 
+            CACHE_KEY_PREFIX_LIST, brandPart, sortValue, page, size);
+    }
+
+    /**
+     * 상품 상세 캐시 키를 생성합니다.
+     *
+     * @param productId 상품 ID
+     * @return 캐시 키
+     */
+    private String buildDetailCacheKey(Long productId) {
+        return CACHE_KEY_PREFIX_DETAIL + productId;
+    }
+}
+