Kaip veikia Redis Pub/Sub?

Question

Accepted Answer

**Pub/Sub** (Publish/Subscribe) yra Redis žinučių modelis, kuriame **leidėjai** siunčia žinutes į **kanalus**, o **prenumeratoriai** gauna žinutes iš kanalo, kuriems jie prenumeruoti — leidėjai ir prenumeratoriai vienas kito nepažįsta. Tai leidžia realiu laiku keistis žinutėmis ir užtikrina atsiskyrusi komunikaciją tarp paslaugų.

## Pub/Sub modelis

```bash
# Subscriber listens on a channel
SUBSCRIBE news                    # subscribe to the "news" channel

# Publisher sends a message to the channel (in another connection)
PUBLISH news "Breaking story!"    # all subscribers to "news" receive this instantly

# Pattern subscriptions (wildcards)
PSUBSCRIBE news.*                 # subscribe to news.sports, news.tech, etc.
```

Leidėjai `PUBLISH` į kanalą; prenumeratoriai `SUBSCRIBE` į kanalus ir realiu laiku gauna žinutes. Jie yra **atsiskyrę** — leidėjas nežino, kas (jei kas nors) klausosi.

## Panaudojimo atvejai

```text
✓ REAL-TIME notifications — push events to interested services/clients instantly
✓ Chat / messaging — broadcast messages to subscribers
✓ Live updates — dashboards, feeds, multiplayer (broadcast state changes)
✓ Decoupling services — services communicate via channels without direct coupling
✓ Often paired with WebSockets (Redis pub/sub → server → WebSocket → browser)
```

## Svarbi ribotis: degimo ir pamiršimo modelis

```text
⚠️ Redis Pub/Sub is FIRE-AND-FORGET (at-most-once delivery):
  → Messages are delivered ONLY to subscribers connected AT THAT MOMENT.
  → If a subscriber is offline/disconnected, it MISSES the message (no storage/replay).
  → No persistence, no acknowledgment, no delivery guarantee.
→ NOT suitable when you need reliable delivery or message history.
```

## Kai reikalingas patikimumas: naudokite Streams

```text
For RELIABLE messaging (persistence, replay, consumer groups, acknowledgments):
  → use Redis STREAMS (a durable, log-based structure) instead of Pub/Sub
  → or a dedicated message broker (Kafka, RabbitMQ)
Pub/Sub → simple real-time broadcast where missing messages is acceptable
Streams → when you need durability and delivery guarantees
```

## Kodėl tai svarbu

Suprasti Redis Pub/Sub vertinga dėl **realaus laiko žinučių ir atsiskyrusi komunikacijos**, todėl tai naudinga žinia — tačiau kritiškai svarbu suprasti ir jo apribojimus, kad jį taikyti tinkamiau.

Pub/Sub įgalina **realaus laiko žinutes**, kai leidėjai transliuoja į kanalus, o prenumeratoriai gauna žinutes iš karto, kai leidėjai ir prenumeratoriai yra **atsiskyrę** (vienas kito nepažįsta) — tai galimina tokius panaudojimo atvejus, kaip realaus laiko pranešimai, pokalbiai, tiesioginės aparatūros panelės atnaujinimai ir atsiskyrusi paslaugų komunikacija (dažnai naudojama su WebSockets, skirta atnaujinimams siųsti į naršykles).

Tai daro Redis paprastą ir greitą pasirinkimą realaus laiko transliavimo funkcijoms.

Tačiau **svarbiausia yra** suprasti Pub/Sub **degimo ir pamiršimo apribojimą**: jis turi maksimaliai vieną kartą pristatyti žinutes — žinutes gauna tik prenumeratoriai, prijungti tuo metu, o neprisijungę prenumeratoriai **visam laikui praleista žinutes** (nėra išsaugojimo, pakartojimo, patvirtinimo ar pristatymo garantijos).

Tai kritiškas apribojimas: Pub/Sub nėra tinkamas, kai patikimas pristatymas arba žinučių istorija yra svarbi, o nesupratus to, atsiranda žinutės nutrūkimo klaidos.

Žinant alternatyvas — **Redis Streams** (patvariu, žurnalo pagrindas, su prenumeratorių grupėmis ir patvirtinimais) arba dedikuoti brokeriai (Kafka, RabbitMQ) patikimam žinučių siuntimui — ir pasirenkant Pub/Sub tik paprastam realaus laiko transliavimui, kur praleistos žinutes yra priimtinos, tai rodo sveikus sprendimus.

Kadangi realaus laiko žinučios yra dažna poreikis, o Redis Pub/Sub suteikia paprastą sprendimą, bet su svarbiais patikimumo apribojimais (reikalingas Streams arba brokeris, kai garantijos yra reikalingos), suprasti Pub/Sub — kaip jis veikia, jo panaudojimo atvejus ir ypač jo degimo ir pamiršimo apribojimą bei kada naudoti Streams — yra vertinga, praktiškai svarbi žinia, skirta realaus laiko funkcijoms teisingai įgyvendinti, kur apribojimo supratimas yra toks pat svarbus, kaip ir galimybės supratimas.