인증서버 webflux로 전환

src/backend/auth_server/build.gradle

@@ -15,26 +15,29 @@ java {
 
 repositories {
     mavenCentral()
+    maven { url 'https://repo.spring.io/milestone' }
 }
 
 dependencyManagement {
     imports {
         mavenBom "org.springframework.cloud:spring-cloud-dependencies:2023.0.2"
+        mavenBom "org.springframework.security:spring-security-bom:6.3.0-M2"
     }
 }
 
 dependencies {
     //common-module
     implementation project(":common_module")
 
+    //webflux
+    implementation 'org.springframework.boot:spring-boot-starter-webflux'
+
     // Spring
-    implementation 'org.springframework.boot:spring-boot-starter-web'
     developmentOnly 'org.springframework.boot:spring-boot-devtools'
-    implementation 'org.springframework.boot:spring-boot-starter-actuator'
 
     //db
-    implementation group: 'org.postgresql', name: 'postgresql', version: '42.7.3'
-    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
+    implementation 'org.springframework.boot:spring-boot-starter-data-r2dbc'
+    runtimeOnly 'org.postgresql:r2dbc-postgresql'
 
     // Lombok
     compileOnly 'org.projectlombok:lombok'
@@ -43,17 +46,11 @@ dependencies {
     // Validation
     implementation 'org.springframework.boot:spring-boot-starter-validation'
 
-    // Test
-    testImplementation 'org.springframework.boot:spring-boot-starter-test'
-
-    //junit
-    testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
-
     // Spring Cloud OpenFeign
     implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
 
     //Swagger
-    implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.1.0'
+    implementation 'org.springdoc:springdoc-openapi-starter-webflux-ui:2.1.0'
 
     //JWT
     implementation group: 'io.jsonwebtoken', name: 'jjwt-api', version: '0.11.5'
@@ -65,7 +62,7 @@ dependencies {
 
     //Security
     implementation 'org.springframework.boot:spring-boot-starter-security'
-    testImplementation 'org.springframework.security:spring-security-test'
+    implementation 'org.springframework.security:spring-security-config'
 }
 
 tasks.named('test') {

src/backend/auth_server/src/main/java/com/jootalkpia/auth_server/AuthServerApplication.java

@@ -3,18 +3,30 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration;
+import org.springframework.boot.autoconfigure.security.servlet.UserDetailsServiceAutoConfiguration;
 import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.cloud.openfeign.FeignAutoConfiguration;
-import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.data.r2dbc.config.EnableR2dbcAuditing;
+import org.springframework.data.r2dbc.repository.config.EnableR2dbcRepositories;
+import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
 
-@EnableJpaAuditing
+@EnableR2dbcAuditing
 @EnableFeignClients
 @ImportAutoConfiguration(FeignAutoConfiguration.class)
-@SpringBootApplication(scanBasePackages = {
-        "com.jootalkpia.auth_server",
-        "com.jootalkpia.passport",
-        "com.jootalkpia.config",
-})
+@EnableR2dbcRepositories(basePackages = "com.jootalkpia.auth_server.user.repository")
+@EnableRedisRepositories(basePackages = "com.jootalkpia.auth_server.jwt")
+@SpringBootApplication(
+        scanBasePackages = {
+                "com.jootalkpia.auth_server",
+                "com.jootalkpia.passport",
+                "com.jootalkpia.config",
+        },
+        exclude = {
+                SecurityAutoConfiguration.class,
+                UserDetailsServiceAutoConfiguration.class
+        }
+)
 public class AuthServerApplication {
 
     public static void main(String[] args) {

src/backend/auth_server/src/main/java/com/jootalkpia/auth_server/client/kakao/KakaoApiClient.java

@@ -2,14 +2,28 @@
 
 
 import com.jootalkpia.auth_server.client.kakao.response.KakaoUserResponse;
-import org.springframework.cloud.openfeign.FeignClient;
+import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpHeaders;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestHeader;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Mono;
 
-@FeignClient(name = "kakaoApiClient", url = "https://kapi.kakao.com")
-public interface KakaoApiClient {
+@Service
+@RequiredArgsConstructor
+public class KakaoApiClient {
 
-    @GetMapping(value = "/v2/user/me")
-    KakaoUserResponse getUserInformation(@RequestHeader(HttpHeaders.AUTHORIZATION) String accessToken);
+    private final WebClient webClient = WebClient.builder()
+            .baseUrl("https://kapi.kakao.com")
+            .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
+            .build();
+
+    public Mono<KakaoUserResponse> getUserInfo(String accessToken) {
+        return webClient.get()
+                .uri("/v2/user/me")
+                .header(HttpHeaders.AUTHORIZATION, "Bearer " + accessToken)
+                .retrieve()
+                .bodyToMono(KakaoUserResponse.class);
+    }
 }
+

src/backend/auth_server/src/main/java/com/jootalkpia/auth_server/client/kakao/KakaoAuthWebClientService.java

@@ -0,0 +1,36 @@
+package com.jootalkpia.auth_server.client.kakao;
+
+import com.jootalkpia.auth_server.client.kakao.response.KakaoTokenResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.BodyInserters;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Mono;
+
+@Service
+@RequiredArgsConstructor
+public class KakaoAuthWebClientService {
+
+    @Value("${kakao.clientId}")
+    private String clientId;
+
+    private final WebClient kakaoWebClient = WebClient.builder()
+            .baseUrl("https://kauth.kakao.com")
+            .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_FORM_URLENCODED_VALUE)
+            .build();
+
+    public Mono<KakaoTokenResponse> getAccessToken(String code, String redirectUri) {
+        return kakaoWebClient.post()
+                .uri("/oauth/token")
+                .body(BodyInserters
+                        .fromFormData("grant_type", "authorization_code")
+                        .with("client_id", clientId)
+                        .with("redirect_uri", redirectUri)
+                        .with("code", code))
+                .retrieve()
+                .bodyToMono(KakaoTokenResponse.class);
+    }
+}

src/backend/auth_server/src/main/java/com/jootalkpia/auth_server/client/kakao/KakaoSocialService.java

@@ -2,65 +2,40 @@
 
 import com.jootalkpia.auth_server.client.dto.UserInfoResponse;
 import com.jootalkpia.auth_server.client.dto.UserLoginRequest;
-import com.jootalkpia.auth_server.client.kakao.response.KakaoAccessTokenResponse;
 import com.jootalkpia.auth_server.client.kakao.response.KakaoUserResponse;
 import com.jootalkpia.auth_server.client.service.SocialService;
 import com.jootalkpia.auth_server.exception.CustomException;
 import com.jootalkpia.auth_server.response.ErrorCode;
 import com.jootalkpia.auth_server.user.domain.Platform;
-import feign.FeignException;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import reactor.core.publisher.Mono;
 
 @Service
 @Slf4j
 @RequiredArgsConstructor
 public class KakaoSocialService implements SocialService {
 
-    private static final String AUTH_CODE = "authorization_code";
-
-    @Value("${kakao.clientId}")
-    private String clientId;
     private final KakaoApiClient kakaoApiClient;
-    private final KakaoAuthApiClient kakaoAuthApiClient;
+    private final KakaoAuthWebClientService kakaoAuthWebClientService;
 
     @Transactional
     @Override
-    public UserInfoResponse login(
+    public Mono<UserInfoResponse> login(
             final String authorizationCode,
             final UserLoginRequest loginRequest
     ) {
-        String accessToken;
-        try {
-            // 인가 코드로 Access Token + Refresh Token 받아오기
-            accessToken = getOAuth2Authentication(authorizationCode, loginRequest.redirectUri());
-        } catch (FeignException e) {
-            throw new CustomException(ErrorCode.AUTHENTICATION_CODE_EXPIRED);
-        }
-        // Access Token으로 유저 정보 불러오기
-        return getLoginDto(loginRequest.platform(), getUserInfo(accessToken));
-    }
-
-    private String getOAuth2Authentication(
-            final String authorizationCode,
-            final String redirectUri
-    ) {
-        KakaoAccessTokenResponse response = kakaoAuthApiClient.getOAuth2AccessToken(
-                AUTH_CODE,
-                clientId,
-                redirectUri,
-                authorizationCode
-        );
-        return response.accessToken();
-    }
-
-    private KakaoUserResponse getUserInfo(
-            final String accessToken
-    ) {
-        return kakaoApiClient.getUserInformation("Bearer " + accessToken);
+        return kakaoAuthWebClientService.getAccessToken(authorizationCode, loginRequest.redirectUri())
+                .flatMap(tokenResponse ->
+                        kakaoApiClient.getUserInfo(tokenResponse.getAccessToken())
+                )
+                .map(userResponse -> getLoginDto(loginRequest.platform(), userResponse))
+                .onErrorMap(Exception.class, e -> {
+                    log.error("❌ Kakao 로그인 실패: {}", e.getMessage(), e);
+                    return new CustomException(ErrorCode.AUTHENTICATION_CODE_EXPIRED);
+                });
     }
 
     private UserInfoResponse getLoginDto(
@@ -74,4 +49,4 @@ private UserInfoResponse getLoginDto(
                 userResponse.kakaoAccount().profile().nickname()
         );
     }
-}
+}

src/backend/auth_server/src/main/java/com/jootalkpia/auth_server/client/kakao/response/KakaoTokenResponse.java

@@ -0,0 +1,30 @@
+package com.jootalkpia.auth_server.client.kakao.response;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class KakaoTokenResponse {
+
+    @JsonProperty("access_token")
+    private String accessToken;
+
+    @JsonProperty("refresh_token")
+    private String refreshToken;
+
+    @JsonProperty("expires_in")
+    private Long expiresIn;
+
+    @JsonProperty("token_type")
+    private String tokenType;
+
+    // 필요에 따라 추가적인 필드들:
+    @JsonProperty("scope")
+    private String scope;
+
+    @JsonProperty("refresh_token_expires_in")
+    private Long refreshTokenExpiresIn;
+
+}

src/backend/auth_server/src/main/java/com/jootalkpia/auth_server/client/service/SocialService.java

@@ -1,9 +1,9 @@
 package com.jootalkpia.auth_server.client.service;
 
-
 import com.jootalkpia.auth_server.client.dto.UserInfoResponse;
 import com.jootalkpia.auth_server.client.dto.UserLoginRequest;
+import reactor.core.publisher.Mono;
 
 public interface SocialService {
-    UserInfoResponse login(final String authorizationToken, final UserLoginRequest loginRequest);
+    Mono<UserInfoResponse> login(final String authorizationToken, final UserLoginRequest loginRequest);
 }