[Feat] 채널 구분 및 입장, 퇴장 메시지 중개

[Berithx]

PR 타입

• [x] 기능 추가
• [ ] 기능 삭제
• [ ] 버그 수정
• [ ] 의존성, 환경 변수, 빌드 관련 코드 업데이트

반영 브랜치

feat/textchat-stream-> dev

변경 사항

• Sink를 기반으로 채널 구분하여 메시징 처리 로직 구현
• 입장 로그, 퇴장 로그 구현(현재 DB에 저장되지 않음)
• Sink에 구독자(세션)이 0일 경우 Sink는 초기화되어 새로운 Sink로 시작함.
  • Sink에 구독자가 0일 때 소켓 연결이 안되는 오류가 있음.
• 현재 Sink의 관리 전략은 onBackpressureBuffer로 버퍼 크기 및 드랍 여부는 설정하지 않음.
  • 서버 운영 상황 및 전략에 따라 차후 수정 가능
• 채팅방 퇴장, 오류로 인한 소켓 연결 종료 시 자동 서버에 저장된 세션 정리

현 상태 관련 사용 방법 (src - templates - text - index.html 기준)

1. 로컬에서 바로 실행 시 CORS 오류 발생 -> VS코드에서 라이브 서버 실행 후 적용 가능

2. HTTP Request를 통해 사전 JWT 획득 및 채널 생성 필요(메시지 저장 간 채널 ID가 존재하지 않으면 오류 발생)

3. JWT 및 연결하고자 하는 채널 입력 후 연결 버튼 (완료, 설정 버튼 누르지 않아도 됨)

4. 이후 메시지 입력

5. 소켓 통신 간 사용되는 값

• 소켓 연결 : URI를 통한 채널 ID 및 JWT 토큰 정보
• 입, 퇴장 메시지 : 문자열
• 메시지 전송 : contents (TextReques 객체)
• 메시지 수신 : id, contents, username, createdAt, channelId (테스트 환경에서 channelId는 Html 객체에 부여하지 않음)

테스트 결과

동일 채널에서 소켓 연결 및 채팅 시 입장 시점을 기준으로 메시지 출력 확인

다른 채널일 때 독립적인 메시징 처리 확인