diff --git a/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/bus/ChatRedisPublisher.java b/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/bus/ChatRedisPublisher.java index bdd0685..ecc9272 100644 --- a/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/bus/ChatRedisPublisher.java +++ b/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/bus/ChatRedisPublisher.java @@ -18,11 +18,11 @@ public class ChatRedisPublisher { private final String nodeId = System.getProperty("node.id", java.lang.management.ManagementFactory.getRuntimeMXBean().getName()); - public void publishToRoom(UUID roomId, Map payload) { + public void publishToRoom(String roomId, Map payload) { try { payload.put("_src", nodeId); // 루프 방지 태그 String json = objectMapper.writeValueAsString(payload); - stringRedisTemplate.convertAndSend(ChatChannels.roomChannel(roomId), json); + stringRedisTemplate.convertAndSend(roomId, json); } catch (Exception ignore) {} } diff --git a/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/controller/ChatMessagingController.java b/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/controller/ChatMessagingController.java index f74555d..3ccb006 100644 --- a/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/controller/ChatMessagingController.java +++ b/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/controller/ChatMessagingController.java @@ -56,9 +56,9 @@ public void send(@DestinationVariable UUID roomId, ); System.out.println("------------받은메세지"+req.getContent()); // ✅ 즉시 현재 노드의 클라이언트에게 전달 - messagingTemplate.convertAndSend("/topic/chat/" + roomId, payload); + // messagingTemplate.convertAndSend("/topic/chat/" + roomId, payload); // ✅ 다른 노드를 위해 Redis로도 전달 - chatRedisPublisher.publishToRoom(roomId, new java.util.HashMap<>(payload)); + chatRedisPublisher.publishToRoom("/topic/chat/" + roomId, new java.util.HashMap<>(payload)); } } diff --git a/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/controller/ChatNotificationController.java b/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/controller/ChatNotificationController.java index d8cc8c4..4f64258 100644 --- a/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/controller/ChatNotificationController.java +++ b/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/controller/ChatNotificationController.java @@ -50,7 +50,7 @@ public ResponseEntity> roomAlert( "createdAt", saved.getCreatedAt().toString() ); messagingTemplate.convertAndSend("/topic/chat/" + roomId, payload); - chatRedisPublisher.publishToRoom(roomId, new java.util.HashMap<>(payload)); + // chatRedisPublisher.publishToRoom(roomId, new java.util.HashMap<>(payload)); return ResponseEntity.ok(Map.of("ok", true, "id", saved.getId().toString())); } diff --git a/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/service/Impl/ChatNotificationServiceImpl.java b/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/service/Impl/ChatNotificationServiceImpl.java index 3a3832a..3bc2dfd 100644 --- a/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/service/Impl/ChatNotificationServiceImpl.java +++ b/backendProject/src/main/java/likelion/mlb/backendProject/domain/chat/service/Impl/ChatNotificationServiceImpl.java @@ -85,7 +85,7 @@ protected void doDispatch(UUID playerId, "createdAt", saved.getCreatedAt().toString() ); messagingTemplate.convertAndSend("/topic/chat/" + roomId, payload); - chatRedisPublisher.publishToRoom(roomId, new java.util.HashMap<>(payload)); + // chatRedisPublisher.publishToRoom(roomId, new java.util.HashMap<>(payload)); } }