#90 chatforyou 서버 scaleout 대응 :: fallback 로직 수정 및 전체 코드 정리

SeJonJ · SeJonJ · commit afb6893ced14 · 2025-09-13T16:28:28.000+09:00
diff --git a/nodejs-frontend/static/js/rtc/dataChannelChatting.js b/nodejs-frontend/static/js/rtc/dataChannelChatting.js
@@ -4,7 +4,7 @@
 const dataChannelChatting = {
     $element: $('.floating-chat'),
     $sendMessageBtn : $('#sendMessageBtn'),
-    $userTextInput :  $('.text-box'),
+    $userTextInput :  $('#userTextInput'),
     $messagesContainer : $('.messages'),
     isCheckMinioPage : false,
     init: function() {
@@ -24,13 +24,16 @@ const dataChannelChatting = {
         self.$userTextInput.on('keydown', function(event) {
             if (event.shiftKey && event.which === 13) {
                 // shift + enter 사용 시 한줄 띄우기
-            } else if (event.which === 13) {
+            } else if (event.which === 13 && self.$userTextInput.text().trim() !== '') {
                 event.preventDefault(); // 기본 동작(한줄 띄우기)을 방지
                 dataChannel.showNewMessage(self.parseMessage(self.$userTextInput), 'self');
             }
         });
 
-        this.$sendMessageBtn.on("click", function(){
+        self.$sendMessageBtn.on("click", function(){
+            if(self.$userTextInput.text().trim() === ''){
+                return;
+            }
             dataChannel.showNewMessage(self.parseMessage(self.$userTextInput), 'self');
         });
 
diff --git a/nodejs-frontend/static/js/rtc/kurento-service.js b/nodejs-frontend/static/js/rtc/kurento-service.js
@@ -226,7 +226,6 @@ function register() {
         // 방 정보를 서버에서 조회
         const url = window.__CONFIG__.API_BASE_URL + '/chat/room/' + new URLSearchParams(window.location.search).get('roomId');
         const successCallback = (response) => {
-            debugger;
             if(response.result === 'REDIRECT_ROOM'){
                 console.log('room redirect to : ', response.data.roomId);
                 location.reload();
diff --git a/nodejs-frontend/templates/kurentoroom.html b/nodejs-frontend/templates/kurentoroom.html
@@ -158,8 +158,8 @@ <h2 class="justify-content-md-center" id="room-header"></h2>
                             <input type="file" id="file" style="display: none;"/>
                         </div>
                     </div>
-                    <div class="text-box" contenteditable="true" disabled="true"></div>
-                    <button id="sendMessage">send</button>
+                    <div class="text-box" id="userTextInput" contenteditable="true" disabled="true"></div>
+                    <button id="sendMessageBtn">send</button>
                 </div>
             </div>
         </div>
diff --git a/springboot-backend/src/main/java/webChat/controller/ChatRoomController.java b/springboot-backend/src/main/java/webChat/controller/ChatRoomController.java
@@ -10,12 +10,9 @@
 import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.*;
-import webChat.model.redis.DataType;
-import webChat.model.redis.RedisKeyPrefix;
 import webChat.model.response.ChatForYouResponseResult;
 import webChat.model.routing.RoomRoutingInfo;
 import webChat.model.routing.RoutingCookie;
-import webChat.service.redis.RedisService;
 import webChat.model.response.common.ChatForYouResponse;
 import webChat.model.room.ChatRoom;
 import webChat.model.room.RoomState;
@@ -40,7 +37,6 @@ public class ChatRoomController {
     private final ChatRoomService chatRoomService;
     private final RoutingService routingService;
     private final RoutingInstanceProvider instanceProvider;
-    private final RedisService redisService;
 
     // 채팅방 생성
     @PostMapping("/room")
@@ -77,13 +73,14 @@ public ResponseEntity<ChatForYouResponse> joinRoom(
         ChatRoom chatRoom = chatRoomService.findRoomById(roomId);
 
         if (StringUtil.isNullOrEmpty(chatRoom.getInstanceId()) || !instanceProvider.isHealthy(chatRoom.getInstanceId())){
-            // TODO 서버가 죽었을때 예외처리 필요 :: 임시 조치로 메인 대시보드로 이동
+            // TODO 서버가 죽었을때 예외처리 필요 :: 방 삭제 및 임시 조치로 메인 대시보드로 이동
+            chatRoomService.delChatRoom(roomId);
             return ResponseEntity.ok(ChatForYouResponse.ofRedirectRoom(chatRoom, ChatForYouResponseResult.REDIRECT_DASHBOARD));
         }
 
 
         if (!instanceProvider.getInstanceId().equals(chatRoom.getInstanceId())) {
-            RoomRoutingInfo roomRoutingInfo = redisService.getRedisDataByDataType(RedisKeyPrefix.ROOM_ROUTING_PREFIX.getPrefix()+roomId, DataType.ROOM_ROUTING, RoomRoutingInfo.class);
+            RoomRoutingInfo roomRoutingInfo = routingService.getRoomRoutingInfoByRoomId(roomId);
             int redirectCount = routingService.getRedirectCount(request);
             if(redirectCount > 3){
                 return ResponseEntity.ok(ChatForYouResponse.ofRedirectRoom(chatRoom, ChatForYouResponseResult.REDIRECT_DASHBOARD));
diff --git a/springboot-backend/src/main/java/webChat/controller/HealthController.java b/springboot-backend/src/main/java/webChat/controller/HealthController.java
@@ -1,6 +1,5 @@
 package webChat.controller;
 
-import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -12,7 +11,6 @@
 import webChat.model.routing.RoutingCookie;
 import webChat.service.routing.CookieCheckEvent;
 import webChat.service.routing.RoutingInstanceProvider;
-import webChat.service.routing.RoutingService;
 import webChat.utils.StringUtil;
 
 /**
@@ -25,7 +23,6 @@
 public class HealthController {
     private final RoutingInstanceProvider instanceProvider;
     private final CookieCheckEvent cookieCheckEvent;
-    private final RoutingService routingService;
 
     @Value("${cookie.check.domain:}")
     private String cookieCheckDomain;
@@ -36,7 +33,7 @@ public class HealthController {
      * @return
      */
     @GetMapping("/cookie")
-    public ResponseEntity<String> cookieHealth(HttpServletRequest request, HttpServletResponse response) {
+    public ResponseEntity<String> cookieHealth(HttpServletResponse response) {
         if (StringUtil.isNullOrEmpty(cookieCheckDomain)) { // 운영환경은 세팅, 로컬은 빈값
             response.addCookie(new jakarta.servlet.http.Cookie(RoutingCookie.CHATFORYOU_SERVER_COOKIE.getName(), instanceProvider.getInstanceId()));
         }
diff --git a/springboot-backend/src/main/java/webChat/controller/LoginController.java b/springboot-backend/src/main/java/webChat/controller/LoginController.java
@@ -6,7 +6,7 @@
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
-@RequestMapping("/chatforyou/api/file")
+@RequestMapping("/chatforyou/api/login")
 public class LoginController {
 
     @GetMapping("/chatlogin")
diff --git a/springboot-backend/src/main/java/webChat/model/kafka/KafkaEvent.java b/springboot-backend/src/main/java/webChat/model/kafka/KafkaEvent.java
@@ -1,6 +1,5 @@
 package webChat.model.kafka;
 
-import com.fasterxml.jackson.annotation.JsonIgnore;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
@@ -12,14 +11,4 @@
 @SuperBuilder
 public abstract class KafkaEvent {
     private long publishedAt;
-
-//    TODO 공통화 처리 필요
-//    @JsonIgnore
-//    public static KafkaServerEvent of(KafkaEvent event){
-//        return (KafkaServerEvent) event;
-//    }
-//    @JsonIgnore
-//    public static KafkaRoomEvent of(KafkaEvent event){
-//        return (KafkaRoomEvent) event;
-//    }
 }
diff --git a/springboot-backend/src/main/java/webChat/model/kafka/KafkaSendKey.java b/springboot-backend/src/main/java/webChat/model/kafka/KafkaSendKey.java
@@ -1,8 +1,5 @@
 package webChat.model.kafka;
 
-import lombok.Getter;
-
-// 키는 파티셔닝 전략에 맞게 명명
 public class KafkaSendKey {
     public static final String EVENT_TYPE = "event-type";
 }
diff --git a/springboot-backend/src/main/java/webChat/model/kafka/KafkaServerEvent.java b/springboot-backend/src/main/java/webChat/model/kafka/KafkaServerEvent.java
@@ -78,10 +78,6 @@ public static KafkaServerEvent createCookieDiscovered(String instanceId, String
                 .build();
     }
 
-    public String getEventId() {
-        return instanceId + "_" + eventType + "_" + getPublishedAt();
-    }
-
     /**
      * 쿠키 관련 이벤트인지 확인
      */
diff --git a/springboot-backend/src/main/java/webChat/service/chatroom/ChatRoomService.java b/springboot-backend/src/main/java/webChat/service/chatroom/ChatRoomService.java
@@ -9,7 +9,6 @@
 import org.springframework.stereotype.Service;
 import webChat.model.redis.RedisKeyPrefix;
 import webChat.model.routing.RoomRoutingInfo;
-import webChat.service.routing.InstanceProvider;
 import webChat.controller.ExceptionController;
 import webChat.model.chat.ChatType;
 import webChat.model.redis.DataType;
diff --git a/springboot-backend/src/main/java/webChat/service/kafka/ChatRoomEventConsumer.java b/springboot-backend/src/main/java/webChat/service/kafka/ChatRoomEventConsumer.java
@@ -8,15 +8,12 @@
 import org.springframework.stereotype.Component;
 import webChat.model.kafka.KafkaEvent;
 import webChat.model.kafka.KafkaRoomEvent;
-import webChat.model.kafka.KafkaServerEvent;
 import webChat.model.kafka.RoomEvent;
 import webChat.model.redis.DataType;
 import webChat.model.room.ChatRoom;
 import webChat.service.chatroom.SseService;
 import webChat.service.redis.impl.RedisServiceImpl;
 
-import java.util.Map;
-
 @Component
 @Slf4j
 @AllArgsConstructor
diff --git a/springboot-backend/src/main/java/webChat/service/kurento/KurentoHandler.java b/springboot-backend/src/main/java/webChat/service/kurento/KurentoHandler.java
@@ -47,7 +47,6 @@ public class KurentoHandler extends TextWebSocketHandler {
     private final KurentoClient kurentoClient;
 
     private final RedisService redisService;
-    private final ChatRoomService chatRoomService;
     private final KurentoParticipantService participantService;
     private final ChatKafkaProducer chatKafkaProducer;
     private final Map<String, MediaPipeline> kurentoPiplineMap = KurentoPiplineMap.getInstance();
diff --git a/springboot-backend/src/main/java/webChat/service/routing/CookieCheckEvent.java b/springboot-backend/src/main/java/webChat/service/routing/CookieCheckEvent.java
@@ -72,32 +72,32 @@ public class CookieCheckEvent {
     public void collectOwnCookieAsync() throws InterruptedException, BadRequestException {
         instanceProvider.initInstanceId();
         // Kafka consumer 준비 대기
-        waitForKafkaConsumerReady();
+        waitKafkaConsumerReady();
 
         log.info("=== 인스턴스 제공 이벤트 init 시작 ===");
         instanceProvider.initInstanceProviderEvent();
 
         log.info("=== 최적화 쿠키 수집 시작 ===");
 
         // Phase 1: 파드간 협력
-        String cookie = tryCollectFromPeersWithRetry();
+        String cookie = collectFromPeers();
         if (cookie != null) {
             saveCookieAndComplete(cookie);
             return;
         }
 
         // Phase 2: 85% 목표 성공률 기반 최적화
-        cookie = tryOptimizedCollectionImproved(instanceProvider.getActiveServers().size());
+        cookie = tryOptimizedCollection(instanceProvider.getActiveServers().size(), false);
         if (cookie != null) {
             saveCookieAndComplete(cookie);
             return;
         }
 
         // Phase 3: 개선된 Fallback
-        handleImprovedFallback();
+        handleFallback();
     }
 
-    private void waitForKafkaConsumerReady() throws InterruptedException {
+    private void waitKafkaConsumerReady() throws InterruptedException {
         for (int i = 0; i < 20; i++) {
             if (instanceProvider != null && !instanceProvider.getActiveServers().isEmpty()) break;
             Thread.sleep(500);
@@ -107,7 +107,7 @@ private void waitForKafkaConsumerReady() throws InterruptedException {
     /**
      * Phase 1: 파드간 협력
      */
-    private String tryCollectFromPeersWithRetry() throws InterruptedException {
+    private String collectFromPeers() throws InterruptedException {
         for (int attempt = 0; attempt < PHASE1_MAX_RETRIES; attempt++) {
             String cookie = tryCollectFromPeers();
             if (cookie != null) return cookie;
@@ -142,7 +142,7 @@ private String tryCollectFromPeers() {
                     log.debug("발견된 파드: {} -> 쿠키: {}", peerInstanceId, peerCookie);
 
                     // 실제 nginx 응답을 통한 검증만 수행
-                    if (validateActualCookie(peerCookie)) {
+                    if (validateCookie(peerCookie)) {
                         log.info("=== Phase 1 성공: 기존 쿠키 검증 완료 ===");
                         return peerCookie;
                     }
@@ -161,11 +161,11 @@ private String tryCollectFromPeers() {
     /**
      * Phase 2: Dynamic Retry Count 최적화
      */
-    private String tryOptimizedCollectionImproved(int activePods) {
+    private String tryOptimizedCollection(int activePods, boolean isFallback) {
         try {
             log.info("=== Phase 2: 네트워크 요청을 통해 확률적 cookie 체크 수행 ===");
 
-            int optimalRetries = calculateOptimalRetryCount(activePods);
+            int optimalRetries = calculateRetryCount(activePods, isFallback);
 
             log.info("활성 파드 수: {}, 시도 횟수: {}", activePods, optimalRetries);
 
@@ -209,7 +209,11 @@ private String tryOptimizedCollectionImproved(int activePods) {
                 }
             }
 
-            log.info("=== Phase 2 실패: {}회 최적화 시도 실패, Phase 3 Fallback 으로 이동 ===", optimalRetries);
+            if (isFallback) {
+                log.info("=== Phase 2 실패: {} 회 최적화 시도 실패, Phase 3 Fallback 으로 이동 ===", optimalRetries);
+            } else {
+                log.info("=== Phase 2 재시도 실패: {} 회 최적화 시도 실패, 파드 재시작 진행 ===", optimalRetries);
+            }
             return null;
 
         } catch (Exception e) {
@@ -224,15 +228,18 @@ private String tryOptimizedCollectionImproved(int activePods) {
      * @param activePods 활성 파드 수 (N)
      * @return 최적 재시도 횟수
      */
-    private int calculateOptimalRetryCount(int activePods) {
+    private int calculateRetryCount(int activePods, boolean isFallback) {
         if (activePods <= 1) {
             return MIN_RETRY_COUNT;
         }
 
+        // fallback 시 90% 를 목표로 재시도
+        double targetRate = isFallback ? 0.90 : TARGET_SUCCESS_RATE;
+
         // p = TARGET_SUCCESS_RATE (0.85)
         // N = activePods
         double probability = 1.0 / activePods;
-        double optimalRetries = Math.log(1 - TARGET_SUCCESS_RATE) / Math.log(1 - probability);
+        double optimalRetries = Math.log(1 - targetRate) / Math.log(1 - probability);
 
         int result = (int) Math.ceil(optimalRetries);
 
@@ -241,15 +248,15 @@ private int calculateOptimalRetryCount(int activePods) {
         result = Math.min(result, MAX_RETRY_COUNT);
 
         log.info("최적화 계산: N = [{}], 목표성공률 = [{}%], 계산된시도횟수 = [{}], 적용시도횟수 = [{}]",
-                activePods, (int)(TARGET_SUCCESS_RATE * 100), (int)Math.ceil(optimalRetries), result);
+                activePods, (int)(targetRate * 100), (int)Math.ceil(optimalRetries), result);
 
         return result;
     }
 
     /**
      * 실제 쿠키 검증 
      */
-    private boolean validateActualCookie(String cookie) {
+    private boolean validateCookie(String cookie) {
         try {
             HttpHeaders headers = new HttpHeaders();
             headers.add("Cookie", RoutingCookie.CHATFORYOU_SERVER_COOKIE.getName() + "=" + cookie);
@@ -274,9 +281,9 @@ private boolean validateActualCookie(String cookie) {
     /**
      * 개선된 Fallback 
      */
-    private void handleImprovedFallback() throws BadRequestException {
-        // Phase 2: 90% 목표 성공률 기반 최적화
-        String cookie = tryOptimizedCollectionImproved(instanceProvider.getActiveServers().size());
+    private void handleFallback() throws BadRequestException {
+        // Phase 2 retry : 90% 목표 성공률 기반 최적화
+        String cookie = tryOptimizedCollection(instanceProvider.getActiveServers().size(), true);
         if (cookie != null) {
             saveCookieAndComplete(cookie);
             return;
@@ -362,7 +369,7 @@ public void handleCookieResponse(KafkaServerEvent event) {
 
                 if (cookie != null && !cookie.isEmpty()) {
                     // 응답받은 실제 쿠키로 검증
-                    if (validateActualCookie(cookie)) {
+                    if (validateCookie(cookie)) {
                         saveCookieAndComplete(cookie);
                         log.debug("쿠키 응답으로부터 성공적으로 실제 nginx 쿠키 획득: {}", cookie);
                     }
@@ -387,7 +394,7 @@ public void handleCookieDiscovered(KafkaServerEvent event) {
                 if (cookieInfo != null && cookieInfo.isValidForDiscovery() && !cookieCollected) {
                     String discoveredCookie = cookieInfo.getCookie();
                     // 발견된 실제 쿠키로 검증
-                    if (validateActualCookie(discoveredCookie)) {
+                    if (validateCookie(discoveredCookie)) {
                         saveCookieAndComplete(discoveredCookie);
                         log.debug("발견된 쿠키로부터 성공적으로 실제 nginx 쿠키 획득: {}", discoveredCookie);
                     }
diff --git a/springboot-backend/src/main/java/webChat/service/routing/RoutingService.java b/springboot-backend/src/main/java/webChat/service/routing/RoutingService.java
@@ -3,9 +3,11 @@
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
 import org.apache.coyote.BadRequestException;
+import webChat.model.routing.RoomRoutingInfo;
 import webChat.model.routing.RoutingCookie;
 
 public interface RoutingService {
+    RoomRoutingInfo getRoomRoutingInfoByRoomId(String roomId) throws BadRequestException;
     String getNginxCookie(HttpServletRequest request);
     String getCookie(HttpServletRequest request, RoutingCookie routingCookie);
     void setRoutingInfo(HttpServletRequest request, HttpServletResponse response, String roomId, String selectedInstanceId) throws BadRequestException;
diff --git a/springboot-backend/src/main/java/webChat/service/routing/impl/RoutingServiceImpl.java b/springboot-backend/src/main/java/webChat/service/routing/impl/RoutingServiceImpl.java
@@ -71,6 +71,11 @@ public int getRedirectCount(HttpServletRequest request){
         return StringUtil.isNullOrEmpty(roomRedirectCount) ? 0 : Integer.parseInt(roomRedirectCount);
     }
 
+    @Override
+    public RoomRoutingInfo getRoomRoutingInfoByRoomId(String roomId) throws BadRequestException {
+         return redisService.getRedisDataByDataType(RedisKeyPrefix.ROOM_ROUTING_PREFIX.getPrefix() + roomId, DataType.ROOM_ROUTING, RoomRoutingInfo.class);
+    }
+
     @Override
     public String getNginxCookie(HttpServletRequest request) {
         Cookie[] cookies = request.getCookies();

Original file line number	Diff line number	Diff line change
`@@ -1,8 +1,5 @@`
`1`	`1`	`package webChat.model.kafka;`
`2`	`2`
`3`		`-import lombok.Getter;`
`4`		`-`
`5`		`-// 키는 파티셔닝 전략에 맞게 명명`
`6`	`3`	`public class KafkaSendKey {`
`7`	`4`	`public static final String EVENT_TYPE = "event-type";`
`8`	`5`	`}`