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/auth/dto/CurrentUserAndAdminResponse.java b/backend/src/main/java/io/f1/backend/domain/auth/dto/CurrentUserAndAdminResponse.java
@@ -3,21 +3,19 @@
 import io.f1.backend.domain.admin.dto.AdminPrincipal;
 import io.f1.backend.domain.user.dto.UserPrincipal;
 
-public record CurrentUserAndAdminResponse(Long id, String name, String role, String providerId) {
+public record CurrentUserAndAdminResponse(Long id, String name, String role) {
 
     public static CurrentUserAndAdminResponse from(UserPrincipal userPrincipal) {
         return new CurrentUserAndAdminResponse(
                 userPrincipal.getUserId(),
                 userPrincipal.getUserNickname(),
-                UserPrincipal.ROLE_USER,
-                userPrincipal.getName());
+                UserPrincipal.ROLE_USER);
     }
 
     public static CurrentUserAndAdminResponse from(AdminPrincipal adminPrincipal) {
         return new CurrentUserAndAdminResponse(
                 adminPrincipal.getAuthenticationAdmin().adminId(),
                 adminPrincipal.getUsername(),
-                AdminPrincipal.ROLE_ADMIN,
-                null);
+                AdminPrincipal.ROLE_ADMIN);
     }
 }
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
@@ -67,8 +67,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));
@@ -86,7 +87,7 @@ public void handlePlayerReady(Long roomId, String sessionId) {
 
         PlayerListResponse playerListResponse = toPlayerListResponse(room);
         log.info(playerListResponse.toString());
-        messageSender.send(destination, MessageType.PLAYER_LIST, playerListResponse);
+        messageSender.sendBroadcast(destination, MessageType.PLAYER_LIST, playerListResponse);
     }
 
     public void changeGameSetting(
@@ -161,7 +162,7 @@ private void toggleReadyIfPossible(Room room, Player player) {
     private void broadcastGameSetting(Room room) {
         String destination = getDestination(room.getId());
         Quiz quiz = quizService.getQuizWithQuestionsById(room.getGameSetting().getQuizId());
-        messageSender.send(
+        messageSender.sendBroadcast(
                 destination,
                 MessageType.GAME_SETTING,
                 toGameSettingResponse(room.getGameSetting(), quiz));

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
@@ -1,6 +1,5 @@
 package io.f1.backend.domain.game.app;
 
-import static io.f1.backend.domain.game.app.GameService.START_DELAY;
 import static io.f1.backend.domain.game.mapper.RoomMapper.ofPlayerEvent;
 import static io.f1.backend.domain.game.mapper.RoomMapper.toGameSetting;
 import static io.f1.backend.domain.game.mapper.RoomMapper.toGameSettingResponse;
@@ -21,6 +20,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 +149,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 +168,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 +193,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);
         }
     }
 
@@ -212,7 +221,7 @@ public void chat(Long roomId, String sessionId, ChatMessage chatMessage) {
 
         String destination = getDestination(roomId);
 
-        messageSender.send(destination, MessageType.CHAT, chatMessage);
+        messageSender.sendBroadcast(destination, MessageType.CHAT, chatMessage);
 
         if (!room.isPlaying()) {
             return;
@@ -225,12 +234,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));
@@ -247,7 +257,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));
@@ -260,20 +270,30 @@ 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,
-                    MessageType.QUESTION_START,
-                    toQuestionStartResponse(room, START_DELAY));
+            messageSender.sendPersonal(
+                    userDestination,
+                    MessageType.SYSTEM_NOTICE,
+                    ofPlayerEvent(
+                            principal.getUserNickname(), RoomEventType.RECONNECT_PRIVATE_NOTICE),
+                    principal);
+            messageSender.sendPersonal(
+                    userDestination,
+                    MessageType.RANK_UPDATE,
+                    toRankUpdateResponse(room),
+                    principal);
+            messageSender.sendPersonal(
+                    userDestination,
+                    MessageType.GAME_START,
+                    toGameStartResponse(room.getQuestions()),
+                    principal);
         } else {
             RoomSettingResponse roomSettingResponse = toRoomSettingResponse(room);
 
@@ -286,9 +306,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);
         }
     }
 
@@ -362,4 +385,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/RoomEventType.java b/backend/src/main/java/io/f1/backend/domain/game/dto/RoomEventType.java
@@ -7,7 +7,8 @@ public enum RoomEventType {
     END(null),
     CORRECT_ANSWER(SystemNoticeMessage.CORRECT_ANSWER),
     TIMEOUT(SystemNoticeMessage.TIMEOUT),
-    RECONNECT(SystemNoticeMessage.RECONNECT);
+    RECONNECT(SystemNoticeMessage.RECONNECT),
+    RECONNECT_PRIVATE_NOTICE(SystemNoticeMessage.RECONNECT_PRIVATE_NOTICE);
 
     private final SystemNoticeMessage systemMessage;
 
@@ -17,7 +18,7 @@ public enum RoomEventType {
 
     public String getMessage(String nickname) {
 
-        if (this == TIMEOUT) {
+        if (this == TIMEOUT || this == RECONNECT_PRIVATE_NOTICE) {
             return systemMessage.getMessage();
         }
 

diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/SystemNoticeMessage.java b/backend/src/main/java/io/f1/backend/domain/game/dto/SystemNoticeMessage.java
@@ -5,7 +5,8 @@ public enum SystemNoticeMessage {
     EXIT(" 님이 퇴장하셨습니다"),
     CORRECT_ANSWER(" 님 정답입니다 !"),
     TIMEOUT("땡 ~ ⏰ 제한 시간 초과!"),
-    RECONNECT(" 님이 재연결 되었습니다.");
+    RECONNECT(" 님이 재연결 되었습니다. "),
+    RECONNECT_PRIVATE_NOTICE("⚠️다음 라운드부터 참여하실 수 있습니다");
 
     private final String message;
 

diff --git a/backend/src/main/java/io/f1/backend/domain/game/dto/request/QuizChangeRequest.java b/backend/src/main/java/io/f1/backend/domain/game/dto/request/QuizChangeRequest.java
@@ -36,6 +36,6 @@ public void afterChange(Room room, MessageSender messageSender) {
         PlayerListResponse response = toPlayerListResponse(room);
 
         log.info(response.toString());
-        messageSender.send(destination, MessageType.PLAYER_LIST, response);
+        messageSender.sendBroadcast(destination, MessageType.PLAYER_LIST, response);
     }
 }
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 success) {}
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
@@ -94,8 +94,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) {
@@ -134,10 +134,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/resources/application.yml b/backend/src/main/resources/application.yml
@@ -63,5 +63,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 success) {}