Çekirdek veriGerçek zamanlı

Gerçek Zamanlı Sohbet ve Bildirimler

İletileri bağlı her istemciye gerçek zamanlı dağıtın; kümeler için parçalanmış kanallar ve geçmiş için akışlarla.

yayım, her abone: 1
küme için kanallar: Parçalanmış
akışlarla: +geçmiş

Adım 1 / 5

Sunucular abone olur

Her WebSocket sunucusu, bağlı kullanıcılarının bulunduğu odalara abone olur.

Örnek oturumplaying

# Sunucular abone olur

hotkv> SUBSCRIBE room:42

1) "subscribe"

2) "room:42"

3) (integer) 1

Gerçek HotKV komutları ve örnek yanıtlarla animasyonlu bir anlatım. Herhangi bir adıma atlamak için üzerine tıklayın. Komutlar ve yanıtlar, HotKV'de yazdığınız ve gördüğünüz haliyle İngilizce kalır.

Sorun

Bir sohbet odası veya canlı bildirim akışı, birçok WebSocket sunucusu boyunca, bağlı her kullanıcıya aynı anda ulaşmak zorundadır. Bir veritabanını yoklamak çok yavaş ve çok pahalıdır; sunucuların da bir şeyin olduğunu birbirine söylemek için ortak bir yola ihtiyacı vardır.

HotKV bunu nasıl ele alır

Her WebSocket sunucusu, kullanıcılarının ilgilendiği kanallara abone olur. Bir şey olduğunda tek bir PUBLISH, abone olan her sunucuya ulaşır ve onlar da kullanıcılarına iletir. Parçalanmış kanallar, bir kümede trafiği kanalın sahibi olan düğümde tutar; her odanın yanındaki bir akış da sonradan katılan kullanıcılar için geçmişi saklar.

Adım adım

Ne olur, komut komut

01
Sunucular abone olur
Her WebSocket sunucusu, bağlı kullanıcılarının bulunduğu odalara abone olur.
SUBSCRIBE room:42
02
Alice bir ileti gönderir
Sunucusu bir kez yayımlar. Yanıt, kaç abonenin aldığıdır.
PUBLISH room:42 "{\"from\":\"alice\",\"text\":\"Deploy is green\"}"
03
Geçmişi tutun
İleti ayrıca odanın akışına eklenir; son 1000 iletiyle sınırlıdır.
XADD room:42:history MAXLEN ~ 1000 * from alice text "Deploy is green"
04
Bob daha sonra yeniden bağlanır
Akıştan son 50 iletiyi okur, ardından kanalda canlıya geçer.
XREVRANGE room:42:history + - COUNT 50
05
Kümede parçalanmış kanallar
Küme kipinde SPUBLISH iletiyi kanalın sahibi olan düğümde tutar.
SPUBLISH room:{42}:typing "alice"