1. 개선 배경

기존 시스템은 API 요청 시 RDB에 직접 데이터를 저장하는 동기 방식으로 처리하고 있었습니다.

이 방식은 요청 처리량이 증가할수록 DB 트랜잭션 병목이 발생하며,

응답 지연과 시스템 확장성의 한계를 드러내는 문제가 있었습니다.

before

after

2. 개선 내용

• Redis Streams를 도입하여 비동기 구조로 전환
  • 클라이언트 요청 시 RDB에 직접 저장하는 대신, Redis Streams에 메시지를 발행
  • 실제 저장 처리는 별도의 Consumer가 비동기적으로 수행
• Outbox Pattern을 함께 적용하여 데이터 정합성 확보
  • RDB에 이벤트 로그(Outbox)를 저장한 뒤, Redis 발행은 트랜잭션 외부에서 별도 수행
  • 처리 성공 여부를 상태로 관리하며, 메시지 손실과 중복을 방지

3. 처리 구조 요약

[API 요청]
    ↓
[Outbox 저장 (RDB)]
    ↓
[Scheduler 또는 Worker]
    ↓
[Redis Stream 발행]
    ↓
[Consumer (비동기 처리)]
    ↓
[RDB 반영 및 ack 처리]

4. 개선 효과

• 평균 응답시간 4.2초 → 4.0초로 개선