الخدمات المصغّرة والطوابير

طريقان إلى نفس الفكرة

قبل أن تبدأ

الفكرة الجوهرية

1monolith معياري أولًا

تطبيق واحد يُنشر مرة، لكن مقسّم داخليًا لوحدات بحدود واضحة (orders، payments، notifications) لا تلمس جداول بعضها مباشرة. حين تحتاج فعلًا لفصل وحدة، حدودها جاهزة.

2طابور مع إعادة محاولة

المستهلك يعالج، وعند الفشل تُعاد الرسالة للطابور حتى حد، ثم تذهب لطابور الرسائل الميتة:

from collections import deque

queue = deque([{"id": "m1", "order": 1}, {"id": "m2", "order": 2}, {"id": "m3", "order": 3}])
dead_letters, attempts = [], {}
flaky = {"m2": 1}            # m2 fails once, then works
broken = {"m3"}              # m3 always fails
MAX_ATTEMPTS = 3

def handle(msg):
    if msg["id"] in broken:
        raise RuntimeError("bad payload")
    if flaky.get(msg["id"], 0) > 0:
        flaky[msg["id"]] -= 1
        raise TimeoutError("email service slow")
    print("sent receipt for order", msg["order"])

while queue:
    msg = queue.popleft()
    attempts[msg["id"]] = attempts.get(msg["id"], 0) + 1
    try:
        handle(msg)
    except Exception as e:
        if attempts[msg["id"]] >= MAX_ATTEMPTS:
            dead_letters.append((msg["id"], str(e)))
        else:
            queue.append(msg)

print("dead letters:", dead_letters)

3idempotency: نفس الرسالة مرتين

الطابور يضمن «مرة على الأقل»: لو انقطع المستهلك بعد المعالجة وقبل التأكيد، تصل الرسالة مرة أخرى. لو كانت «اخصم 50 ريالًا» سيُخصم مرتين. الحل: سجّل معرّف كل رسالة عولجت وتجاهل المكرر:

balance = {"sara": 100}
processed = set()

def charge(msg):
    if msg["id"] in processed:
        print("duplicate", msg["id"], "skipped")
        return
    balance[msg["user"]] -= msg["amount"]
    processed.add(msg["id"])

payment = {"id": "pay-7f3", "user": "sara", "amount": 50}
charge(payment)
charge(payment)          # redelivered after a crash
print("balance:", balance["sara"])

مثال محلول

المسألة: إتمام الطلب يستدعي خدمة البريد مباشرة، والبريد بطيء أحيانًا 8 ثوانٍ، فيرى المستخدم دائرة تحميل وأحيانًا خطأ رغم نجاح الدفع. الحل: الطلب يُحفظ وينشر حدث order.paid في الطابور ويرد فورًا. مستهلك البريد يعالج الحدث بإعادة محاولة، وبمعرّف الطلب كمفتاح idempotency حتى لا يصل بريدان. النتيجة: إتمام الطلب في 200ms، والبريد يصل ولو تأخر.

خرافة مقابل حقيقة

أين تقابله في العمل

اختبر فهمك

بطاقات مراجعة سريعة

تحقق من فهمك