오배송은 배달 라이더를 위한 주문 매칭, 실시간 알림, 인센티브 지급 및 상담 지원 서비스입니다.
멀티모듈 아키텍처를 기반으로 대규모 트래픽을 고려한 모니터링 및 실시간 처리 구조를 설계하고 구현하였습니다.
- 배달 이벤트 발생 시, 가게 위치 기준으로 인근 라이더를 탐색하여 매칭 이벤트 발행
- 매칭 이벤트 발생 시, 라이더들에게 알림 전송 (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로 배포.
- ✅ Eureka, Gateway 를 활용한 서비스 등록·탐색 구현
- ✅ Kafka 기반 비동기 이벤트 처리
- ✅ 보상 트랜잭션 구현
- ✅ DLQ 기반 장애 대응 및 재처리 로직
- ✅ 라이더 매칭 실시간 알림 (RabbitMQ, Slack, WebSocket)
- ✅ 라이더 실시간 위치 추적 (Redis GEO, WebSocket)
- ✅ Prometheus, Grafana 기반 모니터링, Slack 메시지를 통한 에러 메시지 전송