package org.example.backendproject.stompwebsocket.config;

import org.example.backendproject.stompwebsocket.handler.CustomHandshakeHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {


    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {

        /**
         * 구독중 Prefix
         * /topic 일반 채팅을 받을 접두어
         * /queue 귓속말을 받을 접두어
         * 서버가 보내는 메시지를 클라이언트가 구독할 때 사용하는 경로
         */
        registry.enableSimpleBroker("/topic", "/queue");    // 구독용 경로

        /** 전송용 Prefix **/
        // 클라이언트가 서버에 메시지를 보낼 때 사용하는 경로 접두어
        registry.setApplicationDestinationPrefixes("/app");   // 클라이언트 -> 서버

        // 서버가 특정 사용자에게 메시지를 보낼 때, 클라이언트가 구독할 경로 접두어
        registry.setUserDestinationPrefix("/user");          // 서버 -> 특정 사용자
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws-chat")
            .setHandshakeHandler(new CustomHandshakeHandler())
            .setAllowedOriginPatterns("*");
    }
}
Java
복사

1. @EnableWebSocketMessageBroker

•

이 어노테이션은 Spring이 WebSocket 메시지 브로커 기능을 활성화하도록 지시한다. 이를 통해 STOMP 메시지 처리를 위한 환경이 자동으로 구성된다.

2. configureMessageBroker(MessageBrokerRegistry registry)

이 메서드는 메시지 브로커의 동작 방식을 설정한다.

•

registry.enableSimpleBroker("/topic", "/queue");

◦

@EnableWebSocketMessageBroker와 함께 사용될 때, 이 설정은 인메모리(in-memory) 메시지 브로커를 활성화한다.

◦

/topic: 일반적으로 공개 채팅이나 여러 사용자가 구독하는 메시지에 사용된다. 예를 들어, "/topic/publicChat"과 같은 경로로 메시지를 보내면 해당 경로를 구독하는 모든 클라이언트가 메시지를 수신한다.

◦

/queue: 주로 특정 사용자에게 1:1 메시지(귓속말)를 보낼 때 사용됩니다. 클라이언트는 /user/queue/privateMessages와 같은 경로를 구독하여 자신에게 온 메시지를 받게 된다.

•

registry.setApplicationDestinationPrefixes("/app");

◦

분석: 클라이언트가 서버로 메시지를 보낼 때 사용하는 목적지(destination)의 접두어를 설정한다. 예를 들어, 클라이언트가 /app/chat.sendMessage로 메시지를 보내면, Spring은 @MessageMapping("/chat.sendMessage")와 같은 어노테이션이 붙은 컨트롤러 메서드를 찾아 해당 메시지를 처리한다.

•

registry.setUserDestinationPrefix("/user");

◦

Spring STOMP는 사용자별(user-specific) 메시징을 지원한다. 이 접두어는 서버가 특정 사용자에게 메시지를 보낼 때 사용되는 경로의 접두어를 정의한다. 예를 들어, 서버가 특정 userId를 가진 사용자에게 메시지를 보내고자 할 때, 내부적으로 /user/{userId}/queue/messages와 같은 경로를 사용하게 된다. 클라이언트 입장에서는 stompClient.subscribe('/user/queue/messages')와 같이 구독하면 자신에게 전송된 메시지를 받을 수 있다.

3. registerStompEndpoints(StompEndpointRegistry registry)

이 메서드는 WebSocket 연결을 위한 STOMP 엔드포인트를 등록한다.

•

registry.addEndpoint("/ws-chat"):

◦

클라이언트가 WebSocket 연결을 시도할 URL 경로를 정의한다. 클라이언트는 new WebSocket("ws://localhost:8080/ws-chat")와 같이 이 경로를 사용하여 연결을 시작한다. 이 경로는 HTTP 핸드셰이크를 처리하며, 연결이 성공하면 WebSocket 프로토콜로 업그레이드 된다.

•

.setHandshakeHandler(new CustomHandshakeHandler()):

◦

WebSocket 핸드셰이크 과정에서 사용자 정보를 커스터마이징하거나 특정 로직을 추가할 때 사용됩니다. CustomHandshakeHandler 클래스를 통해 사용자 세션에 특정 정보를 저장하거나, 인증/인가 로직을 처리할 수 있습니다. 예를 들어, HTTP 세션에 있는 사용자 정보를 STOMP 세션에 연결하는 데 유용하다.

•

.setAllowedOriginPatterns("*"):

◦

분석: 이 설정은 CORS(Cross-Origin Resource Sharing) 문제를 해결하기 위해 사용된다. "*"는 모든 오리진(origin)에서의 연결을 허용한다는 의미이다. 개발 단계에서는 편리하지만, 프로덕션 환경에서는 보안상 특정 도메인으로 제한하는 것이 강력히 권장된다. 예를 들어, .setAllowedOriginPatterns("https://yourfrontend.com", "http://localhost:3000")와 같이 명시적으로 허용할 오리진을 지정해야 한다.

CustomHandshakeHandler

CustomHandshakeHandler는 WebSocket 핸드셰이크 과정에서 사용자 정보를 추출하고 Principal 객체를 설정하는 데 사용된다.

package org.example.backendproject.stompwebsocket.handler;

import java.security.Principal;
import java.util.Map;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.support.DefaultHandshakeHandler;

public class CustomHandshakeHandler extends DefaultHandshakeHandler {

    @Override
    protected Principal determineUser(ServerHttpRequest request,
                                    WebSocketHandler wsHandler,
                                    Map<String, Object> attributes) {

        String nickname = getNickName(request.getURI().getQuery());
        return new StompPrincipal(nickname);
    }

    private String getNickName(String query) {
        if (query == null || !query.contains("nickname=")) {
            return "닉네임없음";
        } else {
            return query.split("nickname=")[1];
        }
    }
}
Java
복사

•

DefaultHandshakeHandler를 상속받아 WebSocket 핸드셰이크의 기본 동작을 확장한다.

•

determineUser 메서드를 오버라이드하여 WebSocket 연결 시 사용자(Principal)를 결정한다.

•

이 메서드에서는 ServerHttpRequest 객체에서 요청 URI의 쿼리 스트링을 가져와 getNickName 메서드를 호출한다.

•

getNickName 메서드는 쿼리 스트링에서 "nickname="으로 시작하는 부분을 찾아 그 뒤의 값을 추출한다. 만약 쿼리 스트링이 없거나 "nickname="을 포함하지 않으면 기본값으로 "닉네임없음"을 반환한다.

•

추출된 닉네임 문자열을 사용하여 StompPrincipal 객체를 생성하고 이를 Principal로 반환한다. 이렇게 설정된 Principal은 해당 WebSocket 세션의 사용자 식별자로 사용된다.

•

닉네임을 URI 쿼리 파라미터에서 직접 추출하는 방식은 간단하지만, 보안적인 측면에서 취약할 수 있다. 실제 서비스에서는 토큰(JWT 등)이나 세션 기반 인증을 통해 사용자를 안전하게 식별하고, 해당 인증 정보에서 사용자 고유 ID나 닉네임을 추출하는 것이 훨씬 안전하다.

•

쿼리 파라미터 파싱 로직(getNickName)이 매우 간단하여, "nickname=" 문자열이 쿼리 중간에 있거나 다른 파라미터와 조합될 경우 예상치 못한 동작을 할 수 있다. 예를 들어, ?param=value&nickname=myname과 같은 경우에는 정상 작동하지만, ?nickname=myname&param=value처럼 닉네임이 먼저 나오지 않으면 문제가 발생할 수 있다. UriComponentsBuilder나 UriUtils 같은 Spring 유틸리티를 활용하여 쿼리 파라미터를 안전하게 파싱하는 것이 더 견고한 구현 방법이다.

•

닉네임이 없을 경우 "닉네임없음"으로 처리하는 부분은 디버깅이나 간단한 테스트에는 유용하지만, 실제 서비스에서는 명확한 에러 처리나 기본 닉네임 부여 정책을 고려해야 한다.

StompPrincipal

StompPrincipal은 Principal 인터페이스를 구현하여 STOMP 세션에서 사용자를 식별하는 데 사용되는 커스텀 Principal 구현체이다.

package org.example.backendproject.stompwebsocket.entity;

import java.security.Principal;

public class StompPrincipal implements Principal {

    private final String name;

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

    @Override
    public String getName() {
        return name;
    }
}
Java
복사

•

java.security.Principal 인터페이스를 구현한다. 이 인터페이스는 인증된 개체(사용자)의 이름을 나타내는 기본적인 기능을 제공한다.

•

name 필드를 통해 사용자의 고유 식별자(이름, 여기서는 닉네임)를 저장한다.

•

getName() 메서드를 오버라이드하여 name 필드의 값을 반환한다.
Spring STOMP 메시지 브로커는 이 getName() 메서드가 반환하는 값을 기반으로 사용자별 메시징 (예:/user/{userName}/queue/messages)을 처리한다.

STOMP 프로토콜을 활용한 통신 흐름

WebSocketConfig에서 /ws-chat 엔드포인트에 CustomHandshakeHandler를 등록했으므로, 클라이언트가 /ws-chat으로 WebSocket 연결을 시도하면 다음과 같은 흐름으로 진행된다.

클라이언트의 WebSocket 연결 요청: 웹 브라우저나 STOMP 클라이언트 라이브러리가 ws://localhost:8080/ws-chat?nickname=사용자닉네임과 같은 URL로 WebSocket 핸드셰이크 요청을 보낸다.

Spring의 핸드셰이크 처리: Spring WebSocket 컨테이너는 이 요청을 감지하고 WebSocketConfig에 등록된 CustomHandshakeHandler의 determineUser 메서드를 호출한다.

determineUser 메서드 실행:

•

CustomHandshakeHandler의 determineUser 메서드가 실행된다.

•

request.getURI().getQuery()를 통해 nickname=사용자닉네임과 같은 쿼리 스트링을 가져온다.

•

getNickName 메서드가 호출되어 이 쿼리 스트링에서 "사용자닉네임" 부분을 추출한다.

•

추출된 닉네임을 인자로 new StompPrincipal(nickname)을 호출하여 StompPrincipal 객체가 생성된다.

•

이 StompPrincipal 객체가 determineUser 메서드의 반환 값으로 Spring에 전달된다.

Principal 객체 설정: Spring은 determineUser 메서드가 반환한 StompPrincipal 객체를 현재 WebSocket 세션의 Principal로 설정한다. 이 Principal은 STOMP 메시지의 헤더(SimpMessageHeaderAccessor.USER_HEADER 등)에 자동으로 추가되어, 나중에 @MessageMapping이 적용된 컨트롤러 메서드나 메시지 가로채기(Interceptor) 등에서 현재 메시지를 보낸 사용자를 식별하는 데 사용될 수 있다. 또한, /user 접두사를 사용한 사용자별 메시징 시 이 Principal의 getName() 값이 사용자 식별자로 활용된다.

WebSocket 연결 수립: 핸드셰이크가 성공적으로 완료되면, 클라이언트와 서버 간에 WebSocket 연결이 수립되고 STOMP 메시지를 주고받을 준비가 된다.

STOMP 메시징: 이후 클라이언트가 /app 접두어를 가진 목적지로 메시지를 보내거나, /topic, /queue, /user 접두어를 가진 목적지를 구독할 때, 이 세션에 연결된 StompPrincipal 객체의 getName() 메서드가 반환하는 닉네임 값이 사용자 식별자로 사용된다. 예를 들어, 서버가 /user/{nickname}/queue/messages로 메시지를 보내면, 이 nickname에 해당하는 StompPrincipal을 가진 클라이언트만 메시지를 수신한다.

RedisConfig

RedisConfig 클래스는 Redis pub/sub 메시징 시스템의 핵심 설정으로, 메시지 리스너 컨테이너를 정의한다.

package org.example.backendproject.stompwebsocket.redis;

import lombok.RequiredArgsConstructor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;

@RequiredArgsConstructor
@Configuration
public class RedisConfig {

    private final RedisSubscriber redisSubscriber;

    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory redisConnectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(redisConnectionFactory);

        container.addMessageListener(new MessageListenerAdapter(redisSubscriber), new PatternTopic("room.*"));
        container.addMessageListener(new MessageListenerAdapter(redisSubscriber), new PatternTopic("private.*"));       // 귓속말

        return container;
    }
}
Java
복사

•

@Configuration 어노테이션은 이 클래스가 Spring의 설정 클래스임을 나타낸다.

•

@RequiredArgsConstructor는 final 필드인 redisSubscriber에 대한 생성자를 자동으로 생성한다.

•

container 빈은 RedisMessageListenerContainer를 생성하고 설정한다. 이 컨테이너는 Redis로부터 메시지를 수신하는 역할을 한다.

•

container.setConnectionFactory(redisConnectionFactory);를 통해 Redis 연결 팩토리를 설정하여 Redis 서버와의 통신을 관리한다.

•

container.addMessageListener를 사용하여 메시지 리스너(RedisSubscriber를 래핑한 MessageListenerAdapter)를 특정 채널 패턴에 등록한다.

◦

new PatternTopic("room.*"): "room."으로 시작하는 모든 채널(예: room.1, room.2)에서 발행되는 메시지를 redisSubscriber가 수신하도록 설정한다. 이는 일반 채팅방 메시지 처리에 사용된다.

◦

new PatternTopic("private.*"): "private."으로 시작하는 모든 채널(예: private.user1, private.user2)에서 발행되는 메시지를 redisSubscriber가 수신하도록 설정한다. 이는 귓속말 처리에 사용된다.

RedisPublisher

RedisPublisher 클래스는 Redis 채널로 메시지를 발행하는 역할을 담당한다.

package org.example.backendproject.stompwebsocket.redis;

import lombok.RequiredArgsConstructor;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;

@RequiredArgsConstructor
@Component
public class RedisPublisher {

    private final StringRedisTemplate stringRedisTemplate;
    /** 메세지를 발행하는 클래스 **/
    public void publish(String channel, String msg) {
        stringRedisTemplate.convertAndSend(channel, msg);
    }
}
Java
복사

•

@Component 어노테이션은 이 클래스가 Spring의 컴포넌트 스캔 대상이 되어 빈으로 등록됨을 나타낸다.

•

@RequiredArgsConstructor는 StringRedisTemplate에 대한 생성자를 자동으로 생성한다.

•

StringRedisTemplate은 Redis와의 상호작용을 위한 편리한 템플릿으로, 특히 문자열 기반의 키-값 데이터를 다룰 때 유용하다.

•

publish 메서드는 주어진 channel로 msg를 발행한다. stringRedisTemplate.convertAndSend는 Redis의 PUBLISH 명령을 실행한다.

RedisSubscriber

RedisSubscriber 클래스는 Redis 채널로부터 메시지를 수신하고, 이를 WebSocket 클라이언트로 전송하는 역할을 한다.

package org.example.backendproject.stompwebsocket.redis;

import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.RequiredArgsConstructor;
import org.example.backendproject.stompwebsocket.dto.ChatMessage;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor
public class RedisSubscriber implements MessageListener {

    private final SimpMessagingTemplate simpMessagingTemplate;
    private ObjectMapper objectMapper = new ObjectMapper();

    @Override
    public void onMessage(Message message, byte[] pattern){
        try {
            String msgBody = new String(message.getBody());
            ChatMessage chatMessage = objectMapper.readValue(msgBody, ChatMessage.class);

            if (chatMessage.getTo() != null && !chatMessage.getTo().isEmpty()) {
                simpMessagingTemplate.convertAndSendToUser(chatMessage.getTo(),
                    "/queue/private", chatMessage);
            } else {
                simpMessagingTemplate.convertAndSend("/topic/room." +
                        chatMessage.getRoomId(), chatMessage);
            }
        } catch (Exception e) {
            // 예외 처리 로직 (로깅 등)
        }
    }
}
Java
복사

•

@Service 어노테이션은 이 클래스가 Spring의 서비스 레이어 컴포넌트임을 나타낸다.

•

MessageListener 인터페이스를 구현하여 Redis 메시지를 수신할 수 있도록 한다.

•

@RequiredArgsConstructor는 SimpMessagingTemplate에 대한 생성자를 자동으로 생성한다. SimpMessagingTemplate은 Spring WebSocket STOMP 메시지 브로커를 통해 클라이언트에게 메시지를 보낼 때 사용되는 핵심 도구이다.

•

ObjectMapper는 JSON 문자열을 Java 객체로 역직렬화하는 데 사용된다.

•

onMessage 메서드는 Redis 채널에서 메시지가 수신될 때마다 호출된다.

◦

수신된 Message 객체의 본문(body)을 String으로 변환한다.

◦

ObjectMapper를 사용하여 메시지 본문(JSON 문자열)을 ChatMessage 객체로 역직렬화한다.

◦

chatMessage.getTo() 필드의 존재 여부를 확인하여 귓속말인지 일반 메시지인지를 판단한다.

▪

귓속말인 경우: simpMessagingTemplate.convertAndSendToUser(chatMessage.getTo(), "/queue/private", chatMessage);를 사용하여 특정 사용자(chatMessage.getTo())에게 /queue/private 목적지로 메시지를 전송한다. convertAndSendToUser는 /user/{userName}/queue/private 형태로 메시지를 라우팅한다.

▪

일반 메시지인 경우: simpMessagingTemplate.convertAndSend("/topic/room." + chatMessage.getRoomId(), chatMessage);를 사용하여 해당 채팅방의 topic 목적지(/topic/room.{roomId})를 구독하고 있는 모든 클라이언트에게 메시지를 전송한다.

ChatController

ChatController 클래스는 클라이언트로부터 STOMP 메시지를 수신하고, 이를 Redis 채널로 발행하는 역할을 한다.

package org.example.backendproject.stompwebsocket.controller;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.RequiredArgsConstructor;
import org.example.backendproject.stompwebsocket.dto.ChatMessage;
import org.example.backendproject.stompwebsocket.redis.RedisPublisher;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.stereotype.Controller;

@Controller
@RequiredArgsConstructor
public class ChatController {

    private final RedisPublisher redisPublisher;
    private ObjectMapper objectMapper = new ObjectMapper();

    @Value("${PROJECT_NAME:web Server}")
    private String instanceName;

    // 동적으로 방 생성 가능
    @MessageMapping("/chat.sendMessage")
    public void sendMessage(ChatMessage message) throws JsonProcessingException {

        message.setMessage(instanceName + " " + message.getMessage());

        String channel = null;
        String msg = null;

        if (message.getTo() != null && !message.getTo().isEmpty()) {
            // 귓속말
            // 내 아이디로 귓속말 경로를 활성화 함
            channel = "private." + message.getRoomId(); // Note: room.Id in private chat might be confusing if it's not a real room
            msg = objectMapper.writeValueAsString(message);
        } else {
            // 일반 메시지
            // message에서 roomId를 추출해서 해당 roomId를 구독하고 있는 클라이언트에게 메세지를 전달
            channel = "room." + message.getRoomId();
            msg = objectMapper.writeValueAsString(message);
        }

        redisPublisher.publish(channel, msg);
    }
}
Java
복사

•

@Controller 어노테이션은 이 클래스가 Spring MVC 컨트롤러임을 나타내지만, WebSocket 메시징에서는 @MessageMapping을 처리하는 컴포넌트 역할을 한다.

•

@RequiredArgsConstructor는 RedisPublisher에 대한 생성자를 자동으로 생성한다.

•

@Value("${PROJECT_NAME:web Server}")는 환경 변수 PROJECT_NAME의 값을 instanceName 필드에 주입하며, 기본값은 "web Server"이다. 이 값은 메시지에 서버 인스턴스 이름을 추가하는 데 사용된다.

•

ObjectMapper는 Java 객체를 JSON 문자열로 직렬화하는 데 사용된다.

•

@MessageMapping("/chat.sendMessage")는 클라이언트가 /app/chat.sendMessage 목적지로 메시지를 보낼 때 이 sendMessage 메서드가 호출되도록 매핑한다.

•

sendMessage 메서드 내부:

◦

수신된 ChatMessage의 메시지 본문에 instanceName을 추가한다.

◦

chatMessage.getTo() 필드의 존재 여부를 확인하여 귓속말인지 일반 메시지인지를 판단한다.

▪

주의사항

•

귓속말인 경우: Redis 채널을 private.{roomId}로 설정하고, ChatMessage 객체를 JSON 문자열로 변환한다. 여기서 roomId가 귓속말 채널에 사용되는 것은 조금 의아할 수 있다. 보통 귓속말은 private.{수신자ID} 형태가 더 일반적이다. 만약 roomId가 실제 수신자의 고유 ID를 나타낸다면 문제가 없지만, 그렇지 않다면 혼란을 줄 수 있다.

•

일반 메시지인 경우: Redis 채널을 room.{roomId}로 설정하고, ChatMessage 객체를 JSON 문자열로 변환한다.

◦

준비된 channel과 msg를 redisPublisher.publish 메서드를 통해 Redis로 발행한다.

Redis Pub/Sub을 통한 전체 통신 흐름

클라이언트의 메시지 전송: WebSocket 클라이언트가 STOMP를 통해 /app/chat.sendMessage 목적지로 ChatMessage를 보낸다. (예: { "roomId": "general", "sender": "user1", "message": "Hello" } 또는 { "to": "user2", "roomId": "privateChatWithUser2", "sender": "user1", "message": "Hi private" })

ChatController의 메시지 수신: Spring은 @MessageMapping("/chat.sendMessage")에 따라 ChatController의 sendMessage 메서드를 호출한다.

Redis 채널 선택 및 발행:

•

ChatController는 수신된 ChatMessage의 to 필드를 확인하여 일반 메시지인지 귓속말인지를 판단한다.

•

일반 메시지: Redis 채널을 room.{roomId}로 설정하고, ChatMessage를 JSON 문자열로 직렬화하여 RedisPublisher.publish를 통해 Redis로 발행한다.

•

귓속말: Redis 채널을 private.{roomId} (여기서 roomId는 귓속말 대상의 고유 ID가 되어야 함)로 설정하고, ChatMessage를 JSON 문자열로 직렬화하여 RedisPublisher.publish를 통해 Redis로 발행한다.

Redis의 메시지 전달: Redis는 발행된 메시지를 해당 채널을 구독하고 있는 모든 RedisMessageListenerContainer 인스턴스(즉, 여러 서버 인스턴스)로 전달한다.

RedisSubscriber의 메시지 수신: 각 서버 인스턴스에 있는 RedisConfig에 의해 등록된 RedisSubscriber의 onMessage 메서드가 Redis로부터 메시지를 수신한다.

메시지 역직렬화 및 WebSocket 전송:

•

RedisSubscriber는 수신된 메시지 본문을 ChatMessage 객체로 역직렬화한다.

•

ChatMessage의 to 필드를 다시 확인한다.

◦

귓속말: simpMessagingTemplate.convertAndSendToUser(chatMessage.getTo(), "/queue/private", chatMessage);를 사용하여 원래 귓속말의 대상(chatMessage.getTo())에게만 WebSocket 메시지를 전송한다. chatMessage.getTo()에 해당하는 사용자만 "/user/{to}/queue/private"를 구독하여 이 메시지를 받게 된다.

◦

일반 메시지: simpMessagingTemplate.convertAndSend("/topic/room." + chatMessage.getRoomId(), chatMessage);를 사용하여 해당 채팅방을 구독하고 있는 모든 클라이언트에게 WebSocket 메시지를 전송한다. 이들은 "/topic/room.{roomId}"를 구독하고 있다.

클라이언트의 메시지 수신: WebSocket 클라이언트는 구독하고 있는 STOMP 목적지(예: /topic/room.{roomId} 또는 /user/{myNickname}/queue/private)를 통해 메시지를 수신한다.

이 설계의 장점:

•

수평 확장성: Redis Pub/Sub을 사용하면 여러 Spring WebSocket 서버 인스턴스를 실행하여 부하를 분산하고 서비스의 확장성을 확보할 수 있다. 어떤 서버 인스턴스로 메시지가 들어오든 Redis를 통해 모든 관련 서버 인스턴스에 전달되고, 각 인스턴스는 연결된 클라이언트에게 메시지를 전달할 수 있다.

•

Decoupling (결합도 감소): 메시지 발행자와 구독자가 직접 통신하는 것이 아니라 Redis를 통해 간접적으로 통신하므로, 시스템 컴포넌트 간의 결합도가 낮아진다.