البيانات الأساسيةالوقت الفعلي

دردشة وإشعارات في الوقت الفعلي

وزّع الرسائل على كل عميل متصل في الوقت الفعلي، مع قنوات مجزأة للعناقيد وتدفقات للسجل.

نشر واحد، كل المشتركين: 1
قنوات للعناقيد: مجزأة
مع التدفقات: +السجل

الخطوة 1 من 5

الخوادم تشترك

يشترك كل خادم WebSocket في الغرف التي يوجد فيها مستخدموه المتصلون.

جلسة توضيحيةplaying

# الخوادم تشترك

hotkv> SUBSCRIBE room:42

1) "subscribe"

2) "room:42"

3) (integer) 1

عرض متحرك بأوامر HotKV حقيقية وردود توضيحية. انقر على أي خطوة للانتقال إليها. تبقى الأوامر والردود بالإنجليزية، تمامًا كما تكتبها وتراها في HotKV.

المشكلة

يجب أن تصل غرفة الدردشة أو خلاصة الإشعارات المباشرة إلى كل مستخدم متصل في الوقت نفسه، عبر خوادم WebSocket كثيرة. واستطلاع قاعدة البيانات أبطأ وأكثر تكلفة من اللازم، وتحتاج الخوادم إلى طريقة مشتركة يخبر بها بعضها بعضًا بأن شيئًا ما حدث.

كيف يتعامل HotKV معها

يشترك كل خادم WebSocket في القنوات التي تهم مستخدميه. وعندما يحدث أي شيء، يصل PUBLISH واحد إلى كل خادم مشترك، فيمرّره إلى مستخدميه. وتبقي القنوات المجزأة الحركة على العقدة التي تملك القناة في العنقود، ويحتفظ تدفق بجوار كل غرفة بالسجل للمستخدمين الذين ينضمون لاحقًا.

خطوة بخطوة

ما يحدث، أمرًا بأمر

01
الخوادم تشترك
يشترك كل خادم WebSocket في الغرف التي يوجد فيها مستخدموه المتصلون.
SUBSCRIBE room:42
02
Alice ترسل رسالة
ينشر خادمها مرة واحدة. والرد هو عدد المشتركين الذين تلقوها.
PUBLISH room:42 "{\"from\":\"alice\",\"text\":\"Deploy is green\"}"
03
احتفظ بالسجل
تُلحق الرسالة أيضًا بتدفق الغرفة، بحد أقصى آخر 1000 رسالة.
XADD room:42:history MAXLEN ~ 1000 * from alice text "Deploy is green"
04
Bob يعيد الاتصال لاحقًا
يقرأ آخر 50 رسالة من التدفق، ثم ينتقل إلى البث المباشر على القناة.
XREVRANGE room:42:history + - COUNT 50
05
قنوات مجزأة في عنقود
في وضع العنقود، يبقي SPUBLISH الرسالة على العقدة التي تملك القناة.
SPUBLISH room:{42}:typing "alice"