ברוקר הודעות וניתוב אירועים

(סעיף: טכנולוגיה ותשתיות)

תקציר

Message Broker היא שכבה בסיסית של אינטגרציה ואוטובוס אירועים ב-iGaming. הוא מיישם משלוח, חציצה וניתוב של מסרים בין מיקרו-רווחים של תעריפים, תשלומים, אנטי-הונאה, KYC, CRM ואנליטיקה. החלפות מתוכננות היטב (החלפות), תורים, מפתחות ניתוב וכללי העברה מחדש מספקים איחור נמוך, התנגדות להתפרצויות תנועה ו-SLOs צפויים.

תפקיד ברוקר בפלטפורמת iGaming

שירותי פירוק: פרסום אירועים במקום שיחות סינכרוניות קשות.
ניתוב גמיש: אירוע אחד = צרכנים רבים (CRM, סיכון, אנליטיקה).
ניהול טעינה: תורים, קדם-טיפול/קיו-אס, תרמילאי גב.
אמינות והחלמה: אישורים, מגשים מחדש, DLQ, שכפול.
ביקורת וציות: איתור אירועים, מיסוך מח "ש, מדיניות שמירה.

הודעות מודלים

Point-to-Point (תור משימה): צרכן אחד מעבד משימה (KYC, דואר אלקטרוני, PSP webhook).
Pub/Sub (אירועי דומיין): פרסום לבורר עם אוהד-אאוט למספר תורים.
RPC באמצעות ברוקר: בקשה/תגובה עם קורלציה (לעיתים נדירות במסלולים חמים, אך שימושיים לאינטגרציות).

ניתוב מושגים (קלאסיקות AMQP)

1. התאמה ישירה של 'routing _ key'.

2. נושא - תבניות 'a. ב. C "(מילה אחת) ו-" # "(0 + מילים). בחירה אוניברסלית.

3. שידור לכל התורים הקשורים.

4. ניתוב כותרת (מפתח/ערך), שימושי למדיניות מורכבת.

• "תשלומים. psp. פסים. הצליח, 'תשלומים. psp נכשל ”,” הימורים. בשידור חי. # ", 'rg. הגבלה. פריצה ".
• החלפות לפי התחום: "תשלומים. נושא, 'הימורים. נושא ”,” סיכון. נושא "; אישית עבור אירועי מערכת 'פלטפורמה'. ביקורת חשבונות.

תורים ומדיניות

תור עבודה: נצרך על ידי מפעילי עסקים.
Retry תורים: עם TTL (עיכוב) ו-DLX לגיבויים מעריכיים (לדוגמה, '5s _ 1 m = 5 m = 1').
DLQ (תור דד-אות): התור האחרון של ”מזבלה” לאחר תשישות הרטראס.
סדרי עדיפויות: למשימות דחופות (מסקנות> אותיות).
עצלן/קוראום: עצלן - מציל את הרמב "ם עם רישומים גדולים; HA מבוסס מניין.

• "עבודה. Q 'ub-x-מת-אותיות החלפה = retry. &exposite
• 'לנסות מחדש. 1 מ '. Q 'ub' x-הודעה-tl = 60000, 'x-מת-אותיות-החלפת = עבודה. &exposite
• 'Diq. Q 'ouse ניטור ושיקום ידני

אחריות משלוח ונהלים

לפחות פעם אחת - ברירת מחדל: שכפולים אפשריים = = אידמפוטנטיות היא חובה.
עיכוב מינימלי, אבל סיכון לאובדן (לאותות ”לא קריטיים”).
בדיוק-פעם אחת - לעתים נדירות מעשי ברוקרים; השיג קשה יותר ויקר יותר. לכסף: לפחות פעם אחת + אידמפוטנטיות קשה.

• בתור אחד ועם צרכן אחד, הסדר נשמר; עם מקביליות + חוזר, הסדר עלול להיות מופרע.
• עבור ישויות עם דרישת הזמנה, סריג את הזרם (צרכן יחיד פעיל לכל מקש) או העברתו לאוטובוסים ”לוג” (הזרמה).

אידמפוטנטיות והוצאה לאור עסקית

Idempotency-Key בהודעה (ULID/UUID), אחסון dedup עם TTL או Upsert על ידי מפתח.
תבנית אאוטבוקס: כתיבת אירוע לשולחן 'out box 'בתוך עסקה עסקית, המחבר מפרסם לברוקר * לא כולל ”כניסה כפולה ”/הפסד.
Correlation metadata: ”message _ id',” trace _ id', ”causation _ id',” terant _ id'.

RPC באמצעות ברוקר (בעת הצורך)

הבקשה מתפרסמת עם "refly _ to" ו- "correlation _ id', התגובה נמצאת בתור המצוין.
שימוש מוגבל (ספקים חיצוניים, בדיקות סינכרוניות), זמן שליטה ונטיית צ "אט (אחרת - הידרדרות למונולית מבוזרת).
עבור שבילי משתמש חמים, מועדפים אירועים אסינכרוניים + תחזיות מצב.

חוזי נתונים וסכימות

פורמטים: Avro/Protobuf/JSON-Schema. עבור JSON, לתקן את ההתפשטות ונדרש שדות.
הפוליטיקה של האבולוציה: שינוי התאמה לאחור; שבירת שינויים ללא נדידה אסורה.
PII - tokenization/הצפנת שדות; תכלית וחיי מדף.

טיפול שגיאות, מגש מחדש, DLQ

סיווג: זמני (network/5xx) retray ac; File (אימות/תרמית) # DLQ.
גיבוי מעריכי + ג 'יטר, הגבלה מחדש, תוויות רעל גלולות.
משלוח דחוי: באמצעות TTL/החלפה מתעכבת.
הכלי ”לחזור לעבודה” מ- DLQ לאחר תיקון הסיבה.

תצפית ו SLO

מדדי יצרן: מהירות פרסום, שגיאות/אימות.
מדדי תור: אורך, שיעור צריכה, אחוז מגשים חוזרים, זמן תור p99.
צרכנים: פיגור, תפוקה, זמן עיבוד, נתח נאק.
SLO: p99 E2E latency of extence liversion lang X seconds; זמינות 99. 9%; DLQ-rate & Y%.
איתור: trace _ id'/span _ id, logs by "message _ id'.
התראות: DLQ/lags growth, quorum drop, NACK surve, restry states stating.

אבטחה וגישה

TLS/MTLS במעבר; הצפנה בדיסק כאשר תורים עיקשים מאוחסנים.
RBAC/ACL: לפרסם/לצרוך זכויות על ידי vhost/namespace/נושא.
סגמנט: תחומים רגישים (תשלומים/CCM) - החלפות/אשכולות נפרדים.
סודות בכספת/SOPS; ביקורת יומן של פרסומים/מנויים.
לוקליזציה של נתונים: אחסון ושמירה על ידי אזור (האיחוד האירופי, טורקיה, Latam).

זמינות גבוהה ו-DR

תורים/שכפול, מספר אי זוגי של צמתים, AZ אנטי-זיקה.
שכפול חוצה-אזורי (פדרציה/חפירה) עבור תחומים קריטיים.
החלפת תקנות (ספר ריצות), תרגילי DR תקופתיים (יום משחק).
טופולוגיות ורסיונינג כקוד (ICC) - מרבצים ניתנים לחזרה ומהירים.

ביצועים וכוונון

מפיק: המוציא לאור מאשר, שימוש חוזר בערוץ, פרסומים אסינכרוניים.
תורים: הקדמה לתקופה הממוצעת של המשימה; עצלן ליומני גב עמוקים; הפרדה בין תורים ”חמים” לצמתים.
רשת/מערכת ההפעלה: 10/25G, תיאורי קבצים, כוונון TCP. JVM/GC - לפרופיל טעינה.
בדיקות לעומס התפרצויות (גפרורים, טורנירים, תשלומי שיא).

דפוסי ניתוב טיפוסיים עבור iGaming

1. אירועים בתשלום (נושא):

החלפה: "תשלומים. opticfost

• "תשלומים. psp. פסים. מצליח &fost
• "תשלומים. psp.. כשל &pos
• "עם משיכה. מבוקש. #`

• 'Ledger. סופרת. q '(לאגד:' תשלומים. #`)
• 'crm. מעורר. q '(לאגד:' תשלומים... הצליח ')
• "להסתכן. ביקורות. q '(קשירה:' נסיגה. #`)

2. ניקוד אנטי-פראוד (ישירות + retry):

"להסתכן. עבודה. קיו '←' סיכון. ישיר ('ניתוב _ מפתח = סיכון. לבדוק ")

"להסתכן. לנסות מחדש. 1 מ '. Q '(TL 60 = DLX חזרה ל' risk. ישיר ')

"להסתכן. Diq. קיו 'עבור קטלני.

3. הודעות (fanout + עדיפות):

'notify. Fanout' Il' דואר אלקטרוני. q (פריו) ", sms. Q ',' לדחוף. &qapos

סדרי עדיפויות: מסקנות/מגבלות מעל דואר שיווקי.

4. ביקורת חשבונות ועקבות (כותרות):

Hader bindings 'l' derant: ”X”, ”critical”: ”true” = = ”true” = = ”true” = = = ”true” = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = =.

דוגמה לסכימת מסרים מינימלית (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_..."
}
}

אינטגרציה עם לולאות אחרות

הזרמה/אנליטיקה: ניתן לשכפל נושאים חשובים באוטובוס הרישום (קפקא/רדפנדה) לצורך חזרה ועיבוד מחדש.
פיכסטור: אירועים = מאפיינים מקוונים (Redis) ומסיבות לא מקוונות (Parquet/OLAP).
תזמור סאגה: פקודות ישירות/נושא, אירועים - פאב/משנה; פיצוי צעדים - כהודעות נפרדות.

רשימת יישומים

1. הגדר החלפת דומיין וניתוב תקן מפתח.
2. תכנן עבודה/חזרה/DLQ עבור כל זרימה קריטית.
3. אפשר למוציא לאור לאשר, ”טרום טיפול”, סדר עדיפויות ועיכוב במקום הדרוש.
4. הכנס מספר מפתח אידמפוטנטי, תיבת יוצא, ותעודות מתאם.
5. תאשר תוכניות מידע וכללי אבולוציה.
6. הגדרות TLS/RBAC, קטעים לפי תחום/דייר.
7. הגדרת SLO והתראות (lag, DLQ-rate, p99).
8. הכן תוכנית ד "ר וטופולוגיות איי-סי אוטומטיות.
9. לבצע בדיקות עומס וכאוס.
10. לתעד את רישומי התקרית ולהזריק מחדש מ-DLQ.

אנטי דפוסים

מחליף ”ענק” אחד ללא משמעת מרכזית; אקראי ”כמו שאתה צריך” קשירות.
היעדר של Retry/DLQ וערבוב של שגיאות זמן/קטלניות.
RPC סינכרוני מעל ברוקר על נתיבים חמים משתמש.
חוסר אידמפוטנטיות ואובדן כסף.
אחסון PII ברור, לשתף לפרסם/לצרוך לכולם.

תקציר

ברוקר מסרים מעוצב היטב הוא עורק אירועים חזק שבו ניתוב ניתן לחיזוי וסובלנות פגמים מובנית ברמת הטופולוגיה. השתמש בסוגי החלפת נושאים, סטנדרט מפתח יחיד, עבודה/ריטרי/DLQ עבור כל זרם קריטי, אידמפוטנטיות ותיבת חוץ, SLOs קפדנית ויכולת תצפית. במקביל לתחזיות האוטובוס והמדינה, זה נותן לפלטפורמת ה-iGaming מהירות, שקיפות ושליטה על המורכבות ככל שהעומס גדל.