Τι είναι τα Redis Streams;

Question

Accepted Answer

**Redis Streams** είναι μια δομή δεδομένων append-only log — σαν μια ανθεκτική message queue ή event log — που υποστηρίζει **consumer groups**, persistence μηνυμάτων, acknowledgments, και replay. Είναι η απάντηση του Redis σε αξιόπιστη ανταλλαγή μηνυμάτων, πιο ισχυρή από το Pub/Sub (το οποίο είναι fire-and-forget).

## Append-only log μηνυμάτων

```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 είναι ένα **append-only log**: οι καταχωρήσεις προστίθενται με `XADD` (καθεμία με ένα μοναδικό, χρονικά ταξινομημένο ID) και παραμένουν στο stream — σε αντίθεση με το Pub/Sub, τα μηνύματα δεν χάνονται. αποθηκεύονται και μπορούν να διαβαστούν ξανά.

## Consumer groups — αξιόπιστη, επεκτάσιμη επεξεργασία

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

Τα **consumer groups** διανέμουν μηνύματα σε πολλούς consumers (επεκτείνοντας την επεξεργασία), με κάθε μήνυμα να πηγαίνει σε έναν consumer, τα **acknowledgments** (`XACK`) επιβεβαιώνουν την επεξεργασία, και το **pending/reclaim** (`XPENDING`/`XCLAIM`) διασφαλίζει ότι τα μηνύματα δεν χάνονται εάν ένας consumer καταρρεύσει — αξιόπιστη, at-least-once delivery.

## 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 είναι πολύτιμη για **αξιόπιστη ανταλλαγή μηνυμάτων και event processing** εντός του Redis, επομένως είναι χρήσιμη γνώση — ιδιαίτερα επειδή τα Streams αντιμετωπίζουν τους βασικούς περιορισμούς του Pub/Sub.

Το Pub/Sub είναι απλό αλλά fire-and-forget (οι offline subscribers χάνουν μόνιμα τα μηνύματα, χωρίς persistence), ενώ τα **Streams παρέχουν αξιόπιστη ανταλλαγή μηνυμάτων**: ένα **append-only persistent log** όπου τα μηνύματα αποθηκεύονται (δεν χάνονται) και μπορούν να διαβαστούν/επαναληφθούν, συν **consumer groups** που διανέμουν μηνύματα σε πολλούς consumers για επεκτάσιμη επεξεργασία, **acknowledgments** (`XACK`) για να επιβεβαιώσουν την επεξεργασία, και **pending-message reclaim** (`XPENDING`/`XCLAIM`) ώστε τα μηνύματα να μην χαθούν όταν ένας consumer καταρρεύσει — παρέχοντας at-least-once, αξιόπιστη, επεκτάσιμη επεξεργασία μηνυμάτων.

Η κατανόηση του **Streams vs Pub/Sub** (Streams για αξιόπιστη delivery, ιστορικό και επεκτάσιμους consumers· Pub/Sub για απλή real-time μετάδοση όπου η απώλεια είναι αποδεκτή) είναι σημαντική για την επιλογή του σωστού Redis messaging primitive.

Η αναγνώριση ότι τα Streams είναι **παρόμοια με ένα lightweight Kafka** (log-based με consumer groups) βοηθά στο να κατανοήσουμε το ρόλο τους — παρέχοντας event-streaming/message-queue δυνατότητες εντός του Redis χωρίς έναν ξεχωριστό broker για μέσες ανάγκες, ενώ dedicated brokers (Kafka, RabbitMQ) παραμένουν κατάλληλοι για μεγαλύτερης κλίμακας ή πιο απαιτητικές ανάγκες ανταλλαγής μηνυμάτων.

Επειδή η αξιόπιστη ανταλλαγή μηνυμάτων και η event processing είναι κοινές ανάγκες, και επειδή τα Redis Streams παρέχουν μια ισχυρή, persistent, consumer-group-based λύση (ξεπερνώντας τον fire-and-forget περιορισμό του Pub/Sub) εντός του Redis, η κατανόηση των Redis Streams — το append-only log, τα consumer groups με acknowledgments και reclaim, και πώς συγκρίνονται με το Pub/Sub και το Kafka — είναι πολύτιμη, πρακτικά σχετική γνώση για τη δημιουργία αξιόπιστης ανταλλαγής μηνυμάτων και event-driven features με το Redis, η σωστή επιλογή όταν χρειάζεστε delivery guarantees και message history που το Pub/Sub δεν μπορεί να παρέχει.