Merge pull request #138 from yeonjiyeon/feature/week5

[volume-5] 인덱스 및 Redis 캐시 적용

Author: yeonjiyeon

apps/commerce-api/src/main/java/com/loopers/application/like/LikeFacade.java

@@ -23,27 +23,26 @@ public class LikeFacade {
   public LikeInfo like(long userId, long productId) {
     Optional<Like> existingLike = likeService.findLike(userId, productId);
 
-
     if (existingLike.isPresent()) {
       Product product = productService.getProduct(productId);
       return LikeInfo.from(existingLike.get(), product.getLikeCount());
     }
 
     for (int i = 0; i < RETRY_COUNT; i++) {
       try {
+        return transactionTemplate.execute(status -> {
+          Like newLike = likeService.save(userId, productId);
+          int updatedLikeCount = productService.increaseLikeCount(productId);
+          return LikeInfo.from(newLike, updatedLikeCount);
+        });
 
-        Like newLike = likeService.save(userId, productId);
-        int updatedLikeCount = productService.increaseLikeCount(productId);
-
-        return LikeInfo.from(newLike, updatedLikeCount);
       } catch (ObjectOptimisticLockingFailureException e) {
         if (i == RETRY_COUNT - 1) {
           throw e;
         }
         sleep(50);
       }
     }
-
     throw new IllegalStateException("좋아요 처리 재시도 횟수를 초과했습니다.");
   }
 

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

@@ -11,10 +11,11 @@
 @RequiredArgsConstructor
 @Component
 public class ProductFacade {
+
   private final ProductService productService;
   private final BrandService brandService;
 
-  public Page<ProductInfo> getProductInfo(Pageable pageable) {
+  public Page<ProductInfo> getProductsInfo(Pageable pageable) {
     Page<Product> products = productService.getProducts(pageable);
     return products.map(product -> {
       String brandName = brandService.getBrand(product.getBrandId())
@@ -23,4 +24,12 @@ public Page<ProductInfo> getProductInfo(Pageable pageable) {
     });
   }
 
+  public ProductInfo getProductInfo(long id) {
+    Product product = productService.getProduct(id);
+    String brandName = brandService.getBrand(product.getBrandId())
+        .getName();
+
+    return ProductInfo.from(product, brandName);
+  }
+
 }

apps/commerce-api/src/main/java/com/loopers/config/redis/RedisConfig.java

@@ -0,0 +1,61 @@
+package com.loopers.config.redis;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.databind.jsontype.BasicPolymorphicTypeValidator;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+import java.util.List;
+
+@Configuration
+public class RedisConfig {
+
+  @Bean
+  public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
+    RedisTemplate<String, Object> template = new RedisTemplate<>();
+    template.setConnectionFactory(connectionFactory);
+
+    ObjectMapper objectMapper = new ObjectMapper();
+
+    objectMapper.registerModule(new JavaTimeModule());
+    objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
+
+    objectMapper.activateDefaultTyping(
+        BasicPolymorphicTypeValidator.builder()
+            .allowIfBaseType(Object.class)
+            .build(),
+        ObjectMapper.DefaultTyping.EVERYTHING
+    );
+
+    objectMapper.addMixIn(PageImpl.class, PageImplMixin.class);
+
+    GenericJackson2JsonRedisSerializer serializer = new GenericJackson2JsonRedisSerializer(objectMapper);
+
+    template.setKeySerializer(new StringRedisSerializer());
+    template.setValueSerializer(serializer);
+    template.setHashKeySerializer(new StringRedisSerializer());
+    template.setHashValueSerializer(serializer);
+
+    return template;
+  }
+
+  @JsonIgnoreProperties(ignoreUnknown = true)
+  abstract static class PageImplMixin<T> {
+    @JsonCreator
+    public PageImplMixin(@JsonProperty("content") List<T> content,
+        @JsonProperty("pageable") JsonNode pageable,
+        @JsonProperty("total") long total) {
+    }
+  }
+}

apps/commerce-api/src/main/java/com/loopers/domain/product/Product.java

@@ -4,6 +4,7 @@
 import com.loopers.domain.money.Money;
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;
+import jakarta.persistence.AttributeOverride;
 import jakarta.persistence.Column;
 import jakarta.persistence.Embedded;
 import jakarta.persistence.Entity;
@@ -26,7 +27,7 @@ public class Product extends BaseEntity {
   @Column(nullable = false)
   private String description;
 
-  @Column(nullable = false)
+  @AttributeOverride(name = "value", column = @Column(name = "price"))
   @Embedded
   private Money price;
 

apps/commerce-api/src/main/java/com/loopers/domain/product/ProductService.java

@@ -1,8 +1,10 @@
 package com.loopers.domain.product;
 
 import com.loopers.domain.order.OrderItem;
+import com.loopers.support.cache.RedisCacheHandler;
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;
+import java.time.Duration;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -18,19 +20,38 @@ public class ProductService {
 
   private final ProductRepository productRepository;
 
+  private final RedisCacheHandler redisCacheHandler;
 
   public Page<Product> getProducts(Pageable pageable) {
-    return productRepository.findAll(pageable);
+    String key = makeCacheKey("product:list", pageable);
+    return redisCacheHandler.getOrLoad(
+        key,
+        Duration.ofMinutes(5),
+        Page.class,
+        () -> productRepository.findAll(pageable)
+    );
   }
 
   @Transactional
   public Product getProduct(Long id) {
-    return productRepository.findById(id).orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "상품을 찾을 수 없습니다."));
+    String key = "product:detail:" + id;
+    return redisCacheHandler.getOrLoad(
+        key,
+        Duration.ofMinutes(10),
+        Product.class,
+        () -> productRepository.findById(id)
+            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "상품을 찾을 수 없습니다."))
+    );
   }
 
   public Page<Product> getProductsByBrandId(Long brandId, Pageable pageable) {
-
-    return productRepository.findByBrandId(brandId, pageable);
+    String key = makeCacheKey("product:list:brand:" + brandId, pageable);
+    return redisCacheHandler.getOrLoad(
+        key,
+        Duration.ofMinutes(5),
+        Page.class,
+        () -> productRepository.findByBrandId(brandId, pageable)
+    );
   }
 
 
@@ -69,4 +90,18 @@ public int decreaseLikeCount(Long productId) {
 
     return product.decreaseLikeCount();
   }
+
+  private String makeCacheKey(String prefix, Pageable pageable) {
+    StringBuilder sb = new StringBuilder();
+    sb.append(prefix);
+    sb.append(":page:").append(pageable.getPageNumber());
+    sb.append(":size:").append(pageable.getPageSize());
+
+    if (pageable.getSort().isSorted()) {
+      pageable.getSort().forEach(order ->
+          sb.append(":sort:").append(order.getProperty()).append(",").append(order.getDirection())
+      );
+    }
+    return sb.toString();
+  }
 }

apps/commerce-api/src/main/java/com/loopers/support/cache/RedisCacheHandler.java

@@ -0,0 +1,52 @@
+package com.loopers.support.cache;
+
+import com.loopers.support.page.PageWrapper;
+import java.time.Duration;
+import java.util.function.Supplier;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+@RequiredArgsConstructor
+@Component
+public class RedisCacheHandler {
+  private final RedisTemplate<String, Object> redisTemplate;
+
+  /**
+   * 캐시 조회 -> (없거나 에러나면) -> DB 조회 -> 캐시 저장
+   * @param key        캐시 키
+   * @param ttl        만료 시간
+   * @param type       반환 타입 (캐스팅용)
+   * @param dbFetcher  DB 조회 로직 (람다)
+   */
+  public <T> T getOrLoad(String key, Duration ttl, Class<T> type, Supplier<T> dbFetcher) {
+    try {
+      Object cachedData = redisTemplate.opsForValue().get(key);
+      if (cachedData != null) {
+
+        if (cachedData instanceof PageWrapper) {
+          return (T) ((PageWrapper<?>) cachedData).toPage();
+        }
+        return type.cast(cachedData);
+      }
+    } catch (Exception e) {
+    }
+
+    T result = dbFetcher.get();
+
+    if (result != null) {
+      try {
+        Object dataToSave = result;
+        if (result instanceof Page) {
+          dataToSave = new PageWrapper<>((Page<?>) result);
+        }
+
+        redisTemplate.opsForValue().set(key, dataToSave, ttl);
+      } catch (Exception e) {
+      }
+    }
+
+    return result;
+  }
+}

apps/commerce-api/src/main/java/com/loopers/support/page/PageWrapper.java

@@ -0,0 +1,31 @@
+package com.loopers.support.page;
+
+import java.util.List;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.domain.PageRequest;
+
+public class PageWrapper<T> {
+  private List<T> content;
+  private long totalElements;
+  private int pageNumber;
+  private int pageSize;
+
+  public PageWrapper() {}
+
+  public PageWrapper(Page<T> page) {
+    this.content = page.getContent();
+    this.totalElements = page.getTotalElements();
+    this.pageNumber = page.getNumber();
+    this.pageSize = page.getSize();
+  }
+
+  public Page<T> toPage() {
+    return new PageImpl<>(content, PageRequest.of(pageNumber, pageSize), totalElements);
+  }
+
+  public List<T> getContent() { return content; }
+  public long getTotalElements() { return totalElements; }
+  public int getPageNumber() { return pageNumber; }
+  public int getPageSize() { return pageSize; }
+}

apps/commerce-api/src/main/resources/jpa.yml

@@ -0,0 +1,19 @@
+datasource:
+  mysql-jpa:
+    main:
+      jdbc-url: "jdbc:mysql://127.0.0.1:3306/loopers?serverTimezone=Asia/Seoul&characterEncoding=UTF-8&useSSL=false&allowPublicKeyRetrieval=true"
+      username: application
+      password: application
+      driver-class-name: com.mysql.cj.jdbc.Driver
+      maximum-pool-size: 10
+      minimum-idle: 5
+      pool-name: MyHikariCP
+
+spring:
+  jpa:
+    hibernate:
+      ddl-auto: update
+    show-sql: true
+    properties:
+      hibernate:
+        format_sql: true

apps/commerce-api/src/main/resources/redis.yml

@@ -0,0 +1,7 @@
+datasource:
+  redis:
+    database: 0
+    master:
+      host: 127.0.0.1
+      port: 6379
+    replicas: []

apps/commerce-api/src/test/java/com/loopers/application/product/ProductFacadeIntegrationTest.java

@@ -56,7 +56,7 @@ void return_productInfoPage_withBrandNames() {
     Pageable pageable = PageRequest.of(0, 20, Sort.by(Sort.Direction.DESC, "createdAt"));
 
     // act
-    Page<ProductInfo> result = productFacade.getProductInfo(pageable);
+    Page<ProductInfo> result = productFacade.getProductsInfo(pageable);
 
     // assert
     assertAll(
@@ -72,7 +72,7 @@ void return_emptyPage_whenNoProductsExist() {
     Pageable pageable = PageRequest.of(0, 10);
 
     // act
-    Page<ProductInfo> result = productFacade.getProductInfo(pageable);
+    Page<ProductInfo> result = productFacade.getProductsInfo(pageable);
 
     // assert
     assertThat(result.isEmpty()).isTrue();