Redis Stream이란 무엇인가요?

Question

Accepted Answer

**Redis Stream**은 추가 전용 로그 데이터 구조입니다 — 내구성 있는 메시지 큐나 이벤트 로그와 유사하며 — **consumer group**, 메시지 persistence, 확인, 재생을 지원합니다. fire-and-forget인 Pub/Sub보다 견고한, 신뢰성 있는 메시징에 대한 Redis의 답입니다.

## 메시지의 추가 전용 로그

```bash
# stream에 항목 추가 (각각 자동 ID 부여: timestamp-sequence)
XADD events * type "signup" user "ann"     # * = 자동 ID 생성; 예: 1700000000-0 반환
XADD events * type "login" user "bob"

XLEN events                                 # 항목 수
XRANGE events - +                           # 모든 항목 읽기 (- 에서 +)
XREAD COUNT 10 STREAMS events 0             # 항목 읽기 (ID 0부터)
```

Stream은 **추가 전용 로그**입니다: 항목이 `XADD`로 추가되고(각각 고유한 시간 순 ID와 함께) stream에 유지됩니다 — Pub/Sub과 달리 메시지가 손실되지 않고 저장되어 다시 읽을 수 있습니다.

## consumer group — 신뢰성 있고 확장 가능한 처리

```bash
# stream을 처리할 consumer group 생성
XGROUP CREATE events workers 0

# consumer가 메시지 읽기 (각 메시지는 그룹 내 한 consumer에게 감)
XREADGROUP GROUP workers consumer1 COUNT 1 STREAMS events >

# 처리된 메시지 확인 (재전달 방지)
XACK events workers 1700000000-0
# 확인되지 않은 메시지는 회수 가능 (XPENDING/XCLAIM) → 크래시 시 메시지 손실 없음
```

**consumer group**은 메시지를 여러 consumer에 분배(처리 확장)하며, 각 메시지가 한 consumer에게 가고, **확인**(`XACK`)이 처리를 검증하며, **pending/회수**(`XPENDING`/`XCLAIM`)가 consumer 크래시 시 메시지 손실을 방지합니다 — 신뢰성 있는 at-least-once 전달입니다.

## Stream 대 Pub/Sub

```text
PUB/SUB  → fire-and-forget; 오프라인 구독자는 메시지 놓침; persistence/재생 없음
STREAM   → 영구 로그; 메시지 저장; consumer group; 확인; 재생
  → Stream = 신뢰성 있는 전달, 메시지 이력, 확장 가능한 consumer가 필요할 때
  → Pub/Sub = 메시지 손실이 OK인 단순 실시간 브로드캐스트
Stream은 경량 Kafka와 유사 (로그 + consumer group).
```

## 왜 중요한가

Redis Stream을 이해하는 것은 Redis 내에서 **신뢰성 있는 메시징과 이벤트 처리**에 가치가 있으므로 유용한 지식입니다 — 특히 Stream이 Pub/Sub의 핵심 제한을 해결하기 때문입니다.

Pub/Sub은 단순하지만 fire-and-forget인 반면(오프라인 구독자가 메시지를 영구히 놓침, persistence 없음), **Stream은 신뢰성 있는 메시징**을 제공합니다: 메시지가 저장되고(손실되지 않음) 다시 읽기/재생 가능한 **추가 전용 영구 로그**, 확장 가능한 처리를 위해 메시지를 여러 consumer에 분배하는 **consumer group**, 처리를 확인하는 **확인**(`XACK`), consumer 크래시 시 메시지가 손실되지 않게 하는 **pending 메시지 회수**(`XPENDING`/`XCLAIM`) — at-least-once의 신뢰성 있고 확장 가능한 메시지 처리를 제공합니다.

**Stream 대 Pub/Sub**(신뢰성 있는 전달, 이력, 확장 가능한 consumer에는 Stream; 손실이 허용되는 단순 실시간 브로드캐스트에는 Pub/Sub)를 이해하는 것은 올바른 Redis 메시징 기본 요소를 선택하는 데 중요합니다.

Stream이 **경량 Kafka와 유사**(consumer group이 있는 로그 기반)함을 인식하면 그 역할을 잡는 데 도움이 됩니다 — 적당한 요구에는 별도 브로커 없이 Redis 내에서 이벤트 스트리밍/메시지 큐 기능을 제공하고, 더 큰 규모나 까다로운 메시징에는 전용 브로커(Kafka, RabbitMQ)가 여전히 적합합니다.

신뢰성 있는 메시징과 이벤트 처리는 흔한 요구이고, Redis Stream이 Redis 내에서 견고하고 영구적이며 consumer group 기반 해법(Pub/Sub의 fire-and-forget 제한 극복)을 제공하므로, Redis Stream — 추가 전용 로그, 확인과 회수가 있는 consumer group, Pub/Sub 및 Kafka와의 비교 — 을 이해하는 것은 Redis로 신뢰성 있는 메시징과 이벤트 기반 기능을 만드는 데 가치 있고 실무적으로 관련된 지식이며, Pub/Sub이 제공할 수 없는 전달 보장과 메시지 이력이 필요할 때 올바른 선택입니다.