스프링웹소켓에 대해서 질문이 있습니다..!

Question

안녕하세요 웹소켓공부중인 학생입니다.현재 스프링 웹 플럭스와 소켓으로 카드게임을 구현 하고있는데요.하나의 소켓 커넥션에 채팅, 유저 상호작용, 데이터베이스접근 등등을 고려하다보니 10개이상의 액션이 생기더라구요..현재 이걸 switch case문으로 처리 하고있는데(flag가 sendMessage이면 채팅보내고..) 아무리 생각해봐도 비효율적인거같은데 처리 방법이 도저히 생각이 안나서 글을 올려봅니다..대략 이런 식입니다..! &#64;Override public Mono<Void> handle(WebSocketSession session) { log.info(&#34;room-socket sessionId {}&#34;, session.getId()); return session.receive() .map(message ->message.getPayloadAsText()) .flatMap(message -> { try { JsonNode jsonNode &#61; objectMapper.readTree(message); if(jsonNode.get(&#34;type&#34;) &#61;&#61; null) return Mono.empty(); String messageType &#61; jsonNode.get(&#34;type&#34;).asText(); log.info(&#34;message type {}&#34;, messageType); return switch (messageType) { case &#34;joinRoom&#34; -> roomService.joinRoom(jsonNode, session); case &#34;createRoom&#34; -> roomService.createRoom(jsonNode, session); case &#34;sendMessage&#34; -> roomService.sendMessage(jsonNode, session); case &#34;deleteRoom&#34; -> roomService.deleteRoom(jsonNode,session); case &#34;leaveRoom&#34; -> roomService.leaveRoom(session); default -> Mono.empty(); }; } catch (IOException e) { return Mono.error(new IllegalArgumentException(&#34;Invalid JSON format&#34;)); } }) .doFinally(signalType -> { roomService.leaveRoom(session).subscribe(); }) .then(); }읽어주셔서 감사합니다!

Clickin · Answer

MessageType Enum을 만들고 enum 필드에 메서드 참조를 넣어보면 좋겠습니다. 물론 이건 모든 파라미터/리턴이 공통이어야한다는 전제가 있습니다.예시입니다. 돌려보지 않았기 때문에 참고만 하시면 됩니다.&#64;Getter public enum MessageType { JOIN_ROOM(&#34;joinRoom&#34;, RoomService::joinRoom), // 다른 상수 정의 // 생성자 부분 private final String code; private final BiFunction fun; private static Map<String, MessageType> findMap &#61; Collections.unmodifiableMap(Stream.of(values()) .collect(Collectors.toMap(MessageType::getCode, Function.identity()))); public MessageType(String code, BiFunction fun) { this.code &#61; code; this.fun &#61; fun; } // 에러처리 알아서 public static MessageType fromCode(final String code) { return fromMap.get(code); } } // 사용방법 MessageType messageType &#61; Message.fromCode(jsonNode.get(&#34;type&#34;).asText()); return messageType.apply(jsonNode, session); // 형태가 다르면 이렇게 일반화할 수 없음

초무쿤 · Answer

STOMP로 각 액션별 토픽으로 하시는게 더 간단하지 않으시려나요.

스프링웹소켓에 대해서 질문이 있습니다..!

2개의 답변

#websocket 목록