message: 웹소켓

[platanus-kr]

WebSocket 백엔드 구현

시작 전 생각했던것

1) 예상

• 임의의 토픽(채팅방) 등록
• 기본 메시지 송수신 등 일반적인 채팅 서비스가 가져야 할 기능 확인
• WebSocket 메시지 수신시 payload만으로 카프카 전송

2) 예상과 달랐던 점

• Spring MVC 에서 제공하는 web.WebSocket 의 편리한 기능들을 하나도 사용할 수 없었음 (@MessageMapping 등)
• STOMP.js 등을 이용할 수 없었음. STOMP.js 를 사용하는 것이 주 목적이 아니기 때문에 WebSocket을 그냥 사용하기로 함.
• reactive.WebSocket 을 모두 구현(implement) 해야함
• 카프카 같은 메시지 브로커 미들웨어를 쓰기 위해서 WebSocket과 토픽의 연결에 대해 고민해야됨 -> 일단 미뤄놓기

3) 정말로 필요했던 것

• WebSocket 송수신 구현
• WebSocket 핸들러 구현
• 핸들러를 통해 카프카 전달 구현

이 티켓에서 실제로 한 것

Reactive Websocket 기반 채팅 시스템 구현

1. 단일 WAS에서 websocket 채널 관리와 메시지 송수신 구현

• WebSocket에서 session을 channel(채팅방)과 조합하여 Flux 생성.
• 생성된 Flux를 FluxSink에 추가.
• 메시지 수신시 FluxSink에 전달, 전달받은 FluxSink는 각 Flux에 메시지 브로드케스팅.

2. 프론트(web 패키지)과 메시지 브로커(message 패키지) 분리구조

• web : 회원, SSR 프론트를 담당한다.
• message : 채팅 세션을 관리하고 세션을 채팅방과 연결한다. 채팅방에 수신되는 메시지를 세션에 송신하다.

이후 구현할 내용

회원 연결 : message에서 web의 Spring Security context 읽어들이기
메시지 브로커 : message를 kafka에 연결하여 message를 스케일아웃 할 수 있는 구조로 만들기
채팅방 구현 : 각 채팅 방을 만들고 목록을 사용자에게 보여주기

[platanus-kr]

문제점

• WebSocketMessageBrokerConfigurer.registerStompEndpoints() : ws 바인딩 -> STOMP와 SockJS의 차이
• WebSocketMessageBrokerConfigurer.configureMessageBroker : <- 여기가 문제임..
  subscribe까진 일단 STOMP.js상으로 되는데 prefix로 topic에 전송이 안됨.
• reactive.WebSocketHandler 와 web.WebSocketHandler가 따로 있음.
  -> 이 두개가 서로 훅을 잡겠다고 충돌이 나는것 같은데 gradle상으로 mvc는 처음부터 안가져오고있었다.
• 근데 뭘 쓰든 일단 핸들러에서 훅이 안잡힘
• STOMP.js상에서 WebFlux쪽으로 전송은 함.

[platanus-kr]

타협안

• 다 걷어내고 WebSocket 날로 간다.
• reactive.HandlerMapping 랑 WebSocketHandler 구현으로 메시징 자체 처리
• 핸들러를 타고 들어온 세션은 Flux를 생성해서 FluxSink에 포함하기 -> SubscriptionManager 그리고 MessageFlux
• Flux로 부터 발생한 메시지를 FluxSink에 모두 emit 하기 -> MessageBroadcaster

여기까지 해낸 것

• WebSocketHandler 구현하여 세션마다 Flux 생성해서 붙이기
• 생성된 Flux를 FluxSink에 붙이기
• 메시지를 수신 받으면 FluxSink 에 전달하기

해야하는 것

• Flux에서 메시지 전달 받으면 카프카로 전달하기
• 카프카는 해당 채널을 구독하고 있는 모든 WAS에게 메시지 전달하기
• 카프카로부터 수신받은 메시지를 클라이언트로 전달하기

[platanus-kr]

프로토타입 완성.