الضغط العكسي Backpressure: كيف تمنع تدفق الأحداث من إغراق المستهلك؟

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

قِس معدل الإنتاج والاستهلاك أولًا

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

حدود واضحة بدل تراكم غير محدود

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

اعتمد التحكم في التدفق

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

افصل بطء الاعتماد الخارجي عن بقية العمل

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

اختبر تحت حمل متدرج ثم انهيار جزئي

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

مؤشرات التشغيل وخطة القرار

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