Что такое Redis Streams?

Question

Accepted Answer

**Redis Streams** — это структура данных журнала, допускающего только добавление (append-only log) — как надежная очередь сообщений или журнал событий — поддерживающая **группы потребителей**, сохранение сообщений, подтверждения и воспроизведение. Это ответ Redis на надежный обмен сообщениями, более надежный, чем Pub/Sub (который работает по принципу "выстрели и забудь").

## Журнал сообщений, допускающий только добавление

```bash
# add entries to a stream (each gets an auto ID: timestamp-sequence)
XADD events * type "signup" user "ann"     # * = auto-generate ID; returns e.g. 1700000000-0
XADD events * type "login" user "bob"

XLEN events                                 # number of entries
XRANGE events - +                           # read all entries (- to +)
XREAD COUNT 10 STREAMS events 0             # read entries (from ID 0)
```

Streams — это **журнал, допускающий только добавление**: записи добавляются командой `XADD` (каждая с уникальным, упорядоченным по времени ID) и сохраняются в потоке — в отличие от Pub/Sub, сообщения не теряются; они хранятся и могут быть прочитаны повторно.

## Группы потребителей — надежная масштабируемая обработка

```bash
# create a consumer group to process the stream
XGROUP CREATE events workers 0

# consumers read messages (each message goes to ONE consumer in the group)
XREADGROUP GROUP workers consumer1 COUNT 1 STREAMS events >

# acknowledge a processed message (so it's not redelivered)
XACK events workers 1700000000-0
# unacknowledged messages can be reclaimed (XPENDING/XCLAIM) → no message lost on crash
```

**Группы потребителей** распределяют сообщения между несколькими потребителями (масштабируя обработку), при этом каждое сообщение попадает только одному потребителю, **подтверждения** (`XACK`) подтверждают обработку, а **отложенные сообщения/перезахват** (`XPENDING`/`XCLAIM`) обеспечивают, что сообщения не будут потеряны, если потребитель упадет — надежная доставка с гарантией минимум один раз.

## Streams vs Pub/Sub

```text
PUB/SUB  → fire-and-forget; offline subscribers MISS messages; no persistence/replay
STREAMS  → PERSISTENT log; messages stored; consumer groups; acknowledgments; replay
  → Streams = when you need RELIABLE delivery, message history, and scalable consumers
  → Pub/Sub = simple real-time broadcast where missing messages is OK
Streams are similar to a lightweight Kafka (log + consumer groups).
```

## Почему это важно

Понимание Redis Streams ценно для **надежного обмена сообщениями и обработки событий** внутри Redis, так что это полезные знания — особенно потому, что Streams решают ключевые ограничения Pub/Sub.

Хотя Pub/Sub простой, но работает по принципу "выстрели и забудь" (оффлайн подписчики безвозвратно пропускают сообщения, нет сохранения), **Streams обеспечивают надежный обмен сообщениями**: **журнал с постоянным хранением, допускающий только добавление**, где сообщения хранятся (не теряются) и могут быть повторно прочитаны/воспроизведены, плюс **группы потребителей**, которые распределяют сообщения между несколькими потребителями для масштабируемой обработки, **подтверждения** (`XACK`) для подтверждения обработки и **перезахват отложенных сообщений** (`XPENDING`/`XCLAIM`), чтобы сообщения не были потеряны при падении потребителя — обеспечивая доставку минимум один раз, надежную, масштабируемую обработку сообщений.

Понимание **Streams vs Pub/Sub** (Streams для надежной доставки, истории и масштабируемых потребителей; Pub/Sub для простой трансляции в реальном времени, где потери приемлемы) важно для выбора правильного примитива обмена сообщениями Redis.

Осознание того, что Streams **подобны облегченной Kafka** (журнал с группами потребителей), помогает понять их роль — обеспечивает возможности потоковой передачи событий/очереди сообщений внутри Redis без отдельного брокера для умеренных потребностей, в то время как выделенные брокеры (Kafka, RabbitMQ) остаются подходящим выбором для более крупномасштабного или более требовательного обмена сообщениями.

Поскольку надежный обмен сообщениями и обработка событий — это общие потребности, а Redis Streams обеспечивают надежное, постоянное решение на основе групп потребителей (преодолевая ограничение "выстрели и забудь" в Pub/Sub) внутри Redis, понимание Redis Streams — журнала, допускающего только добавление, групп потребителей с подтверждениями и перезахватом, и того, как они сравниваются с Pub/Sub и Kafka — это ценные, практически релевантные знания для создания надежного обмена сообщениями и событийно-ориентированных функций с Redis, правильный выбор, когда вам нужны гарантии доставки и история сообщений, которые Pub/Sub не может обеспечить.