Merge pull request #274 from prgrms-aibe-devcourse/perf/v2-redis-caching

perf: 캐싱 적용

Author: dochmai382

build.gradle

@@ -79,6 +79,9 @@ dependencies {
     annotationProcessor "jakarta.annotation:jakarta.annotation-api" // Jakarta 어노테이션 API
     annotationProcessor "jakarta.persistence:jakarta.persistence-api" // Jakarta Persistence API
 
+    // Cache
+    implementation 'org.springframework.boot:spring-boot-starter-cache'
+    implementation 'com.github.ben-manes.caffeine:caffeine'
 }
 
 // QueryDSL Q-Type 생성 위치 지정

src/main/java/store/lastdance/config/CacheConfig.java

@@ -0,0 +1,51 @@
+package store.lastdance.config;
+
+import com.github.benmanes.caffeine.cache.Caffeine;
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cache.caffeine.CaffeineCacheManager;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.concurrent.TimeUnit;
+
+@Configuration
+@EnableCaching
+public class CacheConfig {
+
+    @Bean
+    public CacheManager cacheManager() {
+        CaffeineCacheManager manager = new CaffeineCacheManager();
+
+        manager.registerCustomCache("userProfile",
+                Caffeine.newBuilder()
+                        .maximumSize(500)
+                        .expireAfterWrite(10, TimeUnit.MINUTES)
+                        .recordStats()
+                        .build()
+        );
+
+        manager.registerCustomCache("nickname",
+                Caffeine.newBuilder()
+                        .maximumSize(1000)
+                        .expireAfterWrite(5, TimeUnit.MINUTES)
+                        .build()
+        );
+
+        manager.registerCustomCache("expenseTrend",
+                Caffeine.newBuilder()
+                        .maximumSize(200)
+                        .expireAfterWrite(5, TimeUnit.MINUTES)
+                        .build()
+        );
+
+        manager.registerCustomCache("groupExpenseTrend",
+                Caffeine.newBuilder()
+                        .maximumSize(200)
+                        .expireAfterWrite(5, TimeUnit.MINUTES)
+                        .build()
+        );
+
+        return manager;
+    }
+}

src/main/java/store/lastdance/service/expense/ExpenseV2QueryServiceImpl.java

@@ -2,6 +2,7 @@
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageImpl;
 import org.springframework.data.domain.Pageable;
@@ -116,6 +117,7 @@ public String getReceiptImageUrl(Long expenseId, UUID userId) {
     }
 
     @Override
+    @Cacheable(value = "expenseTrend", key = "#userId + ':' + #searchDTO.year() + ':' + #searchDTO.month() + ':' + #searchDTO.months() + ':' + (#searchDTO.category() ?: 'ALL')")
     public MonthlyExpenseTrendResponseDTO getPersonalExpenseTrend(UUID userId, ExpenseSearchDTO searchDTO) {
         log.info("개인 지출 추이 조회: userId={}, year={}, month={}, months={}, category={}", userId, searchDTO.year(), searchDTO.month(), searchDTO.months(), searchDTO.category());
 
@@ -130,6 +132,7 @@ public MonthlyExpenseTrendResponseDTO getPersonalExpenseTrend(UUID userId, Expen
     }
 
     @Override
+    @Cacheable(value = "expenseTrend", key = "#userId + ':' + #searchDTO.year() + ':' + #searchDTO.month() + ':' + #searchDTO.months() + ':' + (#searchDTO.category() ?: 'ALL')")
     public MonthlyExpenseTrendResponseDTO getGroupExpenseTrend(UUID userId, UUID groupId, ExpenseSearchDTO searchDTO) {
         User user = findUserById(userId);
         Group group = findGroupById(groupId);

src/main/java/store/lastdance/service/expense/ExpenseV2ServiceImpl.java

@@ -2,6 +2,7 @@
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
@@ -58,6 +59,7 @@ private Group findGroupById(UUID groupId) {
     }
 
     @Override
+    @CacheEvict(value = {"expenseTrend", "groupExpenseTrend"}, allEntries = true)
     public ExpenseResponseDTO createPersonalExpense(UUID userId, CreatePersonalExpenseRequestDTO requestDTO, MultipartFile receiptFile) {
         Expense expense = createBaseExpense(userId, requestDTO, ExpenseType.PERSONAL, receiptFile);
 
@@ -78,6 +80,7 @@ public ExpenseResponseDTO createPersonalExpense(UUID userId, CreatePersonalExpen
     }
 
     @Override
+    @CacheEvict(value = {"expenseTrend", "groupExpenseTrend"}, allEntries = true)
     public ExpenseResponseDTO createGroupExpense(UUID userId, CreateGroupExpenseRequestDTO requestDTO, MultipartFile receiptFile) {
 
         Group group = findGroupById(requestDTO.groupId());
@@ -201,6 +204,7 @@ private void applySplitResultToDatabase(Expense original, Map<UUID, BigDecimal>
     }
 
     @Override
+    @CacheEvict(value = {"expenseTrend", "groupExpenseTrend"}, allEntries = true)
     public ExpenseResponseDTO updateExpense(UUID userId, Long expenseId, UpdateExpenseRequestDTO requestDTO, MultipartFile receiptFile) {
 
         User user = findUserById(userId);
@@ -287,6 +291,7 @@ private List<GroupMember> validateAndGetGroupMembers(Expense expense) {
     }
 
     @Override
+    @CacheEvict(value = {"expenseTrend", "groupExpenseTrend"}, allEntries = true)
     public void deleteExpense(UUID userId, Long expenseId) {
 
         User user = findUserById(userId);
@@ -312,6 +317,7 @@ public void deleteExpense(UUID userId, Long expenseId) {
     }
 
     @Override
+    @CacheEvict(value = {"expenseTrend", "groupExpenseTrend"}, allEntries = true)
     public void deleteReceiptImage(UUID userId, Long expenseId) {
 
         User user = findUserById(userId);

src/main/java/store/lastdance/service/user/UserV2QueryServiceImpl.java

@@ -2,6 +2,7 @@
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import store.lastdance.converter.user.UserConverter;
@@ -41,13 +42,15 @@ public User findByUserId(UUID userId) {
     }
 
     @Override
+    @Cacheable(value = "userProfile", key = "#userId")
     public UserResponseDTO getUserWithProfileImage(UUID userId) {
         User user = userRepository.findByIdWithProfileImage(userId)
                 .orElseThrow(() -> new CustomException(ErrorCode.USER_NOT_FOUND));
         return userConverter.toResponseDTO(user);
     }
 
     @Override
+    @Cacheable(value = "nickname", key = "#userId + ':' + #nickname")
     public boolean isNicknameAvailable(UUID userId, String nickname) {
         if (nickname == null || nickname.trim().isEmpty()) {
             return false;

src/main/java/store/lastdance/service/user/UserV2ServiceImpl.java

@@ -4,6 +4,7 @@
 import jakarta.servlet.http.HttpServletResponse;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -34,6 +35,7 @@ public class UserV2ServiceImpl implements UserV2Service {
 
     @Override
     @Transactional
+    @CacheEvict(value = "nickname", allEntries = true)
     public User updateMyInfo(UUID userId, UserUpdateRequestDTO requestDTO) {
         User user = userV2QueryService.findByActiveUser(userId);
 
@@ -56,6 +58,7 @@ public User updateMyInfo(UUID userId, UserUpdateRequestDTO requestDTO) {
 
     @Override
     @Transactional
+    @CacheEvict(value = "userProfile", key = "#userId")
     public UserResponseDTO updateProfileImage(UUID userId, MultipartFile file) {
         User user = userRepository.findByIdWithProfileImage(userId)
                 .orElseThrow(() -> new CustomException(ErrorCode.USER_NOT_FOUND));
@@ -90,8 +93,9 @@ public UserResponseDTO updateProfileImage(UUID userId, MultipartFile file) {
 
     @Override
     @Transactional
-    public UserResponseDTO deleteProfileImage(UUID userid) {
-        User user = userRepository.findByIdWithProfileImage(userid).orElseThrow(
+    @CacheEvict(value = "userProfile", key = "#userId")
+    public UserResponseDTO deleteProfileImage(UUID userId) {
+        User user = userRepository.findByIdWithProfileImage(userId).orElseThrow(
                 () -> new CustomException(ErrorCode.USER_NOT_FOUND)
         );
 

src/main/resources/application-prod.yml

@@ -183,7 +183,7 @@ management:
   endpoints:
     web:
       exposure:
-        include: health,info,prometheus # Prometheus 엔드포인트 노출
+        include: health,info,prometheus,caches # Prometheus 엔드포인트 노출
   prometheus:
     metrics:
       export: