Redis Streams Nedir?

Question

Accepted Answer

**Redis Streams**, güvenilir bir mesajlaşma sırası veya olay günlüğü gibi — append-only (yalnızca ekleme) bir günlük veri yapısıdır; **tüketici grupları**, mesaj kalıcılığı, onaylamalar ve yeniden okuma desteği sunun. Pub/Sub'ın cevabıdır (Pub/Sub ateşle-ve-unut şeklidir).

## Mesajların append-only günlüğü

```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 bir **append-only günlüktür**: girdiler `XADD` ile eklenir (her biri benzersiz, zaman sıralı bir ID'ye sahip) ve akışta kalır — Pub/Sub'ın aksine, mesajlar kaybolmaz; depolanır ve yeniden okunabilir.

## Tüketici grupları — güvenilir, ölçeklenebilir işleme

```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
```

**Tüketici grupları** mesajları birden çok tüketici arasında dağıtır (işleme ölçekler), her mesaj bir tüketiciye gider, **onaylamalar** (`XACK`) işlemeyi doğrular ve **beklemede/talep etme** (`XPENDING`/`XCLAIM`) bir tüketici çöküşürse mesajların kaybolmadığını garantiler — güvenilir, en-az-bir-kez teslim.

## 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).
```

## Neden önemli

Redis Streams'i anlamak **Redis içinde güvenilir mesajlaşma ve olay işleme** için değerlidir — özellikle de Streams, Pub/Sub'ın temel sınırlamalarını giderdiği için.

Pub/Sub basit ama ateşle-ve-unut olsa da (çevrimdışı abone mesajları kalıcı olarak kaybeder, kalıcılık yok), **Streams güvenilir mesajlaşma** sağlar: depolanan (kaybolmayan) ve yeniden okunabilen/tekrar oynatılabilen mesajlarla bir **append-only kalıcı günlük**, artı birden çok tüketici arasında mesajları dağıtan **tüketici grupları** (ölçeklenebilir işleme için), işlemeyi doğrulayan **onaylamalar** (`XACK`) ve bir tüketici çöküşürse mesajların kaybolmadığını sağlayan **beklemede-mesaj talep etme** (`XPENDING`/`XCLAIM`) — en-az-bir-kez, güvenilir, ölçeklenebilir mesaj işleme sunarlar.

**Streams vs Pub/Sub** anlamak (Streams güvenilir teslim, geçmiş ve ölçeklenebilir tüketiciler için; Pub/Sub kayıp kabul edilebilir basit gerçek-zamanlı yayın için) doğru Redis mesajlaşma ilkel seçmek için önemlidir.

Streams'in **hafif bir Kafka'ya benzer** (günlük tabanlı tüketici gruplarıyla) olduğunu anlamak rollerini çerçevelemesine yardımcı olur — orta ölçekli ihtiyaçlar için ayrı bir broker olmadan Redis'te olay-akışı/mesaj-sırası yetenekleri sağlar, büyük ölçekli veya daha talep eden mesajlaşma için adanmış brokerler (Kafka, RabbitMQ) uygun kalır.

Güvenilir mesajlaşma ve olay işleme yaygın ihtiyaçlar olduğundan ve Redis Streams güçlü, kalıcı, tüketici-grup-tabanlı bir çözüm (Pub/Sub'ın ateşle-ve-unut sınırlamasını aşarak) Redis'te sağladığından, Redis Streams'i anlamak — append-only günlüğü, onaylamalar ve talep etme ile tüketici grupları ve Pub/Sub ve Kafka ile nasıl karşılaştırıldıklarını — Pub/Sub'ın sağlayamadığı teslim garantileri ve mesaj geçmişi gerektiğinde Redis ile güvenilir mesajlaşma ve olay-güdümlü özellikler oluşturmak için değerli, pratik açıdan ilgili bir bilgidir.