[SpringBoot] WebSocket ver.Spring

가독성 있게 보고 싶다면 ➡️ https://pretty-pilot-212.notion.site/WebSocket-ver-Spring-116708535dff803d8f60ffa16a365c22

 

https://velog.io/@mw310/Stomp-WebSocket-개념-정리ver-Spring

Stomp, WebSocket 개념 정리(ver. Spring)

Stomp란(Simple/Stream Text Oriented Message Protocol)

• websocket 위에서 동작하는 문자 기반 메세징 프로토콜로써 클라이언트와 서버가 전송할 메세지의 유형, 형식, 내용들을 정의하는 매커니즘이다.
• TCP와 웹소켓과 같은 신뢰할 수 있는 양방향 스트리밍 네트워크 프로토콜에서 사용할 수 있다.
• 기본적으로 pub / sub 구조로 되어있어, 메세지를 전송하고 받아 처리하는 부분이 확실히 정해져있다.
• http와 마찬가지로 frame을 사용해 전송하는 프로토콜이다.

---

Springboot에서 사용할 시 장점

메시징 프로토콜과 메시징 형식을 개발할 필요가 없다.

STOMP 클라이언트는 Java 클라이언트를 포함해서 사용할 수 있다.

메시지 브로커를 사용하면 구독을 관리하고 메시지를 broadcast하는데 사용할 수 있다.

유저가 접속할 때 이를 모든 클라이언트에 알리고, 서버에도 로깅한다.

이때, 모든 클라이언트에 메세지를 보내는 것을 브로드캐스트(Broadcast) 한다고 말한다.

메시지 브로커는 무엇일까?

• 3줄 요약

1. 서비스(어플리케이션) 간의 의존성 제거
2. 메시지 처리 시점
3. 다양하고 유연한 통신

• 자세한 것은 아래 링크

https://binux.tistory.com/74

STOMP에서 역할

• 클라이언트, 브로커, 서버

1. 클라이언트 (Client)
   정의: 메시징 시스템의 참여자 중 하나로, 메시지를 보내거나 구독하는 역할을 합니다.
   기능:
   발행자 (Publisher): 메시지를 특정 경로로 발행하는 클라이언트입니다. 예를 들어, 채팅 애플리케이션에서 메시지를 입력한 사용자는 발행자 역할을 합니다.
   구독자 (Subscriber): 특정 경로에 구독(subscribe)하여, 브로커가 해당 경로로 전달하는 메시지를 받는 클라이언트입니다. 채팅방을 구독한 사용자는 구독자 역할을 합니다.
2. 브로커 (Broker)
   정의: 클라이언트 간의 메시지를 중개하는 시스템입니다. 메시지의 발송 및 전달을 관리하여 메시지를 올바른 대상에게 전파합니다.
   기능:
   클라이언트에서 발행된 메시지를 받아, 적절한 구독자에게 전달합니다.
   메시지 라우팅을 담당하여, 특정 주제나 경로에 대해 구독한 클라이언트들에게 발행된 메시지를 전파합니다.
   종류:
   심플 브로커: 간단한 구현으로, 메모리에 메시지를 저장하고 경로를 구독한 클라이언트로 바로 전달합니다.
   외부 브로커 (예: RabbitMQ, ActiveMQ): 더 복잡한 메시징 시나리오를 지원하며, 대량의 메시지를 처리하고 영구 저장 등의 기능을 제공합니다.
3. 서버 (Server)
   정의: STOMP 메시지를 처리하고, 로직에 따라 메시지를 브로커로 전달하거나 클라이언트 요청을 처리하는 역할을 담당하는 애플리케이션입니다.
   기능:
   메시지를 받아 로직에 맞는 처리 후 결과를 브로커로 전송합니다.
   예를 들어, /pub/chat/send와 같은 경로로 메시지가 전송되면, 서버의 특정 컨트롤러 메소드에서 해당 메시지를 처리합니다.

• 메시지 흐름
  발행자 (Publisher) - 클라이언트가 /pub/... 경로로 메시지를 발행.
  서버는 이 메시지를 받아 로직을 처리하고, 처리된 결과를 브로커로 전달.
  브로커는 /sub/... 경로를 구독한 구독자 (Subscriber) - 클라이언트에게 메시지를 전달.

반환 타입

• 일반적으로 MessageConverter를 사용하여 serialized된 응답 형태가 반환되고 Messagesms brokerChannel에 전달된다. outbound 메시지는 바로 브로커에게 전달하는 /topic에 경우에는 동일한 형태로 값을 전달 받는다.
• @SendTo, @SendToUser 애노테이션을 사용해서 output message에 목적지를 커스터마이징 할 수 있다. @SendTo는 목적지를 커스터마이징 하기위해서 사용되거나 여러 목적지에 값을 전달하기 위해 사용된다. @SendToUser는 inputMessage를 보낸 user에게만 응답을 보내기 위해서 사용된다.
• @SendTo, @SendToUser를 같이 사용할 수 있고 클래스 레벨에서도 사용할 수 있으며 클래스 레벨에 있던 애노테이션은 메소드 레벨에서 재정의 될 수 있다.
• Message는 비동기로 다뤄지고 @MessageMapping은 ListenableFuture, CompletableFuture, CompletionStage를 반환한다.
• 사실 @SendTo와 @SendToUser는 SimpleMessagingTemplate를 사용하는것과 다르지 않다.