[MQ] Springboot STOMP 프로토콜으로 Web Socket 통신하기

Springboot STOMP 프로토콜으로 Web Socket 통신하기

---

1. 메시지 큐(Message Queue)

2. STOMP 프로토콜

3. Springboot STOMP 프로토콜으로 Web Socket 통신하기

---

1. 메시지 큐(Message Queue)

메시지 큐(Message Queue)는 비동기적으로 애플리케이션 간의 통신을 할 때 사용됩니다.

메시지를 큐(Queue)에 임시적으로 저장하여, FIFO(First-In-First-Out, 선입선출)로 동작합니다.

 

이러한 메시지 큐를 사용하는 RabbitMQ, Kafka와 같은 메시지 브로커(Message Broker)가 존재합니다.

해당 포스팅에서는 RabbitMQ에 대해 다뤄보겠습니다.

 

2. STOMP 프로토콜

STOMP(Simple Text Oriented Messaging Protocol)은 메세지를 효율적으로 전달할 때 사용하는 프로토콜입니다.

TCP와 WebSocket 같은 양방향 통신 프로토콜을 기반으로 동작합니다.

 

3. Springboot STOMP 프로토콜으로 Web Socket 통신하기

Springboot에는 기본적으로 내장 SimpleBroker가 존재합니다. STOMP 프로토콜을 사용하여 내장 SimpleBroker와 통신해보고자 합니다. RabbitMQ와 같은 외부 메시지 브로커의 연동할 때 통신을 위해 STOMP 프로토콜을 사용할 수 있기 때문에, 이를 활용한 통신 방식에 대해 학습해보겠습니다.

 

전체적인 통신 구현을 위해서는 아래의 6개의 파일이 필요합니다.

WebSocketConfig.java, GreetingController.java, Greeting.java, HelloMessage.java, index.html, app.js 

 

해당 포스팅에서는 4개의 java파일에 대한 설명만 다루겠습니다.

 

- WebSocketConfig.java

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

  @Override
  public void configureMessageBroker(MessageBrokerRegistry config) {
    config.enableSimpleBroker("/topic");
    config.setApplicationDestinationPrefixes("/app");
  }

  @Override
  public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/gs-guide-websocket");
  }
}

 

configureMessageBroker는 메시지를 주고받는 경로를 설정

registerStompEndPoints는 클라이언트가 서버에 접속할 수 있는 출입구 설정

 

1. configureMessageBroker 메서드 - 1번 문장

/topic은 모든 메시지는 /topic 경로를 통해 전달된다는 의미입니다.

/topic/greetings 이라는 경로가 있으면 이 경로를 구독한 사람들에게 메시지가 전달됩니다.

 

2. configureMessageBroker 메서드 - 2번 문장

/app은 클라이언트가 서버로 데이터를 보낼 때 /app/hello 같은 경로를 사용할 수 있습니다.

서버로 가는 메시지의 출발 경로입니다.

 

 

3. registerStompEndPoints 메서드

클라이언트가 서버에 연결하려면 주소가 필요합니다.

클라이언트는 http://[서버주소]/gs-guide-websocket 으로 연결을 시작할 수 있습니다.

 

- GreetingController.java

@Controller
public class GreetingController {

  @MessageMapping("/hello")
  @SendTo("/topic/greetings")
  public Greeting greeting(HelloMessage message) throws Exception {
    Thread.sleep(1000);
    return new Greeting("Hello, " + HtmlUtils.htmlEscape(message.getName()) + "!");
  }
}

 

1. @MessageMapping("/hello")

클라이언트가 /app/hello 경로로 메시지를 보내면 이 메서드가 호출됩니다.

 

2. @SendTo("/topic/greetings")

메서드가 실행되면 처리된 결과가 /topic/greetings 경로로 전달됩니다.

 

3. Thread.sleep(1000);

1초동안 기다리게 하는 코드입니다.

서버가 계산을 하거나 응답을 잠시 지연시키고 싶은 경우에 사용합니다.

 

4. return new Greeting("Hello, " + HtmlUtils.htmlEscape(message.getName()) + "!");

message.getName()으로 클라이언트가 보낸 이름을 가져옵니다. 악의적인 HTML 코드 삽입 방지를 위해 HtmlUtils.htmlEscape를 사용했습니다. 반환된 Greeting 객체는 /topic/greetings 경로로 전달됩니다.

 

- Greeting.java

public class Greeting {

  private String content;

  public Greeting() {
  }

  public Greeting(String content) {
    this.content = content;
  }

  public String getContent() {
    return content;
  }
}

 

/topic/greetings 경로로 전달될 Greeting 객체를 생성하는 코드입니다.

 

- HelloMessage.java

public class HelloMessage {

  private String name;

  public HelloMessage() {
  }

  public HelloMessage(String name) {
    this.name = name;
  }

  public String getName() {
    return name;
  }

  public void setName(String name) {
    this.name = name;
  }
}

 

클라이언트에서 html로부터 입력을 받아올 코드입니다.

---

참고 사이트

[간단정리] 메세지 큐(Message Queue)란?

 

[서버] 메세지 큐(Message Queue) 을 알아보자

 

[IT정보] 메시지 큐(Message Queue, MQ) 개념

 

[RabbitMQ] 기초 개념

 

[Architecture] 메시지 큐와 메시지 브로커 - MSA의 핵심요소

 

WebSocket의 Stomp

 

Spring Websocket & STOMP

 

Getting Started | Using WebSocket to build an interactive web application

 

문제가 있으면 댓글 남겨주세요 !

피드백은 언제나 환영입니다 <3