110 lines (69 loc) · 4.58 KB

🚚 오배송 (Oh Delivery)

오배송은 배달 라이더를 위한 주문 매칭, 실시간 알림, 인센티브 지급 및 상담 지원 서비스입니다.

멀티모듈 아키텍처를 기반으로 대규모 트래픽을 고려한 모니터링 및 실시간 처리 구조를 설계하고 구현하였습니다.

🚀 서비스 주요 기능

🛵 라이더 매칭

배달 이벤트 발생 시, 가게 위치 기준으로 인근 라이더를 탐색하여 매칭 이벤트 발행
매칭 이벤트 발생 시, 라이더들에게 알림 전송 (Slack, WebSocket)
알림을 받은 라이더들 중 선착순 응답자와 배달 매칭 → Redisson 분산락을 활용해 동시 응답 충돌 방지

📦 배달 경로 및 위치 추적

Naver Open API를 활용하여 주소 기반 위도/경도 정보 조회, 최단 경로 제공
Redis GEO와 WebSocket을 활용한 라이더 실시간 위치 추적

💰 라이더 인센티브

배달 수행에 따른 라이더 배달료 및 인센티브 자동 책정
Kafka Streams를 활용하여 인센티브 정산을 위한 통계 데이터 처리

💬 상담 및 실시간 채팅

사용자의 상담 요청 시 상담원 자동 매칭, Redis를 통한 상담원 상태 관리
매칭 완료 후 채팅방 자동 오픈 (WebSocket 기반)
채팅 메시지는 STOMP 프로토콜 + WebSocket을 통해 전달되며, → Kafka를 통해 비동기 처리 후 MongoDB에 저장

👥 팀원 및 역할

🧑‍💻 팀원 역할 정리

이름	역할
박태훈	팀장 - 매칭, 라이더 서비스 도메인 설계 및 구현 - Kafka 기반 이벤트 시스템 설계 및 적용 - Command 패턴, CQRS 구조 적용을 통한 비즈니스 로직 분리 - AWS ECS 기반 배포
김형찬	테크 리더 - 프로젝트 구성 및 개발 환경 구축 - Naver Maps API를 이용한 라이더 최단 경로 탐색 - Redis GEO / WebSocket을 이용한 라이더 실시간 위치 추적
박보현	인증/인가 서비스 구현 - API Gateway 구현 - 회원가입, 로그인, 로그아웃 기능 구현 - WebSocket + STOMP + Kafka + MongoDB 기반의 상담원 채팅 서비스 구현
박경린	인센티브 처리 담당 - Kafka Streams 기반 인센티브 로직 구현 및 파티션을 이용한 병렬 처리 - StateStore를 활용한 인센티브 중복 지급 방지 및 하루 단위 데이터 삭제 - Prometheus + Grafana를 이용한 모니터링 - DLQ 기반 재처리 실패 대응 및 Slack 알림 전송
김지현	알림 및 상담원 매칭 서비스 구현 - 음식점 주소(위/경도) 기준 주변 라이더 조회 후 Slack / WebSocket으로 비동기 알림 전송 - 알림 실패 시 3회 재시도 후 DLT 전송 및 Slack 알림 - Redis + LeastBusy 방식 상담원 매칭 서비스 구현

🛠️ 기술 스택

🌿 Framework

Java 17
Spring Boot 3.4
Eureka
Feign Client
JPA
QueryDsl

💽 Database

PostgreSQL: 하나의 데이터베이스에 여러 스케마를 구성할 수 있어 선택
Redis : 빠른 활용이 필요한 데이터 저장 및 락을 위해 사용

📡 Messaging

Kafka : 서비스 간 메시지브로커와 데이터 스트림으로 메시지와 데이터 처리
WebSocket : 위치 추적, 채팅, 알림 통신을 열어 지속적인 실시간 데이터 통신에 활용

📊Monitoring

Prometheus : 매칭, 위치 추적 등 서비스 성능 모니터링
Grafana : 모니터링을 보기 편하게 도식화

🗄️Infrastructure

Aurora : postgresql DB를 aws의 aurora로 배포
Elastic Container Registry : 각 서비스의 컨테이너 이미지를 AWS ECR로 관리
Elastic Container Service : 각 서비스를 ECS를 통해 Fargate로 배포.

🗂️ ERD

🏗️ System Architecture

✨ 프로젝트 특징

✅ Eureka, Gateway 를 활용한 서비스 등록·탐색 구현
✅ Kafka 기반 비동기 이벤트 처리
✅ 보상 트랜잭션 구현
✅ DLQ 기반 장애 대응 및 재처리 로직
✅ 라이더 매칭 실시간 알림 (RabbitMQ, Slack, WebSocket)
✅ 라이더 실시간 위치 추적 (Redis GEO, WebSocket)
✅ Prometheus, Grafana 기반 모니터링, Slack 메시지를 통한 에러 메시지 전송