📑 개요

해당 서버에서는 사용자를 인증할 수 있는 기능이 없습니다.
그래서 인증할 수 있는 다른 서버로 요청을 보낸 후 결과를 받아 인증 여부를 확인합니다.

해당 기능을 어노테이션으로 처리하여 전송받은 값을 확인한 뒤 필요한 값을 가져오는 기능을 만듭니다.

AuthClient

🚀 상세 작업 내용

• AuthClient 완성
• 어노테이션 생성 및 기능 구현
• 테스트 코드 작성

⏰ 예상 소요 시간

하루

📁 ETC

📑 개요

SSE를 위한 Emitter 기능을 구현합니다.
Redis를 적용하기전 먼저 단순한 방법으로 진행합니다.

🚀 상세 작업 내용

• 연결 요청 API
• SSE 연결 기능
• 메시지 전송 기능

⏰ 예상 소요 시간

8시간

📁 ETC

• [Spring] SSE + Redis pub/sub
• [Spring + SSE + Redis] SSE를 사용한 실시간 알림 Scale out 시 문제점 해결하기
• Redis Pub/Sub 기반 SSE(Server-Sent Events) 실시간 알림 적용기

📑 개요

알림 서버에서 사용하는 kafka의 환경 설정을 추가합니다.

🚀 상세 작업 내용

• Properties 환경 설정
• 직렬화, 역직렬화 설정

⏰ 예상 소요 시간

1시간

📁 ETC

📑 개요

SseEmitter 관련 테스트 코드가 존재하지 않습니다.
연결하고, 알림을 보내는 테스트 코드가 필요하다고 느껴 해당 기능에 대한 테스트 코드를 작성합니다.

Target: NotificationServiceImpl

🚀 상세 작업 내용

• connections 테스트 코드 작성
  • sseEmitterCallback 테스트 코드 작성
• sendMessage 테스트 코드 작성

⏰ 예상 소요 시간

4시간

📁 ETC

📑 개요

로컬에서 동작할 수 있는 환경을 구성합니다.

🚀 상세 작업 내용

• embedded redis
• embedded mongodb
• profile 분리
• shell script 작성

⏰ 예상 소요 시간

3시간

📁 ETC

📑 개요

해당 프로젝트에서 사용하는 SSE 도메인을 작성합니다.

사용자의 닉네임이 수정될 수 있기 때문에 ~~~ 을 합니다.

🚀 상세 작업 내용

• Custom SSE Object 생성 ( Value: 사용자의 닉네임, SSE )
• SSE Repository 작성 ( CRUD )

⏰ 예상 소요 시간

2시간

📁 ETC

📑 개요

• #7

해당 PR에서 카프카 연결 기능을 만들었습니다. 아직 재대로 동작하는지 검증하는 테스트 코드가 없습니다.
그래서 필요한 기능마다 테스트 코드를 작성합니다.

🚀 상세 작업 내용

• Kafka 테스트 환경 구성
• GroupKafka 테스트 코드 작성
• ScheduleKafka 테스트 코드 작성
• Producer 테스트 코드 작성

⏰ 예상 소요 시간

하루

📁 ETC

📑 개요

현재 코틀린으로 사용했지만 자바 21에서 나온 가상 쓰레드가 코루틴보다 더 좋다는 의견이 많아 현재 진행된 코드를 Java21로 마이그레이션합니다.

🚀 상세 작업 내용

• Java21 프로젝트 생성
• SSE 코드 작성
• Kafka 코드 작성

⏰ 예상 소요 시간

2주

📁 ETC

📑 개요

#4 에서 Emitter로 연결하는 기능을 구현했습니다.

이번에는 Kafka로 통신하는 기능을 구현합니다.

🚀 상세 작업 내용

• Kafka Pub/Sub 기능 구현

⏰ 예상 소요 시간

1일

📁 ETC

• [Spring] SSE + Redis pub/sub
• [Spring + SSE + Redis] SSE를 사용한 실시간 알림 Scale out 시 문제점 해결하기
• Redis Pub/Sub 기반 SSE(Server-Sent Events) 실시간 알림 적용기

📑 개요

SseEmitterRepository 에 대한 테스트 코드가 존재하지 않습니다.
아래의 코드를 검증하는 테스트 코드를 작성합니다.

@Repository
class SseEmitterRepository(
    private val emitters: ConcurrentHashMap<Int, SseEmitter> = ConcurrentHashMap(),
) {
    fun save(memberId: Int, sse: SseEmitter): SseEmitter {
        emitters[memberId] = sse;
        return sse
    }

    fun findByMemberId(memberId: Int): SseEmitter? {
        return emitters[memberId]
    }

    fun deleteById(memberId: Int) {
        emitters.remove(memberId)
    }
}

🚀 상세 작업 내용

• save 테스트 코드 작성
• findByMemberId 테스트 코드 작성
• deleteById 테스트 코드 작성
• findBy와 deleteBy 의 네이밍 규칙 정하기

⏰ 예상 소요 시간

4시간

📁 ETC

findById VS findByMemberId ... 좀더 명확한 이름이 필요할 것 같습니다.