MSA 구성

목차

1. 전체 시스템 구성도
2. 서비스 구성
3. 서비스간 통신
4. 배포 전략
5. 데이터 저장소 분리
6. 서비스 라우팅
7. 도입 효과

---

전체 시스템 구성도

---

서비스 구성

1. threadly-service(메인 서비스)

주요 역할

• Threadly 전체의 핵심 비즈니스 로직을 담당하는 메인 서비스
• SNS의 주요 기능 제공

기능

• 사용자 관련: 회원가입, 로그인, 프로필 등 관리
• 게시물 관련: 게시글, 게시글 활동(좋아요, 댓글, 댓글 좋아요), 조회수 등 관리
• 팔로우 관련: 팔로우/언팔로우 관리
• 보안 관련: JWT 인증, 인가, 블랙리스트, 2FA 인증 등 관리

2. notification-service(알림 서비스)

주요 역할

• 알림 및 메일 발송 기능 전담
• 이벤트 기반 알림 처리

기능

• 알림 수신 후 알림 데이터 저장
• WebSocket을 이용한 실시간 알림
• SMTP를 이용한 메일 발신
• 알림 조회, 수정, 읽음 처리 등 상태 관리 및 API 제공

---

서비스 간 통신

Kafka 기반 통신

threadly-service 이벤트 발생
         ↓
    Kafka Topic 발행
         ↓
notification-service 수신
         ↓
    알림 처리 및 전송

이벤트 흐름

• threadly-service에서 비즈니스 이벤트 발생 (좋아요, 댓글, 팔로우 등)
• Kafka를 통해 이벤트 메시지 발행
• notification-service에서 이벤트 수신 및 해당 기능 수행

---

배포 전략

각 서비스별 무중단 배포

1. threadly-service:

   • Blue: app-blue (8080 포트)
   • Green: app-green (8081 포트)

2. notification-service:

   • Blue: notification-blue (8082 포트)
   • Green: notification-green (8083 포트)

상세 문서: 무중단 배포

---

데이터 저장소 분리

서비스별 전용 데이터베이스

• threadly-service: PostgreSQL (관계형 데이터 저장)
• notification-service: MongoDB (알림/이벤트 로그용 문서 기반 저장)
• 공통 캐시: Redis (JWT 인증 토큰 관리)

데이터 일관성 원칙

• 각 서비스는 자체 데이터베이스만 직접 접근
• 서비스 간 데이터 공유는 API 또는 Kafka event 발행으로만 수행
• 분산 트랜잭션 대신 이벤트 기반으로 최종적 일관성 보장

상세 문서: 데이터 베이스 분리 전략

---

서비스 라우팅

Nginx를 게이트웨이로 두어 외부 요청을 서비스별로 분산 처리하도록 구성.

라우팅 규칙

• notification-service
  • https://api.threadly.kr/api/notifications/**
  • WebSocket 업그레이드 요청
• threadly-service
  • 위의 경우를 제외하고 모든 요청

---

운영 및 모니터링

서비스별 독립 운영

• 각 서비스는 독립적인 로그 디렉토리 관리
• 서비스별 Health Check 엔드포인트 제공

중앙화된 모니터링

• Prometheus: 메트릭 수집
• Grafana: 통합 대시보드
• Loki: 중앙화된 로그 수집

상세 문서: 운영 환경 모니터링

---

MSA 도입 효과

기술적 이점

1. 독립 개발
   • 각 서비스(threadly-service, notification-service)를 병렬로 개발 가능
2. 기술 스택 자유도
   • 서비스별로 최적화된 기술 사용
3. 장애 격리
   • 한 서비스 장애가 다른 서비스에 전파되지 않음
4. 확장성
   • 서비스 단위로 수평 확장 가능
   • 특히 notification-service는 Kafka Consumer 그룹 기반으로 설계되어 있어 인스턴스를 늘리면 자동으로 파티션을 분배받아 부하 분산 가능
5. 배포 유연성
   • 서비스별로 독립 배포가 가능해 전체를 재배포하지 않고 특정 서비스만 업데이트 가능
6. 모니터링 강화
   • 서비스 단위별 로그/메트릭 수집이 가능해 추적이 용이

---

관련 문서

• Kafka 장애 재시도 전략
• Kafka Producer 재시도 정책 (Resilience4j)
• Kafka Consumer 재시도 정책 (Spring Cloud Stream)