WS 비정상 종료에 대해 SessionDisconnectEvent를 이용한 이벤트 감지 로직 구현

src/backend/chat_server/src/main/java/com/jootalkpia/chat_server/config/SessionEventListener.java

@@ -0,0 +1,21 @@
+package com.jootalkpia.chat_server.config;
+
+import com.jootalkpia.chat_server.config.interceptor.StompConnectInterceptor;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.event.EventListener;
+import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
+import org.springframework.stereotype.Component;
+import org.springframework.web.socket.messaging.SessionDisconnectEvent;
+
+@Component
+@RequiredArgsConstructor
+public class SessionEventListener {
+    private final StompConnectInterceptor stompConnectInterceptor;
+
+    @EventListener
+    public void handleWebSocketDisconnectListener(SessionDisconnectEvent event) {
+        StompHeaderAccessor headerAccessor = StompHeaderAccessor.wrap(event.getMessage());
+
+        stompConnectInterceptor.handleDisconnection(headerAccessor);
+    }
+}

src/backend/chat_server/src/main/java/com/jootalkpia/chat_server/config/interceptor/StompConnectInterceptor.java

@@ -36,6 +36,14 @@ public void afterSendCompletion(Message<?> message, MessageChannel channel, bool
         handleStompCommand(StompHeaderAccessor.wrap(message));
     }
 
+    public void handleDisconnection(StompHeaderAccessor accessor) {
+        if (!StompCommand.DISCONNECT.equals(accessor.getCommand())) {
+            return;
+        }
+
+        handleUserDisconnection(accessor);
+    }
+
     private boolean hasException(Exception ex) {
         return ex != null;
     }
@@ -53,14 +61,6 @@ private void handleConnection(StompHeaderAccessor accessor) {
         handleUserConnection(accessor);
     }
 
-    private void handleDisconnection(StompHeaderAccessor accessor) {
-        if (!StompCommand.DISCONNECT.equals(accessor.getCommand())) {
-            return;
-        }
-
-        handleUserDisconnection(accessor);
-    }
-
     private void handleUserConnection(StompHeaderAccessor accessor) {
         String sessionId = accessor.getSessionId();
         String userId = accessor.getFirstNativeHeader(HEADER_USER_ID);

src/backend/chat_server/src/main/java/com/jootalkpia/chat_server/config/interceptor/StompSubscriptionInterceptor.java

@@ -13,7 +13,6 @@
 import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
 import org.springframework.messaging.support.ChannelInterceptor;
 import org.springframework.stereotype.Component;
-import org.springframework.transaction.annotation.Transactional;
 
 import java.util.HashSet;
 import java.util.List;
@@ -45,13 +44,12 @@ public void afterSendCompletion(Message<?> message, MessageChannel channel, bool
         handleStompCommand(StompHeaderAccessor.wrap(message));
     }
 
-    @Transactional
     public void handleChatUnsubscription(StompHeaderAccessor accessor) {
         String sessionId = accessor.getSessionId();
         String userId = getUserIdFromSessionId(sessionId);
         String channelId = getChannelIdFromSessionId(sessionId);
 
-        if (userId != null && !userId.trim().isEmpty()) {
+        if (userId != null && !userId.trim().isEmpty() && !channelId.equals(DEFAULT_CHANNEL)) {
             updateChannelFromSession(sessionId);
             removeTabFromChannel(channelId, userId, sessionId);
             userChannelRepository.updateLastReadId(