[volume-5] 인덱스와 캐시를 사용한 성능 최적화

apps/commerce-api/src/main/java/com/loopers/application/product/ProductFacade.java

@@ -6,6 +6,7 @@
 import com.loopers.domain.product.Product;
 import com.loopers.domain.product.ProductSearchCondition;
 import com.loopers.domain.product.ProductService;
+import com.loopers.infrastructure.product.ProductCacheStore;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -20,10 +21,11 @@ public class ProductFacade {
 
     private final BrandService brandService;
     private final ProductService productService;
+    private final ProductCacheStore productCacheStore;
 
     public List<ProductInfo> createProducts(CreateProductCommand command) {
         command.products().keySet().forEach(brandService::getById);
-        
+
         Map<Long, CreateProductRequest> domainRequest = new HashMap<>();
         command.products().forEach((brandId, item) -> {
             domainRequest.put(brandId, new CreateProductRequest(
@@ -32,7 +34,7 @@ public List<ProductInfo> createProducts(CreateProductCommand command) {
                 item.stock()
             ));
         });
-        
+
         List<Product> products = productService.createProducts(domainRequest);
         return products.stream()
             .map(product -> {
@@ -44,29 +46,39 @@ public List<ProductInfo> createProducts(CreateProductCommand command) {
 
     @Transactional(readOnly = true)
     public ProductInfo getProduct(Long productId) {
-        Product product = productService.getById(productId);
-        Brand brand = brandService.getById(product.getRefBrandId());
-        return ProductInfo.of(product, brand);
+        return productCacheStore.getProduct(productId)
+            .orElseGet(() -> {
+                Product product = productService.getById(productId);
+                Brand brand = brandService.getById(product.getRefBrandId());
+                ProductInfo info = ProductInfo.of(product, brand);
+                productCacheStore.putProduct(productId, info);
+                return info;
+            });
     }
 
     @Transactional(readOnly = true)
     public List<ProductInfo> getProducts(ProductSearchCommand command) {
-        if (command.hasBrandId()) {
-            brandService.getById(command.brandId());
-        }
-
-        ProductSearchCondition condition = new ProductSearchCondition(
-            command.brandId(),
-            command.sortType(),
-            command.page(),
-            command.size()
-        );
-
-        return productService.findProducts(condition).stream()
-            .map(product -> {
-                Brand brand = brandService.getById(product.getRefBrandId());
-                return ProductInfo.of(product, brand);
-            })
-            .toList();
+        return productCacheStore.getProducts(command)
+            .orElseGet(() -> {
+                if (command.hasBrandId()) {
+                    brandService.getById(command.brandId());
+                }
+
+                ProductSearchCondition condition = new ProductSearchCondition(
+                    command.brandId(),
+                    command.sortType(),
+                    command.page(),
+                    command.size()
+                );
+
+                List<ProductInfo> list = productService.findProducts(condition).stream()
+                    .map(product -> {
+                        Brand brand = brandService.getById(product.getRefBrandId());
+                        return ProductInfo.of(product, brand);
+                    })
+                    .toList();
+                productCacheStore.putProducts(command, list);
+                return list;
+            });
     }
 }

apps/commerce-api/src/main/java/com/loopers/infrastructure/product/ProductCacheStore.java

@@ -0,0 +1,98 @@
+package com.loopers.infrastructure.product;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.loopers.application.product.ProductInfo;
+import com.loopers.application.product.ProductSearchCommand;
+import com.loopers.config.redis.RedisConfig;
+import java.time.Duration;
+import java.util.List;
+import java.util.Optional;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class ProductCacheStore {
+
+    private static final String DETAIL_KEY_PREFIX = "product:detail:";
+    private static final String LIST_KEY_PREFIX = "product:list:";
+
+    private static final Duration DETAIL_TTL = Duration.ofSeconds(180);
+    private static final Duration LIST_TTL = Duration.ofSeconds(30);
+
+    private final RedisTemplate<String, String> redisTemplate;
+    private final RedisTemplate<String, String> masterRedisTemplate;
+    private final ObjectMapper objectMapper;
+
+    public ProductCacheStore(
+        RedisTemplate<String, String> redisTemplate,
+        @Qualifier(RedisConfig.REDIS_TEMPLATE_MASTER) RedisTemplate<String, String> masterRedisTemplate,
+        ObjectMapper objectMapper
+    ) {
+        this.redisTemplate = redisTemplate;
+        this.masterRedisTemplate = masterRedisTemplate;
+        this.objectMapper = objectMapper;
+    }
+
+    public Optional<ProductInfo> getProduct(Long productId) {
+        String key = detailKey(productId);
+        try {
+            String value = redisTemplate.opsForValue().get(key);
+            if (value == null) {
+                return Optional.empty();
+            }
+            return Optional.of(objectMapper.readValue(value, ProductInfo.class));
+        } catch (JsonProcessingException e) {
+            log.warn("Failed to deserialize product cache. key={}", key, e);
+            return Optional.empty();
+        }
+    }
+
+    public void putProduct(Long productId, ProductInfo productInfo) {
+        String key = detailKey(productId);
+        try {
+            masterRedisTemplate.opsForValue().set(key, objectMapper.writeValueAsString(productInfo), DETAIL_TTL);
+        } catch (JsonProcessingException e) {
+            log.warn("Failed to serialize product cache. key={}", key, e);
+        }
+    }
+
+    public Optional<List<ProductInfo>> getProducts(ProductSearchCommand command) {
+        String key = listKey(command);
+        try {
+            String value = redisTemplate.opsForValue().get(key);
+            if (value == null) {
+                return Optional.empty();
+            }
+            return Optional.of(objectMapper.readValue(value, new TypeReference<>() {}));
+        } catch (JsonProcessingException e) {
+            log.warn("Failed to deserialize product list cache. key={}", key, e);
+            return Optional.empty();
+        }
+    }
+
+    public void putProducts(ProductSearchCommand command, List<ProductInfo> productInfos) {
+        String key = listKey(command);
+        try {
+            masterRedisTemplate.opsForValue().set(key, objectMapper.writeValueAsString(productInfos), LIST_TTL);
+        } catch (JsonProcessingException e) {
+            log.warn("Failed to serialize product list cache. key={}", key, e);
+        }
+    }
+
+    private String detailKey(Long productId) {
+        return DETAIL_KEY_PREFIX + productId;
+    }
+
+    private String listKey(ProductSearchCommand command) {
+        return LIST_KEY_PREFIX
+            + "brandId=" + command.brandId()
+            + ":sort=" + command.sortType()
+            + ":page=" + command.page()
+            + ":size=" + command.size();
+    }
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/product/ProductEntity.java

@@ -4,6 +4,7 @@
 import com.loopers.domain.product.Product;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
+import jakarta.persistence.Index;
 import jakarta.persistence.Table;
 import lombok.NoArgsConstructor;
 import org.hibernate.annotations.Comment;
@@ -12,7 +13,12 @@
  *  Product DB 엔티티
  */
 @Entity
-@Table(name = "product")
+@Table(name = "product", indexes = {
+    @Index(name = "idx_product_brand_like", columnList = "ref_brand_id, like_count DESC"),
+    @Index(name = "idx_product_like", columnList = "like_count DESC"),
+    @Index(name = "idx_product_brand_latest", columnList = "ref_brand_id, created_at DESC"),
+    @Index(name = "idx_product_latest", columnList = "created_at DESC")
+})
 @NoArgsConstructor
 public class ProductEntity extends BaseEntity {
 

db/seed-products.sql

@@ -0,0 +1,36 @@
+-- ============================================================
+-- 상품 더미 데이터 시드 스크립트 (10만 건)
+-- 실행 전제: 앱을 먼저 실행해서 테이블이 생성된 상태여야 합니다.
+-- 실행 방법: mysql -u application -papplication loopers < db/seed-products.sql
+-- ============================================================
+
+-- 브랜드 10개 삽입
+INSERT INTO brand (name, description, created_at, updated_at)
+VALUES
+    ('나이키',   '글로벌 스포츠 브랜드',   NOW(), NOW()),
+    ('아디다스', '독일 스포츠 브랜드',     NOW(), NOW()),
+    ('뉴발란스', '미국 스포츠 브랜드',     NOW(), NOW()),
+    ('컨버스',   '캐주얼 스니커즈 브랜드', NOW(), NOW()),
+    ('반스',     '스케이트 브랜드',        NOW(), NOW()),
+    ('푸마',     '독일 스포츠 브랜드',     NOW(), NOW()),
+    ('리복',     '영국 스포츠 브랜드',     NOW(), NOW()),
+    ('언더아머', '미국 퍼포먼스 브랜드',   NOW(), NOW()),
+    ('살로몬',   '아웃도어 브랜드',        NOW(), NOW()),
+    ('노스페이스','아웃도어 브랜드',        NOW(), NOW());
+
+-- 상품 10만 건 삽입 (cross join으로 빠르게 생성)
+SET @i = 0;
+
+INSERT INTO product (name, ref_brand_id, price, stock, like_count, created_at, updated_at)
+SELECT
+    CONCAT('상품_', @i := @i + 1),
+    FLOOR(1 + RAND() * 10),
+    FLOOR(1 + RAND() * 100) * 1000,
+    FLOOR(RAND() * 500),
+    FLOOR(RAND() * 1000),
+    DATE_SUB(NOW(), INTERVAL FLOOR(RAND() * 365) DAY),
+    NOW()
+FROM
+    information_schema.columns a,
+    information_schema.columns b
+LIMIT 100000;