웹 오픈채팅 구현시 대화저장 조언좀 부탁합니다.

Question

사이트에 웹으로 오픈채팅을 만들어서 추가 할려고 합니다.http://dongledongle.com/ <<-- 데모기능(대화내용 서버저장) spring에 sockjs가 있길래 구독형식의 오픈채팅방은 구현을 했는데 대화내용을 어떻게 저장하고 관리해야할지 잘모르겠네요. 단순히 DB에 전부 insert해서새로운 사람이 채팅방 입장시 이전 대화내용들을 전부 보여주려고 하는데너무 빈번하게 db에 insert 되는거같아서요... 좋은방법이 있나요? WebSocketConfig.java&#64;Configuration &#64;EnableWebSocketMessageBroker public class WebSockConfig implements WebSocketMessageBrokerConfigurer { &#64;Override public void configureMessageBroker(MessageBrokerRegistry config) { config.enableSimpleBroker(&#34;/sub&#34;); config.setApplicationDestinationPrefixes(&#34;/pub&#34;); } &#64;Override public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint(&#34;/ws-stomp&#34;).setAllowedOrigins(&#34;*&#34;) .withSockJS(); } } ChatController.java &#64;RequiredArgsConstructor &#64;Controller public class ChatController { private final SimpMessageSendingOperations messagingTemplate; private final ChatService service; &#64;MessageMapping(&#34;/chat/message&#34;) public void message(ChatMessage message){ if (ChatMessage.MessageType.ENTER.equals(message.getType())){ //입장 처리 }else{ mapper.insertLog(message); } messagingTemplate.convertAndSend(&#34;/sub/chat/room/&#34; &#43; message.getRoomId(), message); } }

컴포지트 · Answer

채팅은 속도가 중요합니다. DB는 단순 CRUD만 해도 은근 무거운 작업입니다.일단 위 예외의 자세한 내용이 없어서 좋은 제안밖에 못해드리겠지만,채팅을 저장하는 Listener 스레드를 따로 구성하고 거기에 채팅 내용과 정보를 저장하는 게 좋습니다.즉, 채팅 소켓과 DB 저장이 따로 노는 식으로 구성하는 거죠.채팅은 채팅에만 집중하고, DB는 DB에만 집중합니다.스프링에도 이벤트 처리를 지원하니 https://engkimbs.tistory.com/718 참조하시길.

등아픈환자 · Answer

컴포지트 //근데 리스너를 통해 따로따로 관리를 하다보면 대화 순서가 바뀌는 일은 안생길까요?

컴포지트 · Answer

&#64;등아픈환자네. 단순히 이벤트만 쓰기엔 순서 보장은 저도 못합니다. 이럴 때를 위해 존재하는 게 바로 메시지 큐입니다.자바 기반의 ActiveMQ 나 ZeroMQ 같은 메시지 큐 서버를 따로 꾸려 구성하고, 직접 순서를 보장하도록 꾸미면 됩니다.

웹 오픈채팅 구현시 대화저장 조언좀 부탁합니다.

3개의 답변

Q&A 목록