Redis Stream 적용기

간단 소개

G마켓의 Redis Stream 적용 사례를 통해 Redis Stream의 특징, 개발 과정, 고려 사항 및 효과를 소개합니다.

AI Summary

Redis Stream 소개 및 선택 이유
- G마켓 Data Product 팀에서 session info data 적재 및 API 서비스 구축에 Redis Stream을 적용한 사례 소개
- 기존 Redis 사용 환경에서 트래픽 급증으로 인한 데이터 처리 지연 문제 해결을 위해 Redis Stream을 선택
- Kafka나 MQ 대비 개발 공수 및 리소스 소모를 줄이고, 기존 로직을 최소화하면서 빠른 히스토리 적재가 가능
Redis Stream의 특징 및 개발 과정
- Pub/Sub 방식의 단점을 보완하여 메시지 유실 및 중복 문제를 해결하고, consumer group을 통해 병렬 처리 지원
- XADD, XREADGROUP, XACK, XPENDING, XCLAIM 등의 명령어를 통해 메시지 컨트롤 가능
- Spring Boot 프로젝트에서 spring-boot-starter-data-redis 의존성을 추가하여 Redis Stream 메시지를 소비하는 consumer Group과 Listener Container를 설정하고 초기화
Redis Stream 적용 시 고려 사항 및 효과
- 파티션 개념이 없어 메시지 처리 순서 보장이 어렵고, in-memory 기반이므로 메모리 관리가 중요
- Pending 메시지 처리 로직을 추가하여 메모리 full 이슈 방지
- Redis Stream 적용 후 트래픽 처리 지연 문제 해결 및 서비스 안정성 향상