[채팅] 채팅 기능 연동

[ypjun100]

Description

MongoDB를 기반한 채팅 기능 추가

Todo

• 채팅방 관련 엔티티 생성
• 소켓 채팅 구현
• MongoDB 연동 (엔티티 생성)
• 더미 유저 및 채팅방 생성하는 테스트 코드 작성
• 채팅방 정보 및 메시지 목록 API 구현
• 현재 사용자가 참여중인 채팅방 목록 API 구현 (JWT 연동, 테스트 코드 포함)
• 유저가 소켓에 접속 중이 아닌 경우 미확인 메시지에 데이터 추가하도록 구현
• 미확인 메시지 API 구현 (테스트 코드 포함)

Etc

• Socket.io 활용하기

[ypjun100]

• Socket.io로 구현시 Spring Cloud 환경에서 제대로 Load Balancing 되지 않을 것으로 판단함
  • 기본적으로 Socket.io를 사용하기 위한 Netty 라이브러리는 스프링 애플리케이션과 다른 서버를 별도로 구축하기 때문
  • 따라서, API Gateway와 생성한 Netty 서버가 정상적으로 연결되지 않을 수 있음

[ypjun100]

• 기존 Legacy WS 코드를 이용한다고 해도, MSA 환경에서는 동일한 애플리케이션이 여러 개가 띄어질 것이므로, 이 애플리케이션 간 연동 문제가 발생할 수 있음
• 따라서, MongoDB 내에서 소켓 세션을 저장해서 다른 애플리케이션에서 이 소켓 세션에 접근하여 메시지를 전송할 수 있는지 확인이 필요함

---

• MongoDB, Redis 확인 결과, 이 DB에는 Unserializable한 객체를 넣을 수 없는 것을 확인
• 따라서, Unserializable한 객체인 WebSocketSession 또한 저장되지 않았음
• 결론적으로, Legacy WS 코드를 활용하여 채팅 기능을 구성하고, 나중에 RabbitMQ를 활용하여 chat 서비스 간의 통신 구현

[ypjun100]

• Socket.io 대신 SockJS를 이용하여 구현 진행
• JWT 토큰을 요청 헤더에 넣어 검증하는 방식까지 구현 완료 (코드 리팩토링 필요)

[ypjun100]

• WebSocketInterceptor에서 토큰 내 이메일 정보를 사용자의 ID로 변환 완료
• SockJS를 이용한 기본적인 소켓 통신 구현 및 간단한 채팅 테스트 페이지 구성

[ypjun100]

소켓 채팅 구현

• 사용자 입장
• 사용자 채팅 메시지 (텍스트, 이미지)
• 사용자 퇴장

[ypjun100]

• 채팅방을 구독할 때 JWT 토큰을 검증하고, 해당 세션을 접속 중인 유저라고 판단하여 저장하게 됨
  • 만약 올바르지 않은 JWT 토큰인 경우 예외를 발생시켜 연결을 종료하게 됨
  • 검증된 유저는 더이상의 JWT 토큰 필요없이 통신이 가능함
• 추후에 유저의 세션이 종료될 때, 해당 유저 세션을 제거하여 더 이상 채팅방에 접속해있지 않다고 판단
• 이 정보를 바탕으로 '읽지 않은 메시지 API' 구현 예정

[ypjun100]

• 채팅방 메시지 리스트 불러오는 API 구현 (/api2/chat/room-data?id=test-chatroom)

[ypjun100]

현재 사용자가 참여중인 채팅방 목록 API 구현

• JWT 데이터 변경 (해당 변경 내용 msa 브런치에 반영)
• 웹소켓에서 정상적으로 데이터 불러오는지 확인
• 변경된 데이터 토대로 현재 사용자 판단 및 채팅방 목록 반환