From e13c55d2c01f27ce523574ec0d61691cf9018b6c Mon Sep 17 00:00:00 2001 From: thsghdud13 Date: Wed, 25 Sep 2024 21:56:01 +0900 Subject: [PATCH] =?UTF-8?q?Feat=20:=20RabbitMQ=EC=99=80=20=EC=97=B0?= =?UTF-8?q?=EB=8F=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../festime/config/WebSocketConfigurer.java | 17 ++++++++++++----- .../festime/controller/MessageController.java | 8 +++----- src/main/resources/application.yml | 8 +++++++- 3 files changed, 22 insertions(+), 11 deletions(-) diff --git a/src/main/java/Be9room/festime/config/WebSocketConfigurer.java b/src/main/java/Be9room/festime/config/WebSocketConfigurer.java index 67db3c4..7934e3d 100644 --- a/src/main/java/Be9room/festime/config/WebSocketConfigurer.java +++ b/src/main/java/Be9room/festime/config/WebSocketConfigurer.java @@ -1,9 +1,9 @@ package Be9room.festime.config; import lombok.RequiredArgsConstructor; +import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Configuration; import org.springframework.messaging.simp.config.MessageBrokerRegistry; -import org.springframework.util.AntPathMatcher; import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker; import org.springframework.web.socket.config.annotation.StompEndpointRegistry; import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer; @@ -12,6 +12,8 @@ @EnableWebSocketMessageBroker @RequiredArgsConstructor public class WebSocketConfigurer implements WebSocketMessageBrokerConfigurer { + @Value("${rabbit.host}") + private String rabbitHost; // private final StompHandler stompHandler; @Override public void registerStompEndpoints(StompEndpointRegistry registry) { @@ -23,10 +25,15 @@ public void registerStompEndpoints(StompEndpointRegistry registry) { @Override public void configureMessageBroker(MessageBrokerRegistry registry) { -// registry.setPathMatcher(new AntPathMatcher(".")); - registry.setApplicationDestinationPrefixes("/pub"); -// registry.enableStompBrokerRelay("/queue", "/topic", "/exchange", "/amq/queue"); - registry.enableSimpleBroker("/sub"); + registry.setApplicationDestinationPrefixes("/pub") + .enableStompBrokerRelay("/topic") + .setRelayHost(rabbitHost) + .setVirtualHost("/") + .setRelayPort(61613) + .setClientLogin("admin") + .setClientPasscode("admin") + .setSystemLogin("admin") + .setSystemPasscode("admin"); } // @Override diff --git a/src/main/java/Be9room/festime/controller/MessageController.java b/src/main/java/Be9room/festime/controller/MessageController.java index 9e649a0..2c0eb5f 100644 --- a/src/main/java/Be9room/festime/controller/MessageController.java +++ b/src/main/java/Be9room/festime/controller/MessageController.java @@ -20,13 +20,12 @@ public class MessageController { */ @MessageMapping(value = "/guestbook/enter") public void enter(MessageDTO message){ - log.info("eee"); message.setMessageType(MessageType.ENTER.toString()); message.setMessage(message.getMemberName() + "님이 방명록에 참여했어요!"); /* 메세지 저장 부분 */ - template.convertAndSend("/sub/guestbook", message); + template.convertAndSend("/topic/guestbook", message); } /** @@ -35,12 +34,11 @@ public void enter(MessageDTO message){ */ @MessageMapping(value = "/guestbook/message") public void message(MessageDTO message){ - log.info("messsaggee"); message.setMessageType(MessageType.MESSAGE.toString()); /* 메세지 저장 부분 */ - template.convertAndSend("/sub/guestbook", message); + template.convertAndSend("/topic/guestbook", message); } /** @@ -54,7 +52,7 @@ public void leave(MessageDTO message){ /* 메세지 저장 부분 */ - template.convertAndSend("/sub/guestbook", message); + template.convertAndSend("/topic/guestbook", message); } diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index eea48b4..11f75f0 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -1 +1,7 @@ -spring.application.name=festime +spring: + application: + name: festime_BE + + +rabbit: + host: ${RABBIT_HOST}