Springboot STOMP 채팅 기능 구현에서 메시지를 받은 후 작업을 하고 싶은데 어떻게 할 수 있을까요?

Question

안녕하세요. springboot로 STOMP 를 활용해 동아리와 회원들의 단체 채팅방 기능을 개발하고 있는데 막히는 점이 있어서 여쭤보고자 글을 올렸습니다!메시지 전송 및 수신은 잘 되는데, 여기서 더 나아가받는 사람이 채팅방 안에 들어와 있어서 메시지를 수신하면, 받는 사람의 user_chat_room 테이블의 last_read_chat_id (해당 채팅방에서 가장 마지막으로 읽은 채팅 메시지 아이디)를 가장 최신 채팅 아이디로 업데이트하고 싶습니다.혹시 메시지를 받은 후 처리를 어떻게 해야 할지 조언을 구할 수 있을까요? 도와주시면 감사하겠습니다!!아래는 제가 작성한 메시지 송신 코드입니다. (잘 작동합니다.)웹소켓 config 코드&#64;Configuration &#64;EnableWebSocketMessageBroker &#64;RequiredArgsConstructor public class WebSocketBrokerConfig implements WebSocketMessageBrokerConfigurer { &#64;Override public void registerStompEndpoints(StompEndpointRegistry registry) { // Client에서 websocket연결할 때 사용할 API 경로를 설정 registry.addEndpoint(&#34;/ws/chat&#34;) // 연결될 엔드포인트 // STOMP 접속 주소 url &#61;> /ws/chat (이 주소로 소켓을 연결) .setAllowedOriginPatterns(&#34;*&#34;); // CORS 설정 부분 // *으로 모든 도메인 허용함 // .withSockJS(); // 일부 소켓을 지원하지 않는 브라우저에서 SocketJS를 사용하게 함 // 이것때문에 연결이 안 되길래 삭제함 } &#64;Override public void configureMessageBroker(MessageBrokerRegistry registry) { // 메시지를 구독하는 요청 url -> 메시지 받을 때 registry.enableSimpleBroker(&#34;/sub&#34;); // 메시지를 발행하는 요청 url -> 메시지 보낼 때 registry.setApplicationDestinationPrefixes(&#34;/pub&#34;); } }채팅 메시지 보낼 때 코드 // 채팅 메시지 송신 // /pub/chat/message 엔드포인트로 들어오는 WebSocket 메시지를 처리 &#64;MessageMapping(&#34;/chat/message&#34;) public ResponseEntity sendChatMessage( &#64;RequestBody ChatDto chatDto // 이 안에 crewId, userId를 담아서 같이 보냄! ) { // senderName 설정 String senderName &#61; &#34;&#34;; if (chatDto.getCrewId() !&#61; null && chatDto.getUserId() &#61;&#61; null) { // 동아리가 보낸 경우 senderName &#61; crewService.findCrewNameByCrewId(chatDto.getCrewId()); } else { // 회원이 보낸 경우 senderName &#61; &#34;익명&#34;; Integer enterOrder &#61; userChatRoomService.findEnterOrderByUserIdAndChatRoomId(chatDto.getUserId(), chatDto.getChatRoomId()); senderName &#43;&#61; enterOrder; } // Dto to Entity Chat chat &#61; chatDto.toEntity(senderName, Timestamp.valueOf(LocalDateTime.now(ZoneId.of(&#34;Asia/Seoul&#34;)))); // 채팅 저장 chatService.createChatMessage(chat); // 해당 채팅 메시지를 WebSocket 토픽(/sub/chatroom/채팅방ID)에 전송하여 클라이언트에게 브로드캐스팅한다. messagingTemplate.convertAndSend(&#34;/sub/chatroom/&#34; &#43; chat.getChatRoomId(), chat); // 채팅을 보낸 동아리/회원의 last_read_chat_id 갱신 if (chatDto.getCrewId() !&#61; null && chatDto.getUserId() &#61;&#61; null) { // 동아리가 보낸 경우 updateCrewLastReadChatId(chatDto.getChatRoomId(), chatDto.getCrewId()); } else { // 회원이 보낸 경우 updateUserLastReadChatId(chatDto.getChatRoomId(), chatDto.getUserId()); } return new ResponseEntity(ResponseFormat.responseFormat(StatusCode.SUCCESS, ResponseMessage.SEND_SUCCESS_CHAT_MESSAGE, chat.getChatRoomId()), HttpStatus.OK); }제가 원하는 기능을 구현하신 다른 분의 코드는 로직이 달라서 따라하기가 어려울 것 같아 직접 여기에 여쭤보았습니다..!chatGPT에게 물어보면서 아래와 같이 진행해보기도 했는데, /sub/chatroom/{chatRoomId} 구독경로로 메시지를 받으면 이 코드가 실행되도록 하고 싶은데 아예 저 &#34;여기 들어옴!!!&#34; 코드가 출력이 안 되어서.. 아예 여기로는 매핑이 되지 않는 것 같습니다...// /sub/chatroom/{chatroomId} 경로로 채팅 메시지를 받는 메소드 &#64;SubscribeMapping(&#34;/sub/chatroom/{chatRoomId}&#34;) public void receiveChatMessage ( &#64;DestinationVariable(&#34;chatRoomId&#34;) String chatRoomId, &#64;RequestHeader(&#34;crewId&#34;) Integer crewId, &#64;RequestHeader(&#34;userId&#34;) Integer userId ) { // 채팅 메시지를 받는 로직 처리 System.out.println(&#34;여기 들어옴!!!!!!!!!!!!!!!!!!!!!&#34;); // 채팅을 받은 동아리/회원의 last_read_chat_id 갱신 if (crewId !&#61; null && userId &#61;&#61; null) { // 동아리가 보낸 경우 updateCrewLastReadChatId(Integer.parseInt(chatRoomId), crewId); } else { // 회원이 보낸 경우 updateUserLastReadChatId(Integer.parseInt(chatRoomId), userId); } }도와주시면 정말 감사하겠습니다! 읽어주셔서 감사합니다.

Springboot STOMP 채팅 기능 구현에서 메시지를 받은 후 작업을 하고 싶은데 어떻게 할 수 있을까요?

0개의 답변

기술 목록