وسيط الرسائل وتوجيه الأحداث

(القسم: التكنولوجيا والهياكل الأساسية)

موجز موجز

Message Broker هي طبقة أساسية من عمليات التكامل وحافلة الأحداث في iGaming. ينفذ تسليم الرسائل وتخزينها وتوجيهها بين الخدمات الدقيقة للأسعار والمدفوعات ومكافحة الاحتيال و KYC و CRM والتحليلات. توفر التبادلات (التبادلات) المصممة جيدًا وقوائم الانتظار ومفاتيح التوجيه وقواعد إعادة التسليم زمن انتقال منخفض ومقاومة للانفجارات المرورية ومنظمات SLO يمكن التنبؤ بها.

دور الوسيط في منصة iGaming

خدمات الفصل: نشر الأحداث بدلاً من المكالمات المتزامنة الصعبة.
التوجيه المرن: حدث واحد → العديد من المستهلكين (إدارة علاقات العملاء والمخاطر والتحليلات).
إدارة الأحمال: قوائم الانتظار، presetch/QoS، backprescher.
الموثوقية والاسترداد: التأكيدات، إعادة التصوير، DLQ، التكرار.
مراجعة الحسابات والامتثال: تتبع الأحداث، وإخفاء مؤشر الاستثمار الدولي، وسياسة الاحتفاظ.

نماذج الرسائل

من نقطة إلى نقطة (قائمة انتظار المهام): يقوم أحد المستهلكين بمعالجة مهمة ما (KYC، البريد الإلكتروني، PSP webhook).
Pub/Sub (أحداث المجال): النشر إلى المبادل مع مروحة لعدة قوائم انتظار.
RPC عن طريق الوسيط: الطلب/الاستجابة مع الارتباط (نادرًا ما تكون على مسارات ساخنة، ولكنها مفيدة للتكامل).

مفاهيم التوجيه (كلاسيكيات AMQP)

1. مباشرة - مطابقة دقيقة لـ «التوجيه _ المفتاح».

2. الموضوع - القوالب 'أ. ب. c 'c "(كلمة واحدة) و' # '(0 + كلمات). اختيار عالمي.

3. fanout - بث إلى جميع قوائم الانتظار ذات الصلة.

4. الرؤوس - توجيه الرأس (المفتاح/القيمة)، مفيد للسياسات المعقدة.

• المدفوعات. psp. شريط. نجحت المدفوعات. psp.. فشل '،' الرهانات. حي. # '،' rg. حد. خرق '.
• المبادلون حسب المجال: المدفوعات. «،» الرهانات. '،' المخاطرة. الموضوع '؛ فردية - لأحداث نظام «النظام الأساسي». مراجعة الحسابات ".

قوائم الانتظار والسياسات

قائمة انتظار العمل: يستهلكها عمال الأعمال.
إعادة تجربة قوائم الانتظار: مع TTL (تأخير) و DLX للنسخ الاحتياطية الأسية (على سبيل المثال، 5s → 1 م → 5 م → 1 ساعة).
DLQ (قائمة انتظار الحروف الميتة): «التفريغ» الأخير بعد استنفاد عمليات العودة.
الأولويات: للمهام العاجلة (الاستنتاجات> الرسائل).
الكسل/النصاب: كسول - توفير ذاكرة الوصول العشوائي مع تراكم كبير ؛ النصاب القانوني - HA القائم على توافق الآراء.

• 'عمل. q '→' x-dead-letter-exchange = retry. ex '
• 'محاولة. 1 م. q '→' x-message-tl = 60000 ',' x-dead-letter-exchange = work. ex '
• 'dlq. → الرصد والإصلاح اليدوي

ضمانات وإجراءات التسليم

مرة واحدة على الأقل - الافتراضي: التكرارات ممكنة → الغموض إلزامي.
على الأكثر مرة واحدة - الحد الأدنى من التأخير، ولكن خطر الخسارة (للإشارات «غير الحرجة»).
مرة واحدة بالضبط - نادرًا ما تكون عملية في السماسرة ؛ أكثر صعوبة وأكثر تكلفة. من أجل المال: مرة واحدة على الأقل + الغباء الصعب.

• في طابور واحد ومع مستهلك واحد، يتم الحفاظ على الطلب ؛ مع التوازي + التراجع، قد يكون الترتيب مضطربًا.
• بالنسبة للكيانات التي تتطلب طلبًا، قم بتسلسل البث (مستهلك مفرد النشاط لكل مفتاح) أو نقله إلى حافلات «تسجيل» (بث).

الخصوصية ونشر المعاملات

Idempotency-Key in a message (ULID/UUID), dedup storage with TTL or upsert by key.
نمط Outbox: كتابة حدث إلى جدول «outbox» داخل معاملة تجارية، ينشر الموصل للوسيط → يستبعد «الإدخال المزدوج »/الخسارة.
البيانات الوصفية المتعلقة بالترابط: 'message _ id' و 'trace _ id' و 'causation _ id' و 'tenant _ id'.

RPC عبر الوسيط (عند الحاجة)

يتم نشر الطلب مع «الرد _ على» و «الارتباط _ id»، يكون الرد في قائمة الانتظار المحددة.
استخدام محدود (مقدمو الخدمات الخارجيون، الفحوصات المتزامنة)، مهلات التحكم واتجاه الدردشة (بخلاف ذلك - التحلل إلى كتلة متراصة موزعة).
بالنسبة لمسارات المستخدم الساخنة، يتم تفضيل الأحداث غير المتزامنة + توقعات الحالة.

عقود ومخططات البيانات

التنسيقات: Avro/Protobuf/JSON-Schema. بالنسبة لـ JSON، قم بإصلاح الإصدار والحقول المطلوبة.
سياسة التطور: التغيير المتوافق مع الخلف ؛ كسر التغييرات دون هجرات محظور.
PII - ترميز/تشفير الحقول ؛ والهدف وفترة الصلاحية.

مناولة الأخطاء، إعادة النظر، DLQ

التصنيف: إعادة → مؤقتة (الشبكة/5xx) ؛ (التحقق/المخطط) → DLQ.
تراجع أسي + نفث، حد إعادة تجربة، ملصقات حبوب منع الحمل السامة.
تأخر التسليم: عبر TTL/التبادل المتأخر.
أداة «إعادة العمل» من DLQ بعد إصلاح السبب.

قابلية الملاحظة و SLO

مقاييس المنتج: سرعة النشر، الأخطاء/التأكيدات.
مقاييس قائمة الانتظار: الطول، معدل الاستهلاك، النسبة المئوية لإعادة التصوير، وقت الانتظار p99.
المستهلكون: التأخير، الإنتاجية، وقت المعالجة، حصة NACK.
SLO: p99 E2E زمن وصول الحدث ≤ X ثانية ؛ ≥ 99. 9%; معدل DLQ ≤ Y٪.
التعقب: 'تعقب' من طرف إلى طرف/' امتداد - معرف '، سجلات بواسطة' معرف رسالة '.
التنبيهات: DLQ/نمو متأخر، انخفاض النصاب القانوني، زيادة NACK، مراحل إعادة التجربة ثابتة.

الأمن والوصول

TLS/MTLS أثناء العبور ؛ التشفير على القرص عند تخزين قوائم الانتظار المستمرة.
RBAC/ACL: نشر/استهلاك الحقوق حسب vhost/namespace/their.
التجزئة: المجالات الحساسة (المدفوعات/CCM) - مبادلات/مجموعات منفصلة.
الأسرار في Vault/SOPS ؛ سجل مراجعة حسابات المنشورات/الاشتراكات.
توطين البيانات: التخزين والاحتفاظ بها حسب المنطقة (الاتحاد الأوروبي، تركيا، LatAm).

توافر عالي و DR

قوائم انتظار النصاب/النسخ المتماثل، عدد فردي من العقد، مكافحة تقارب AZ.
التكرار عبر الأقاليم (الاتحاد/المجرفة) للمجالات الحرجة.
تبديل اللوائح (كتاب التشغيل)، تمارين DR الدورية (يوم اللعبة).
إصدار الطوبولوجيات كرمز (IaC) - رواسب قابلة للتكرار وريسينك سريع.

الأداء والضبط

المنتج: الناشر يؤكد، إعادة استخدام القناة، المنشورات غير المتزامنة.
قوائم الانتظار: التمهيد لمتوسط مدة المهمة ؛ كسول بسبب التراكم العميق ؛ فصل الطوابير «الساخنة» عن طريق العقد.
Network/OS: 10/25G, file descripts, TCP tuning. JVM/GC - لملف تعريف التحميل.
اختبارات الأحمال المتفجرة (المباريات، البطولات، مدفوعات الذروة).

أنماط التوجيه النموذجية للألعاب

1. أحداث الدفع (الموضوع):

الصرف: المدفوعات. '

• المدفوعات. psp. شريط. نجحت "
• المدفوعات. psp.. فشلت
• 'withdrawal. المطلوبة. #`

• ليدر. كاتب. q '(ملزم:' المدفوعات. #`)
• 'crm. المحفزات. q '(ملزم:' المدفوعات... نجح ')
• مخاطرة. . q '(ملزم:' الانسحاب. #`)

2. تسجيل Antifraud (direct + retry):

مخاطرة. العمل. q '←' خطر. مباشرة '(' التوجيه _ المفتاح = المخاطرة. شيك ')

مخاطرة. إعادة المحاولة. 1 م. q '(TTL 60s → DLX العودة إلى' المخاطرة. مباشرة ')

مخاطرة. dlq. q 'للقتل.

3. الإخطارات (fanout + الأولوية):

'notify. البريد الإلكتروني fanout '→'. q (prio) ',' sms. q '،' دفع. س "

الأولويات: الاستنتاجات/الحدود فوق البريد التسويقي.

4. مراجعة الحسابات والتعقب (الرؤوس):

ربط الرأس «{» مستأجر «:» X «،» حرج «:» صحيح «}» → قائمة انتظار مراجعة منفصلة.

مثال على الحد الأدنى من الرسائل (JSON)

json
{
"message_id": "01HX8H8Y6D6W0T1S2A3B4C5D6E",
"trace_id": "f4d2a1...e9",
"occurred_at": "2025-11-05T11:20:45. 321Z",
"tenant_id": "eu-1",
"schema_version": 3,
"event": "payments. psp. stripe. succeeded",
"payload": {
"payment_id": "pay_123",
"player_id": "p_987",
"amount": { "currency": "EUR", "value": 50. 00 },
"psp_tx": "tx_456",
"idempotency_key": "ulid_..."
}
}

التكامل مع الحلقات الأخرى

البث/التحليلات: يمكن تكرار الموضوعات المهمة في حافلة السجل (كافكا/ريدباندا) للتخفيف وإعادة المعالجة.
Fichestor: الأحداث → الميزات عبر الإنترنت (Redis) والحفلات غير المتصلة بالإنترنت (Parquet/OLAP).
تنسيق الملحمة: أوامر عبر مباشر/موضوع، أحداث - حانة/فرعية ؛ الخطوات التعويضية - كرسائل منفصلة.

قائمة التنفيذ المرجعية

1. تحديد مبادلات المجال ومعيار التوجيه الرئيسي.
2. تصميم عمل/إعادة/DLQ لكل تدفق حرج.
3. تمكين الناشر يؤكد، «بريتش»، الأولويات والتأخير عند الحاجة.
4. أدخل idempotency-key و outbox و correlation IDs.
5. الموافقة على مخططات البيانات وقواعد التطور.
6. اضبط TLS/RBAC، التجزئة حسب المجال/المستأجر.
7. حدد SLO والتنبيهات (lag، DLQ-rate، p99).
8. قم بإعداد خطة DR وطوبولوجيات IaC الآلية.
9. قم بإجراء اختبارات التحميل والفوضى.
10. وثق دفتر الحوادث وأعد حقنه من DLQ.

الأنماط المضادة

مبادل «عملاق» واحد ليس له أي نظام رئيسي ؛ ارتباطات عشوائية «كما عليك».
عدم وجود إعادة/DLQ وخلط الأخطاء الزمنية/المميتة.
RPC المتزامن فوق الوسيط على مسارات المستخدم الساخنة.
الافتقار إلى الخصوصية والخروج → يتضاعف/فقدان المال.
تخزين PII واضحًا، شارك بالنشر/الاستهلاك للجميع.

موجز

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