Feat/7 : 외부 메시지 브로커와 연동

build.gradle

@@ -28,6 +28,10 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-web'
 	implementation 'org.springframework.boot:spring-boot-starter-websocket'
 	implementation group: 'org.webjars', name: 'stomp-websocket', version: '2.3.3-1'
+	//rabbitMQ
+	implementation 'org.springframework.boot:spring-boot-starter-amqp'
+	implementation 'org.springframework.boot:spring-boot-starter-reactor-netty:3.0.0'
+	implementation 'io.netty:netty-resolver-dns-native-macos:4.1.68.Final:osx-aarch_64'
 	compileOnly 'org.projectlombok:lombok'
 	annotationProcessor 'org.projectlombok:lombok'
 	testImplementation 'org.springframework.boot:spring-boot-starter-test'

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

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);
     }
 
 

src/main/resources/application.yml

@@ -0,0 +1,7 @@
+spring:
+  application:
+    name: festime_BE
+
+
+rabbit:
+  host: ${RABBIT_HOST}