다중서버의 SpringBoot + WebSocket + stomp+ kafka 채팅시스템 구축 질문이 있습니다.

Question

🧩 시스템 구조와 메시지 라우팅에 대한 고민현재 구축 중인 시스템은 WebSocket 서버가 다중 인스턴스로 구성되어 있으며, Kafka를 통해 채팅 메시지를 수신하고 있습니다.✅ 현재 아키텍처Kafka는 채팅 메시지를 브로드캐스트 용도로 사용하며,→ 모든 WebSocket 서버가 Kafka를 동일한 그룹 ID로 구독하고 있습니다 (즉, 같은 메시지를 하나의 서버만 소비함).문제는 Kafka에서 메시지를 수신한 WebSocket 서버에 해당 유저의 세션이 존재하지 않는 경우,→ 해당 유저에게 메시지가 전송되지 않고 유실될 수 있다는 점입니다.이를 방지하기 위해 다음과 같은 구조를 고려하고 있습니다:각 WebSocket 서버는 자신만의 Redis Pub/Sub 채널을 구독Kafka 메시지를 수신한 서버가 해당 유저의 세션이 존재하지 않을 경우,→ 유저가 실제로 연결된 서버의 Redis 채널로 메시지를 발행하여 라우팅⚠ 고민: 메시지 순서 보장 문제이 구조에서는 메시지 순서가 어긋날 가능성이 존재합니다.예시: 단체 채팅방에 10명이 있는 경우일부 유저는 Kafka 컨슈머에서 직접 메시지를 받음다른 유저는 Redis Pub/Sub을 통해 간접 수신 → 이로 인해 서버 간 메시지 도착 타이밍 차이로 순서가 꼬일 수 있음❌ 다른 대안의 한계Kafka 컨슈머 그룹 ID를 각 WebSocket 서버마다 다르게 설정하면? → 모든 메시지를 모든 서버가 수신하게 되어→ 불필요한 리소스/네트워크 낭비 발생❓ 질문Kafka + WebSocket + Redis 기반의 분산 시스템에서, 유저 세션 기반 메시지 라우팅을 구현하면서도 메시지 순서를 보장할 수 있는 아키텍처는 어떤 것이 있을까요?Redis Pub/Sub을 통해 메시지를 라우팅하면 순서 보장이 어려운 문제가 있고, Kafka 컨슈머 그룹을 다르게 설정하면 오버헤드가 크다는 문제가 있습니다.실제 운영 환경에서 이런 문제를 해결하기 위한 실용적인 설계나 패턴이 존재할까요?

장독깨기 · Accepted Answer

채팅 룸별로 토픽을 만들어서 메시지를 주고 받으면 간단하지 랂을까요?

초무쿤 · Answer

웹소켓 래이어어에서 먼저 보냈더라도 네트워크상의 문지로 순서가 뒤비뀔수 있어서 아미 안될껍니다.(근데 부하가 아주 크지 않는 이상은 보통은 크게 뒤바뀌거너 하지는 않는듯)순서에 민감한 데이터의 경우는 메시지 바디에 시간이나 UUIDv7(시간에 따라 정렬가능)를 보내서 클라이언트에서 재졍렬 하거나 순서 저정하는 빙법 밖에 없는가로 알아요.Ps.근데 채팅창에 메시지에 먼저 타이핑해서 엔터친 순서대로 꺽 보여줘야될 일이 있을런비는..

3인칭관찰자시점 · Answer

redis streams가 순서보장이 된다고 하는데 적용해 보는건 어떤가요

다중서버의 SpringBoot + WebSocket + stomp+ kafka 채팅시스템 구축 질문이 있습니다.

3개의 답변

#kafka 목록