spring에서 2개의 핸들러의 세션 공유가 가능한가요?

Question

안녕하세요. 현재 프로젝트를 진행 중에 막혀서 질문을 올리게 되었습니다.현재 TextWebSocketHandler 에서 handlemessage 에 service를 실행하고 있습니다.여기서 service 또 다른 service2가 있고 service2 에서 이미 연결이 되어 있는 BinaryWebSocketHandler 에 연결이 되어있는 session list를 가져와서 별도로 데이터 전송을 해야하는데 이 부분이 안되는 상태입니다.이미 Text 쪽에서는 작동되는 부분이 있으며 별도로 binary를 뜷어서 데이터를 전송해야되는데 session list를 가져올 수가 없네요.각 handler에서 websocket 연결이 되어있는지 로그를 찍어보면 세션이 저장이 되어있다고 뜨는데service에서 각 handler에 연결되어있는 session 값을 찍어보면 null이 발생이 됩니다.service에서 handler에 연결되어 있는 session 값을 가져올 수 있는 방법이 있을까요?@Repository public class TextSocketHandler extends TextWebSocketHandler { private final Logger logger = LoggerFactory.getLogger(TextSocketHandler.class); private Set textSessionSet = new HashSet(); public static Map sessionTimeMap = new HashMap(); @Autowired WsProcessService wsProcessService; ObjectMapper mapper = new ObjectMapper(); List textWebSocketSessions = null;; public static Thread thread; public Set getSessionList() throws Exception { return textSessionSet; } @Override public void handleMessage(WebSocketSession session, WebSocketMessage message) throws Exception { super.handleMessage(session, message); long time = System.currentTimeMillis(); if (!textSessionSet.contains(session)) { session.close(); } AuthInfoResponse authInfoResponse = wsProcessService.processService(new AuthInfoResponse(), session, message, textSessionSet); //session.sendMessage(); } } } @Repository public class BinarySocketHandler extends BinaryWebSocketHandler { private final Logger logger = LoggerFactory.getLogger(BinarySocketHandler.class); private Set binarySessionSet = new HashSet(); public static Map sessionTimeMap = new HashMap(); ObjectMapper mapper = new ObjectMapper(); List binaryWebSocketSessions = null; public static Thread thread; public Set getSessionList() throws Exception { return binarySessionSet; } ...... } public class service2{ @Autowired BinarySocketHandler binarySocketHandler; @Autowired TextSocketHandler textSocketHandler; private Set textSessionSet = new HashSet(); private Set binarySessionSet = new HashSet(); public ByteString createFileTextToSpeechSampleSource(String text, String langCode) throws Exception { ByteString audioContents = textToSpeechWork.synthesizeText(text, langCode); ByteBuffer audioBuffer = audioContents.asReadOnlyByteBuffer(); testSocket(audioBuffer); return audioContents; } public void testSocket(ByteBuffer byteBuffer) throws Exception { Set biSessionList = binarySocketHandler.getSessionList(); Set txSessionList = textSocketHandler.getSessionList(); _logger.info("biSessionList : {}", biSessionList); _logger.info("txSessionList : {}", txSessionList); _logger.info("textSessionSet : {}", textSessionSet); _logger.info("binarySessionSet : {}", binarySessionSet); for (WebSocketSession wsSess : wsSessionList) { try { wsSess.sendMessage(new BinaryMessage(byteBuffer)); } catch (Exception e) { } } } }

spring에서 2개의 핸들러의 세션 공유가 가능한가요?

0개의 답변

Q&A 목록