الحفاظ على سجل أوامر حي عبر تحديثات WebSocket

الملخص

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

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

الأفكار الرئيسية

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

الوسوم

من مجموعة مقررات خاصة؛ لم يُنشر المصدر الأصلي.