prgrms-web-devcourse-final-project · sehee123 · Jul 25, 2025 · Jul 20, 2025 · Jul 20, 2025 · Jul 21, 2025
diff --git a/backend/src/main/java/io/f1/backend/domain/game/app/GameService.java b/backend/src/main/java/io/f1/backend/domain/game/app/GameService.java
@@ -63,8 +63,9 @@ public void gameStart(Long roomId, UserPrincipal principal) {
 
         timerService.startTimer(room, START_DELAY);
 
-        messageSender.send(destination, MessageType.GAME_START, toGameStartResponse(questions));
-        messageSender.send(
+        messageSender.sendBroadcast(
+                destination, MessageType.GAME_START, toGameStartResponse(questions));
+        messageSender.sendBroadcast(
                 destination,
                 MessageType.QUESTION_START,
                 toQuestionStartResponse(room, START_DELAY));

diff --git a/backend/src/main/java/io/f1/backend/domain/game/app/RoomService.java b/backend/src/main/java/io/f1/backend/domain/game/app/RoomService.java
@@ -21,6 +21,7 @@
 import io.f1.backend.domain.game.dto.RoomEventType;
 import io.f1.backend.domain.game.dto.request.RoomCreateRequest;
 import io.f1.backend.domain.game.dto.request.RoomValidationRequest;
+import io.f1.backend.domain.game.dto.response.ExitSuccessResponse;
 import io.f1.backend.domain.game.dto.response.GameSettingResponse;
 import io.f1.backend.domain.game.dto.response.PlayerListResponse;
 import io.f1.backend.domain.game.dto.response.RoomCreateResponse;
@@ -149,10 +150,12 @@ public void initializeRoomSocket(Long roomId, String sessionId, UserPrincipal pr
 
         String destination = getDestination(roomId);
 
-        messageSender.send(destination, MessageType.ROOM_SETTING, roomSettingResponse);
-        messageSender.send(destination, MessageType.GAME_SETTING, gameSettingResponse);
-        messageSender.send(destination, MessageType.PLAYER_LIST, playerListResponse);
-        messageSender.send(destination, MessageType.SYSTEM_NOTICE, systemNoticeResponse);
+        messageSender.sendPersonal(
+                getUserDestination(), MessageType.GAME_SETTING, gameSettingResponse, principal);
+
+        messageSender.sendBroadcast(destination, MessageType.ROOM_SETTING, roomSettingResponse);
+        messageSender.sendBroadcast(destination, MessageType.PLAYER_LIST, playerListResponse);
+        messageSender.sendBroadcast(destination, MessageType.SYSTEM_NOTICE, systemNoticeResponse);
     }
 
     public void exitRoom(Long roomId, String sessionId, UserPrincipal principal) {
@@ -166,6 +169,12 @@ public void exitRoom(Long roomId, String sessionId, UserPrincipal principal) {
 
             String destination = getDestination(roomId);
 
+            messageSender.sendPersonal(
+                    getUserDestination(),
+                    MessageType.EXIT_SUCCESS,
+                    new ExitSuccessResponse(true),
+                    principal);
+
             /* 방 삭제 */
             if (room.isLastPlayer(sessionId)) {
                 removeRoom(room);
@@ -185,8 +194,9 @@ public void exitRoom(Long roomId, String sessionId, UserPrincipal principal) {
 
             PlayerListResponse playerListResponse = toPlayerListResponse(room);
 
-            messageSender.send(destination, MessageType.PLAYER_LIST, playerListResponse);
-            messageSender.send(destination, MessageType.SYSTEM_NOTICE, systemNoticeResponse);
+            messageSender.sendBroadcast(destination, MessageType.PLAYER_LIST, playerListResponse);
+            messageSender.sendBroadcast(
+                    destination, MessageType.SYSTEM_NOTICE, systemNoticeResponse);
         }
     }
 
@@ -202,7 +212,8 @@ public void handlePlayerReady(Long roomId, String sessionId) {
 
         String destination = getDestination(roomId);
 
-        messageSender.send(destination, MessageType.PLAYER_LIST, toPlayerListResponse(room));
+        messageSender.sendBroadcast(
+                destination, MessageType.PLAYER_LIST, toPlayerListResponse(room));
     }
 
     public RoomListResponse getAllRooms() {
@@ -222,12 +233,11 @@ public RoomListResponse getAllRooms() {
 
     // todo 동시성적용
     public void chat(Long roomId, String sessionId, ChatMessage chatMessage) {
-
         Room room = findRoom(roomId);
 
         String destination = getDestination(roomId);
 
-        messageSender.send(destination, MessageType.CHAT, chatMessage);
+        messageSender.sendBroadcast(destination, MessageType.CHAT, chatMessage);
 
         if (!room.isPlaying()) {
             return;
@@ -240,12 +250,13 @@ public void chat(Long roomId, String sessionId, ChatMessage chatMessage) {
         if (answer.equals(chatMessage.message())) {
             room.increasePlayerCorrectCount(sessionId);
 
-            messageSender.send(
+            messageSender.sendBroadcast(
                     destination,
                     MessageType.QUESTION_RESULT,
                     toQuestionResultResponse(chatMessage.nickname(), answer));
-            messageSender.send(destination, MessageType.RANK_UPDATE, toRankUpdateResponse(room));
-            messageSender.send(
+            messageSender.sendBroadcast(
+                    destination, MessageType.RANK_UPDATE, toRankUpdateResponse(room));
+            messageSender.sendBroadcast(
                     destination,
                     MessageType.SYSTEM_NOTICE,
                     ofPlayerEvent(chatMessage.nickname(), RoomEventType.CORRECT_ANSWER));
@@ -262,7 +273,7 @@ public void chat(Long roomId, String sessionId, ChatMessage chatMessage) {
 
             // 타이머 추가하기
             timerService.startTimer(room, CONTINUE_DELAY);
-            messageSender.send(
+            messageSender.sendBroadcast(
                     destination,
                     MessageType.QUESTION_START,
                     toQuestionStartResponse(room, CONTINUE_DELAY));
@@ -275,20 +286,29 @@ public void reconnectSession(
         room.reconnectSession(oldSessionId, newSessionId);
 
         String destination = getDestination(roomId);
+        String userDestination = getUserDestination();
 
-        messageSender.send(
+        messageSender.sendBroadcast(
                 destination,
                 MessageType.SYSTEM_NOTICE,
                 ofPlayerEvent(principal.getUserNickname(), RoomEventType.RECONNECT));
 
         if (room.isPlaying()) {
-            // todo 랭킹 리스트 추가
-            messageSender.send(
-                    destination, MessageType.GAME_START, toGameStartResponse(room.getQuestions()));
-            messageSender.send(
-                    destination,
+            messageSender.sendPersonal(
+                    userDestination,
+                    MessageType.RANK_UPDATE,
+                    toRankUpdateResponse(room),
+                    principal);
+            messageSender.sendPersonal(
+                    userDestination,
+                    MessageType.GAME_START,
+                    toGameStartResponse(room.getQuestions()),
+                    principal);
+            messageSender.sendPersonal(
+                    userDestination,
                     MessageType.QUESTION_START,
-                    toQuestionStartResponse(room, START_DELAY));
+                    toQuestionStartResponse(room, START_DELAY),
+                    principal);
         } else {
             RoomSettingResponse roomSettingResponse = toRoomSettingResponse(room);
 
@@ -301,9 +321,12 @@ public void reconnectSession(
 
             PlayerListResponse playerListResponse = toPlayerListResponse(room);
 
-            messageSender.send(destination, MessageType.ROOM_SETTING, roomSettingResponse);
-            messageSender.send(destination, MessageType.GAME_SETTING, gameSettingResponse);
-            messageSender.send(destination, MessageType.PLAYER_LIST, playerListResponse);
+            messageSender.sendPersonal(
+                    userDestination, MessageType.ROOM_SETTING, roomSettingResponse, principal);
+            messageSender.sendPersonal(
+                    userDestination, MessageType.PLAYER_LIST, playerListResponse, principal);
+            messageSender.sendPersonal(
+                    userDestination, MessageType.GAME_SETTING, gameSettingResponse, principal);
         }
     }
 
@@ -378,4 +401,8 @@ private void removePlayer(Room room, String sessionId, Player removePlayer) {
         room.removeSessionId(sessionId);
         room.removeValidatedUserId(removePlayer.getId());
     }
+
+    private String getUserDestination() {
+        return "/queue";
+    }
 }
diff --git a/backend/src/main/java/io/f1/backend/domain/game/app/TimerService.java b/backend/src/main/java/io/f1/backend/domain/game/app/TimerService.java
@@ -44,11 +44,11 @@ public void startTimer(Room room, int delaySec) {
     private void handleTimeout(Room room) {
         String destination = getDestination(room.getId());
 
-        messageSender.send(
+        messageSender.sendBroadcast(
                 destination,
                 MessageType.QUESTION_RESULT,
                 toQuestionResultResponse(NONE_CORRECT_USER, room.getCurrentQuestion().getAnswer()));
-        messageSender.send(
+        messageSender.sendBroadcast(
                 destination,
                 MessageType.SYSTEM_NOTICE,
                 ofPlayerEvent(NONE_CORRECT_USER, RoomEventType.TIMEOUT));
@@ -64,7 +64,7 @@ private void handleTimeout(Room room) {
         room.increaseCurrentRound();
 
         startTimer(room, CONTINUE_DELAY);
-        messageSender.send(
+        messageSender.sendBroadcast(
                 destination,
                 MessageType.QUESTION_START,
                 toQuestionStartResponse(room, CONTINUE_DELAY));

diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/MessageType.java b/backend/src/main/java/io/f1/backend/domain/game/dto/MessageType.java
@@ -9,5 +9,6 @@ public enum MessageType {
     CHAT,
     QUESTION_RESULT,
     RANK_UPDATE,
+    EXIT_SUCCESS,
     QUESTION_START
 }
diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/response/ExitSuccessResponse.java b/backend/src/main/java/io/f1/backend/domain/game/dto/response/ExitSuccessResponse.java
@@ -0,0 +1,3 @@
+package io.f1.backend.domain.game.dto.response;
+
+public record ExitSuccessResponse(boolean isSuccess) {}
diff --git a/backend/src/main/java/io/f1/backend/domain/game/model/Room.java b/backend/src/main/java/io/f1/backend/domain/game/model/Room.java
@@ -91,8 +91,8 @@ public void updateTimer(ScheduledFuture<?> timer) {
         this.timer = timer;
     }
 
-    public void removeSessionId(String sessionId) {
-        this.playerSessionMap.remove(sessionId);
+    public boolean removeSessionId(String sessionId) {
+        return this.playerSessionMap.remove(sessionId) != null;
     }
 
     public void removeValidatedUserId(Long userId) {
@@ -135,10 +135,7 @@ public boolean isExit(String sessionId) {
     }
 
     public boolean isLastPlayer(String sessionId) {
-        long connectedCount =
-                playerSessionMap.values().stream()
-                        .filter(player -> player.getState() == ConnectionState.CONNECTED)
-                        .count();
+        long connectedCount = playerSessionMap.size();
         return connectedCount == 1 && playerSessionMap.containsKey(sessionId);
     }
 }
diff --git a/backend/src/main/java/io/f1/backend/domain/game/websocket/MessageSender.java b/backend/src/main/java/io/f1/backend/domain/game/websocket/MessageSender.java
@@ -2,6 +2,7 @@
 
 import io.f1.backend.domain.game.dto.MessageType;
 import io.f1.backend.domain.game.dto.response.DefaultWebSocketResponse;
+import io.f1.backend.domain.user.dto.UserPrincipal;
 
 import lombok.RequiredArgsConstructor;
 
@@ -14,8 +15,14 @@ public class MessageSender {
 
     private final SimpMessagingTemplate messagingTemplate;
 
-    public <T> void send(String destination, MessageType type, T message) {
+    public <T> void sendBroadcast(String destination, MessageType type, T message) {
         messagingTemplate.convertAndSend(
                 destination, new DefaultWebSocketResponse<>(type, message));
     }
+
+    public <T> void sendPersonal(
+            String destination, MessageType type, T message, UserPrincipal principal) {
+        messagingTemplate.convertAndSendToUser(
+                principal.getName(), destination, new DefaultWebSocketResponse<>(type, message));
+    }
 }
diff --git a/backend/src/main/java/io/f1/backend/domain/game/websocket/service/SessionService.java b/backend/src/main/java/io/f1/backend/domain/game/websocket/service/SessionService.java
@@ -65,7 +65,6 @@ public void handleUserDisconnect(String sessionId, UserPrincipal principal) {
                     /* 재연결 실패  */
                     if (sessionId.equals(userIdSession.get(userId))) {
                         roomService.exitIfNotPlaying(roomId, sessionId, principal);
-                        // 메세지 응답 추가
                     }
                     removeSession(sessionId, userId);
                 },

diff --git a/backend/src/main/java/io/f1/backend/global/config/SecurityConfig.java b/backend/src/main/java/io/f1/backend/global/config/SecurityConfig.java
@@ -50,6 +50,7 @@ public SecurityFilterChain userFilterChain(HttpSecurity http) throws Exception {
                                                 "/signup",
                                                 "/css/**",
                                                 "/js/**",
+                                                "/**",
                                                 "/admin/login")
                                         .permitAll()
                                         .requestMatchers(HttpMethod.OPTIONS, "/**")

diff --git a/backend/src/main/resources/application.yml b/backend/src/main/resources/application.yml
@@ -64,5 +64,4 @@ server:
         same-site: None
         secure: true
         http-only: true
-      timeout: ${SESSION_TIMEOUT}
-
+      timeout: ${SESSION_TIMEOUT}
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		package io.f1.backend.domain.game.dto.response;

		public record ExitSuccessResponse(boolean isSuccess) {}
dlsrks1021 marked this conversation as resolved. Outdated Show resolved Hide resolved