채팅 읽음 처리 구현 과정에서 고민이 있습니다.

Question

웹소켓과 메시지큐를 이용해서 채팅을 구현중인데 메시지 읽음을 어떻게 처리하는게 효율적인지 잘 모르겠습니다.처음 구상한것은 채팅방 참여 테이블에 사용자마다 readAt이라는 필드를 두어 채팅방에 접속할 때, 소켓을 통해 새로운 메시지를 전달받을 때 해당 필드를 업데이트하는 api를 호출하고 메시지 전송 시간과 비교하여 안읽은 메시지를 구분하려했는데 이러면 소켓 참가시 채팅 요청마다 업데이트 쿼리가 발생하므로 비효율적일 수 있다고 생각하였습니다. 하지만 다른 방법이 떠오르지 않는데 어떻게 구현하는게 좋을까요? 추가로 메시지 저장도 웹소켓에서 사용자가 메시지를 보낼때 save 쿼리를 날리는데 이거도 다른 방법으로 처리할 수 있을까요?

Constant · Answer

일단 가장 원초적으로 메시지 하나에 리스트 형태로 읽은 사람 담는게 일반적이겠죠. 그 뿌리부터 시작해야할거같네요. save가 빈번하게 일어나는건 일단 그렇게 처리하고 추후에 얼마나 많이 병목이나 부하가 일어나느냐에 따라 레디스나 카프카를 사용해서 병목 현상을 줄일 수 있을거같습니다

데브폐인 · Answer

사용자가 마지막 읽은 메세지 순번을 기억시키는 방식이 가장 효율적입니다.

오리구이 · Answer

그쵸 메세지id+ custid+ readAt를 관리 해야죠. 이것만 별도 테이블로 만들었었는데. 아니면 말씀하신대로 최종 readAt를 만 관리하고 그 이후 message를 찾아서 해도 되고요.하지만 채팅에서 update는 지양해야 합니다.

채팅 읽음 처리 구현 과정에서 고민이 있습니다.

3개의 답변

Q&A 목록