[BACKEND] 카카오 로그인 수정 및 ProductService 캐싱 적용 (#70)

ddoed · web-flow · commit b25b098b83da · 2025-11-05T14:58:44.000+09:00
## 📝작업 내용 > 개발 환경을 위해 카카오 로그인 시 redirectUri 지정 가능하도록 변경 > redirectUri 지정하지 않으면 env file의 redirectUri로 사용됨 > ProductService 상품 API 호출에 캐싱 적용 (Caffeine Local Cache) > 6시간 후 만료, maximumSize 5000 > CacheMonitorService로 캐싱 로그 출력 ### 스크린샷 (선택) <img width="1642" height="275" alt="image" src="https://github.com/user-attachments/assets/c37d8c8f-91e1-4e51-8c7b-cb56893f917b" />
diff --git a/backend/build.gradle b/backend/build.gradle
@@ -41,6 +41,9 @@ dependencies {
 	runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.11.5'
 
 	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.12'
+
+	implementation 'org.springframework.boot:spring-boot-starter-cache'
+	implementation 'com.github.ben-manes.caffeine:caffeine'
 }
 
 tasks.named('test') {
diff --git a/backend/src/main/java/com/cmg/comtogether/cache/CacheMonitorService.java b/backend/src/main/java/com/cmg/comtogether/cache/CacheMonitorService.java
@@ -0,0 +1,44 @@
+package com.cmg.comtogether.cache;
+
+import com.github.benmanes.caffeine.cache.stats.CacheStats;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.caffeine.CaffeineCache;
+import org.springframework.cache.CacheManager;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class CacheMonitorService {
+
+    private final CacheManager cacheManager;
+
+    public void printCacheStats(String cacheName) {
+        CaffeineCache cache = (CaffeineCache) cacheManager.getCache(cacheName);
+        if (cache != null) {
+            CacheStats stats = cache.getNativeCache().stats();
+            log.info("""
+                [CACHE STATS: {}]
+                hits: {}
+                misses: {}
+                hitRate: {}
+                loadSuccess: {}
+                loadFailure: {}
+                evictions: {}
+                avgLoadPenalty: {} ns
+                """,
+                    cacheName,
+                    stats.hitCount(),
+                    stats.missCount(),
+                    String.format("%.2f%%", stats.hitRate() * 100),
+                    stats.loadSuccessCount(),
+                    stats.loadFailureCount(),
+                    stats.evictionCount(),
+                    stats.averageLoadPenalty()
+            );
+        } else {
+            log.warn("Cache '{}' not found!", cacheName);
+        }
+    }
+}
diff --git a/backend/src/main/java/com/cmg/comtogether/common/config/CacheConfig.java b/backend/src/main/java/com/cmg/comtogether/common/config/CacheConfig.java
@@ -0,0 +1,30 @@
+package com.cmg.comtogether.common.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 Caffeine<Object, Object> caffeineConfig() {
+        return Caffeine.newBuilder()
+                .expireAfterWrite(6, TimeUnit.HOURS)
+                .maximumSize(5000)
+                .recordStats();
+    }
+
+    @Bean
+    public CacheManager cacheManager(Caffeine<Object, Object> caffeineConfig) {
+        CaffeineCacheManager cacheManager = new CaffeineCacheManager();
+        cacheManager.setCaffeine(caffeineConfig);
+        return cacheManager;
+    }
+}
diff --git a/backend/src/main/java/com/cmg/comtogether/oauth/controller/OauthController.java b/backend/src/main/java/com/cmg/comtogether/oauth/controller/OauthController.java
@@ -24,7 +24,8 @@ public class OauthController {
     @PostMapping("/kakao")
     public ResponseEntity<ApiResponse<TokenDto>> kakaoLogin(@Valid @RequestBody OauthLoginRequestDto requestDto) {
         String code = requestDto.getCode();
-        TokenDto tokenDto = oauthService.kakaoLogin(code);
+        String redirect_uri = requestDto.getRedirect_uri();
+        TokenDto tokenDto = oauthService.kakaoLogin(code, redirect_uri);
         return ResponseEntity.ok(ApiResponse.success(tokenDto));
     }
 }
diff --git a/backend/src/main/java/com/cmg/comtogether/oauth/dto/OauthLoginRequestDto.java b/backend/src/main/java/com/cmg/comtogether/oauth/dto/OauthLoginRequestDto.java
@@ -10,4 +10,6 @@ public class OauthLoginRequestDto {
 
     @NotBlank(message = "인가 코드는 필수 값입니다.")
     private String code;
+
+    private String redirect_uri;
 }
diff --git a/backend/src/main/java/com/cmg/comtogether/oauth/service/KakaoService.java b/backend/src/main/java/com/cmg/comtogether/oauth/service/KakaoService.java
@@ -4,6 +4,7 @@
 import com.cmg.comtogether.common.exception.ErrorCode;
 import com.cmg.comtogether.jwt.dto.TokenDto;
 import com.cmg.comtogether.oauth.dto.KakaoProfileDto;
+import jakarta.annotation.Nullable;
 import lombok.RequiredArgsConstructor;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.HttpHeaders;
@@ -24,19 +25,19 @@ public class KakaoService {
     private String clientId;
 
     @Value("${oauth.kakao.redirect-uri}")
-    private String redirectUri;
+    private String defaultRedirectUri;
 
     @Value("${oauth.kakao.user-info-uri}")
     private String userInfoUri;
 
     @Value("${oauth.kakao.token-uri}")
     private String tokenUri;
 
-    public TokenDto getToken(String code) {
+    public TokenDto getToken(String code, @Nullable String redirectUri) {
         MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
         params.add("grant_type", "authorization_code");
         params.add("client_id", clientId);
-        params.add("redirect_uri", redirectUri);
+        params.add("redirect_uri", redirectUri != null ? redirectUri : defaultRedirectUri);
         params.add("code", code);
 
         return restClient.post()
diff --git a/backend/src/main/java/com/cmg/comtogether/oauth/service/OauthService.java b/backend/src/main/java/com/cmg/comtogether/oauth/service/OauthService.java
@@ -8,6 +8,7 @@
 import com.cmg.comtogether.user.entity.SocialType;
 import com.cmg.comtogether.user.entity.User;
 import com.cmg.comtogether.user.repository.UserRepository;
+import io.micrometer.common.lang.Nullable;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -19,8 +20,8 @@ public class OauthService {
     private final JwtService jwtService;
     private final UserRepository userRepository;
 
-    public TokenDto kakaoLogin(String code) {
-        TokenDto kakaoToken = kakaoService.getToken(code);
+    public TokenDto kakaoLogin(String code, @Nullable String redirectUri) {
+        TokenDto kakaoToken = kakaoService.getToken(code, redirectUri);
         KakaoProfileDto profile = kakaoService.getKakaoProfile(kakaoToken.getAccessToken());
 
         User user = userRepository.findBySocialId(String.valueOf(profile.getId()))
diff --git a/backend/src/main/java/com/cmg/comtogether/product/service/NaverProductService.java b/backend/src/main/java/com/cmg/comtogether/product/service/NaverProductService.java
@@ -0,0 +1,57 @@
+package com.cmg.comtogether.product.service;
+
+import com.cmg.comtogether.common.exception.BusinessException;
+import com.cmg.comtogether.common.exception.ErrorCode;
+import com.cmg.comtogether.product.dto.NaverProductResponseDto;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClient;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.util.Optional;
+
+@Service
+@RequiredArgsConstructor
+public class NaverProductService {
+
+    @Value("${naver.shopping.client-id}")
+    private String clientId;
+
+    @Value("${naver.shopping.client-secret}")
+    private String clientSecret;
+
+    @Value("${naver.shopping.base-url}")
+    private String baseUrl;
+
+    private final RestClient restClient;
+
+    @Cacheable(
+            value = "naverProducts",
+            key = "T(java.util.Objects).hash(#searchQuery, #display, #start, #sort, #exclude)"
+    )
+    public NaverProductResponseDto getNaverProducts(String searchQuery, int display, int start, String sort, String exclude) {
+        return restClient.get()
+                .uri(UriComponentsBuilder
+                        .fromUriString(baseUrl)
+                        .queryParam("query", searchQuery)
+                        .queryParam("display", display)
+                        .queryParam("start", start)
+                        .queryParam("sort", sort)
+                        .queryParamIfPresent("exclude", Optional.ofNullable(exclude))
+                        .build()
+                        .toUri())
+                .header("X-Naver-Client-Id", clientId)
+                .header("X-Naver-Client-Secret", clientSecret)
+                .retrieve()
+                .onStatus(HttpStatusCode::is4xxClientError, (req, res) -> {
+                    throw new BusinessException(ErrorCode.INTERNAL_SERVER_ERROR);
+                })
+                .onStatus(HttpStatusCode::is5xxServerError, (req, res) -> {
+                    throw new BusinessException(ErrorCode.NAVER_API_ERROR);
+                })
+                .body(NaverProductResponseDto.class);
+    }
+}
diff --git a/backend/src/main/java/com/cmg/comtogether/product/service/ProductService.java b/backend/src/main/java/com/cmg/comtogether/product/service/ProductService.java
@@ -1,5 +1,6 @@
 package com.cmg.comtogether.product.service;
 
+import com.cmg.comtogether.cache.CacheMonitorService;
 import com.cmg.comtogether.common.exception.BusinessException;
 import com.cmg.comtogether.common.exception.ErrorCode;
 import com.cmg.comtogether.interest.entity.Interest;
@@ -8,34 +9,22 @@
 import com.cmg.comtogether.user.entity.UserInterest;
 import com.cmg.comtogether.user.repository.UserRepository;
 import lombok.RequiredArgsConstructor;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.http.HttpStatusCode;
 import org.springframework.stereotype.Service;
-import org.springframework.web.client.RestClient;
-import org.springframework.web.util.UriComponentsBuilder;
-
-import java.util.Optional;
 import java.util.stream.Collectors;
 
 @Service
 @RequiredArgsConstructor
 public class ProductService {
 
-    private final RestClient restClient;
     private final UserRepository userRepository;
-
-    @Value("${naver.shopping.client-id}")
-    private String clientId;
-
-    @Value("${naver.shopping.client-secret}")
-    private String clientSecret;
-
-    @Value("${naver.shopping.base-url}")
-    private String baseUrl;
+    private final CacheMonitorService cacheMonitorService;
+    private final NaverProductService naverProductService;
 
     public NaverProductResponseDto searchProducts(String category, String query, int display, int start, String sort, String exclude) {
         String searchQuery = category + " " + query;
-        return getNaverProducts(searchQuery, display, start, sort, exclude);
+        NaverProductResponseDto result = naverProductService.getNaverProducts(searchQuery, display, start, sort, exclude);
+        cacheMonitorService.printCacheStats("naverProducts");
+        return result;
     }
 
     public NaverProductResponseDto recommendProducts(Long userId, String category, String query, int display, int start, String sort, String exclude) {
@@ -47,29 +36,8 @@ public NaverProductResponseDto recommendProducts(Long userId, String category, S
                 .map(Interest::getName)
                 .collect(Collectors.joining(" "));
         String searchQuery = category + " " + interestString + query;
-        return getNaverProducts(searchQuery, display, start, sort, exclude);
-    }
-
-    private NaverProductResponseDto getNaverProducts(String searchQuery, int display, int start, String sort, String exclude) {
-        return restClient.get()
-                .uri(UriComponentsBuilder
-                        .fromUriString(baseUrl)
-                        .queryParam("query", searchQuery)
-                        .queryParam("display", display)
-                        .queryParam("start", start)
-                        .queryParam("sort", sort)
-                        .queryParamIfPresent("exclude", Optional.ofNullable(exclude))
-                        .build()
-                        .toUri())
-                .header("X-Naver-Client-Id", clientId)
-                .header("X-Naver-Client-Secret", clientSecret)
-                .retrieve()
-                .onStatus(HttpStatusCode::is4xxClientError, (req, res) -> {
-                    throw new BusinessException(ErrorCode.INTERNAL_SERVER_ERROR);
-                })
-                .onStatus(HttpStatusCode::is5xxServerError, (req, res) -> {
-                    throw new BusinessException(ErrorCode.NAVER_API_ERROR);
-                })
-                .body(NaverProductResponseDto.class);
+        NaverProductResponseDto result = naverProductService.getNaverProducts(searchQuery, display, start, sort, exclude);
+        cacheMonitorService.printCacheStats("naverProducts");
+        return result;
     }
 }
diff --git a/backend/src/test/java/com/cmg/comtogether/oauth/service/KakaoServiceTest.java b/backend/src/test/java/com/cmg/comtogether/oauth/service/KakaoServiceTest.java
@@ -68,7 +68,7 @@ void getToken_success() {
                 .andRespond(withSuccess(responseJson, MediaType.APPLICATION_JSON));
 
         // when
-        TokenDto tokenDto = kakaoService.getToken(code);
+        TokenDto tokenDto = kakaoService.getToken(code, null);
 
         // then
         assertThat(tokenDto.getAccessToken()).isEqualTo("access-token");
@@ -81,7 +81,7 @@ public void getToken_fail_invalidCode() {
         server.expect(requestTo("https://kauth.kakao.com/oauth/token"))
                 .andRespond(withStatus(HttpStatus.BAD_REQUEST));
 
-        assertThatThrownBy(() -> kakaoService.getToken("invalid-code"))
+        assertThatThrownBy(() -> kakaoService.getToken("invalid-code", null))
                 .isInstanceOf(BusinessException.class)
                 .hasMessageContaining(ErrorCode.OAUTH_INVALID_CODE.getMessage());
     }
@@ -91,7 +91,7 @@ public void getToken_fail_invalidCode() {
     public void getToken_fail_serverError() {
         server.expect(requestTo("https://kauth.kakao.com/oauth/token"))
                 .andRespond(withServerError());
-        assertThatThrownBy(() -> kakaoService.getToken("any-code"))
+        assertThatThrownBy(() -> kakaoService.getToken("any-code", null))
                 .isInstanceOf(BusinessException.class)
                 .hasMessageContaining(ErrorCode.OAUTH_PROVIDER_ERROR.getMessage());
     }
diff --git a/backend/src/test/java/com/cmg/comtogether/oauth/service/OauthServiceTest.java b/backend/src/test/java/com/cmg/comtogether/oauth/service/OauthServiceTest.java
@@ -11,6 +11,7 @@
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Import;
 import org.springframework.test.context.bean.override.mockito.MockitoBean;
 
 import java.util.Optional;
@@ -62,12 +63,12 @@ private KakaoProfileDto createKakaoProfile(Long id, String email, String nicknam
     @DisplayName("성공 - 신규회원일 경우 DB에 저장 후 JWT 발급")
     void kakaoLogin_success_newUser() {
         // given
-        given(kakaoService.getToken(code)).willReturn(createKakaoToken());
+        given(kakaoService.getToken(code, null)).willReturn(createKakaoToken());
         given(kakaoService.getKakaoProfile("kakao-access-token"))
                 .willReturn(createKakaoProfile(12345L, "new@example.com", "new-user", "img-url"));
 
         // when
-        TokenDto tokenDto = oauthService.kakaoLogin(code);
+        TokenDto tokenDto = oauthService.kakaoLogin(code, null);
 
         // then
         assertThat(tokenDto.getAccessToken()).isNotBlank();
@@ -77,7 +78,7 @@ void kakaoLogin_success_newUser() {
         assertThat(saved).isPresent();
         assertThat(saved.get().getEmail()).isEqualTo("new@example.com");
 
-        verify(kakaoService).getToken(code);
+        verify(kakaoService).getToken(code, null);
         verify(kakaoService).getKakaoProfile("kakao-access-token");
     }
 
@@ -95,12 +96,12 @@ void kakaoLogin_success_existingUser() {
                 .build();
         userRepository.save(existingUser);
 
-        given(kakaoService.getToken(code)).willReturn(createKakaoToken());
+        given(kakaoService.getToken(code, null)).willReturn(createKakaoToken());
         given(kakaoService.getKakaoProfile("kakao-access-token"))
                 .willReturn(createKakaoProfile(12345L, "exist@example.com", "exist-user", "exist-img"));
 
         // when
-        TokenDto tokenDto = oauthService.kakaoLogin(code);
+        TokenDto tokenDto = oauthService.kakaoLogin(code, null);
 
         // then
         assertThat(tokenDto.getAccessToken()).isNotBlank();
@@ -110,7 +111,7 @@ void kakaoLogin_success_existingUser() {
         assertThat(found).isPresent();
         assertThat(found.get().getEmail()).isEqualTo("exist@example.com");
 
-        verify(kakaoService).getToken(code);
+        verify(kakaoService).getToken(code, null);
         verify(kakaoService).getKakaoProfile("kakao-access-token");
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -41,6 +41,9 @@ dependencies {`
`41`	`41`	`runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.11.5'`
`42`	`42`
`43`	`43`	`implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.12'`
	`44`	`+`
	`45`	`+ implementation 'org.springframework.boot:spring-boot-starter-cache'`
	`46`	`+ implementation 'com.github.ben-manes.caffeine:caffeine'`
`44`	`47`	`}`
`45`	`48`
`46`	`49`	`tasks.named('test') {`
Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,8 @@ public class OauthController {`
`24`	`24`	`@PostMapping("/kakao")`
`25`	`25`	`public ResponseEntity<ApiResponse<TokenDto>> kakaoLogin(@Valid @RequestBody OauthLoginRequestDto requestDto) {`
`26`	`26`	`String code = requestDto.getCode();`
`27`		`- TokenDto tokenDto = oauthService.kakaoLogin(code);`
	`27`	`+ String redirect_uri = requestDto.getRedirect_uri();`
	`28`	`+ TokenDto tokenDto = oauthService.kakaoLogin(code, redirect_uri);`
`28`	`29`	`return ResponseEntity.ok(ApiResponse.success(tokenDto));`
`29`	`30`	`}`
`30`	`31`	`}`
Original file line number	Diff line number	Diff line change
`@@ -10,4 +10,6 @@ public class OauthLoginRequestDto {`
`10`	`10`
`11`	`11`	`@NotBlank(message = "인가 코드는 필수 값입니다.")`
`12`	`12`	`private String code;`
	`13`	`+`
	`14`	`+ private String redirect_uri;`
`13`	`15`	`}`