Csapatcsevegés és támogatási csevegés
Az üzenetek szétszóródnak minden olyan szerverhez, amely egy tag kapcsolatát tartja, a stream pedig a hátralékot adja az újonnan érkezőknek.
Alap adatkezelésValós idejű
Valós idejű csevegés és értesítések
Szórjon üzeneteket minden csatlakoztatott kliensnek valós időben, klaszterekhez shardolt csatornákkal, az előzményekhez streamekkel.
- közzététel, minden előfizető
- 1
- csatornák klaszterekhez
- Shardolt
- streamekkel
- +előzmények
Lépés 1 / 5
A szerverek feliratkoznak
Minden WebSocket-szerver feliratkozik azokra a szobákra, amelyekben a csatlakoztatott felhasználói vannak.
Példa munkamenetplaying
# A szerverek feliratkoznak
hotkv> SUBSCRIBE room:42
1) "subscribe"
2) "room:42"
3) (integer) 1
Animált bemutató valódi HotKV-parancsokkal és példa-válaszokkal. Kattintson bármelyik lépésre, hogy odaugorjon. A parancsok és a válaszok angolul maradnak, pontosan úgy, ahogy begépeli és látja őket a HotKV-ban.
A probléma
Egy csevegőszobának vagy élő értesítési hírfolyamnak egyszerre kell elérnie minden csatlakozott felhasználót, sok WebSocket-szerveren át. Az adatbázis lekérdezgetése túl lassú és túl drága, a szervereknek pedig közös módra van szükségük, hogy jelezzék egymásnak, hogy történt valami.
Hogyan kezeli a HotKV
Minden WebSocket-szerver feliratkozik azokra a csatornákra, amelyek a felhasználóit érdeklik. Amikor bármi történik, egyetlen PUBLISH eléri az összes feliratkozott szervert, amelyek továbbítják a felhasználóiknak. A shardolt csatornák a forgalmat a csatornát birtokló csomóponton tartják egy klaszterben, a szobák melletti stream pedig megőrzi az előzményeket a később csatlakozóknak.
Lépésről lépésre
Mi történik, parancsról parancsra
- 01
A szerverek feliratkoznak
Minden WebSocket-szerver feliratkozik azokra a szobákra, amelyekben a csatlakoztatott felhasználói vannak.
SUBSCRIBE room:42 - 02
Alice üzenetet küld
A szervere egyszer tesz közzé. A válasz azt mondja meg, hány előfizető kapta meg.
PUBLISH room:42 "{\"from\":\"alice\",\"text\":\"Deploy is green\"}" - 03
Az előzmények megőrzése
Az üzenet a szoba streamjéhez is hozzáfűződik, az utolsó 1000 üzenetre korlátozva.
XADD room:42:history MAXLEN ~ 1000 * from alice text "Deploy is green" - 04
Bob később újracsatlakozik
Elolvassa az utolsó 50 üzenetet a streamből, majd élőben csatlakozik a csatornához.
XREVRANGE room:42:history + - COUNT 50 - 05
Shardolt csatornák klaszterben
Klaszter módban az SPUBLISH az üzenetet a csatornát birtokló csomóponton tartja.
SPUBLISH room:{42}:typing "alice"
Hol használható
Valós helyzetek
Élő értesítések
A rendelésfrissítések, említések és riasztások a böngészőbe kerülnek abban a pillanatban, amikor megtörténnek.
Együttműködő alkalmazások
A kurzorpozíciókat és a gépelésjelzőket rövid életű csatornákon sugározzák.
Beépítve
Amit kap
Szétszórás
Egy közzététel minden előfizetőt elér.
PUBLISHSUBSCRIBEMintaelőfizetések
Iratkozzon fel a room:* mintára, hogy minden szobát megkapjon.
PSUBSCRIBEShardolt pub/sub
A csatornák klaszterben azon a csomóponton maradnak, amely birtokolja őket.
SPUBLISHSSUBSCRIBEElőzmények
Párosítson egy csatornát egy korlátozott streammel a lemaradt üzenetekhez.
XADDXREVRANGEGyakori kérdések
Tárolódnak a pub/sub-üzenetek?
Nem. A pub/sub azoknak kézbesít, akik abban a pillanatban fel vannak iratkozva. Használjon a csatorna mellett streamet, ha a felhasználóknak előzményekre van szükségük.
Működik klaszterben?
Igen. Használjon shardolt pub/sub-ot (SPUBLISH, SSUBSCRIBE), hogy az egyes csatornák forgalma azon a csomóponton maradjon, amely birtokolja.
Kaphatok értesítést, ha a kulcsok megváltoznak?
Igen. A kulcstér-értesítések eseményeket tesznek közzé a kulcsváltozásokról. Lásd a dokumentációt a kulcstér-értesítésekről.
Kapcsolódó felhasználási esetek
Próbálja ki a saját munkaterhelésén
A HotKV a Redis protokollt beszéli, így egy meglévő klienst ráirányíthat, és lefuttathatja ugyanezeket a parancsokat.