실시간 데이터 전달 방식

1. 종목별 구독자 저장 방식

Redis pub/sub 기능으로 종목별 유저의 데이터가 Redis 에 set 자료구조 형태로 저장되어있다.

예를들면 “KRW-BTC” 라는 종목에 “1”, “2” 번의 userId 를 가진 Redis 의 market:KRW-BTC:subscribers 의 key 값에 value 값으로 저장되어있다.

• 해당 코드는 종목별로 userId 즉 해당 종목 채널에 구독자를 저장하는 로직이다.

redisTemplate.opsForSet().add("market:" + marketCode + ":subscribers", String.valueOf(userId));

1. 데이터 전달 방식

   • 해당 채널로부터 실시간 데이터가 발행이 되면 MessageListener 의 onMessage 함수가 실행된다.

   

   • 해당 종목의 구독자들을 가져와 해당 userId 기반으로 Websocket 이연결되있다면 실시간 데이터를 보내는 방식이다.

   

트러블 슈팅

#1.문제상황

2024-10-09T16:48:51.317+09:00 ERROR 12752 --- [market] [io-19100-exec-2] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet 
[dispatcherServlet] in context with path [] threw exception [Request processing failed: 
java.lang.IllegalStateException: No primary or single unique constructor found for interface org.springframework.web.socket.WebSocketSession] with root cause

해당 오류가 발생한 이유는 handleWebSocketConnect 메서드에서 WebSocketSession 객체를 매개변수로 받으려 시도했기 때문입니다. Spring MVC가 WebSocketSession을 자동으로 주입하려고 하지만, 이 타입은 Spring에서 일반 HTTP 요청의 컨텍스트에서 인식할 수 없습니다.

#1.문제 원인

• WebSocketSession은 WebSocket 연결이 성립되었을 때만 생성되는 객체이며, 일반 HTTP 요청으로 WebSocket 핸드셰이크를 시작할 때 사용할 수 없습니다.
• @RequestMapping은 일반 HTTP GET/POST 요청을 처리하기 위한 어노테이션이므로, 이를 통해 WebSocket의 세션을 얻으려는 시도는 실패하게 됩니다.

#1.해결 방안

1. WebSocket 핸드셰이크 및 연결 방식 수정:
   • Spring에서 WebSocket 핸드셰이크 및 연결을 처리하려면 WebSocketConfigurer 또는 STOMP 설정을 사용해야 합니다. 일반 HTTP 요청으로 WebSocketSession을 직접 주입하는 방식은 올바르지 않으므로 이 부분을 수정해야 합니다.
   • Spring의 WebSocketHandler를 사용하여 WebSocket 요청을 수신하고 WebSocketSession을 처리해야 합니다.
2. WebSocket 핸들러 정의:
   • WebSocket 연결을 수립하기 위해 WebSocketHandler를 구현하고, 이를 통해 WebSocket 세션을 관리할 수 있습니다.