كيف تنسّق مهمة cron بين عدة عقد NestJS؟

Question

IT Interview Practice · Accepted Answer

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

خذ مهمة يومية لإنشاء الفواتير منشورة على ثلاث عقد NestJS. نريد تنفيذ العمل المجدول دون إنشاء فاتورة أخرى عند إعادة تشغيل العامل.

## 1. افهم لماذا تبدأ جميع العقد المهمة

تسجل كل نسخة من التطبيق استدعاء cron الخاص بها. وعند الموعد، يمكن لكل منها البدء بصورة مستقلة:

```text
00:00 -> Node A -> invoice task
      -> Node B -> invoice task
      -> Node C -> invoice task
```

توجد علامة isRunning المحلية داخل عملية واحدة فقط. يستطيع waitForCompletion في NestJS منع تداخل الاستدعاءات على تلك النسخة، لكنه لا ينسق العقد الأخرى. إضافة العلامة نفسها إلى العقد الثلاث تترك ثلاثة قرارات منفصلة. [الجدولة في NestJS](https://docs.nestjs.com/techniques/task-scheduling).

لذلك نحتاج مكانًا مشتركًا لتحديد العمل الموجود ومن يحق له معالجته.

## 2. اختر نموذج التنسيق

| الحالة | الخيار الذي يستحق التقييم | المسؤولية المتبقية |
| --- | --- | --- |
| توفر المنصة مهام مجدولة أصلًا | شغّل الجدولة خارج نسخ الويب | اضبط التداخل والاستعادة والتعامل مع المواعيد الفائتة. |
| الفريق يشغّل BullMQ بالفعل | Job Scheduler مشترك وطابور مخصص | اضبط التزامن المشترك وإعادة المحاولة الآمنة. |
| يجب إبقاء المهمة الحالية على عقد التطبيق | قفل مشترك أو عقد إيجار | عالج الملكية والانتهاء والعامل القديم بشكل صحيح. |

في مثال الفواتير، إذا كان Redis وBullMQ موجودين، فمجدول مشترك بمعرّف ثابت خيار عملي. افصل الجدول الزمني عن العمال حتى لا تؤدي إضافة عقد ويب إلى إنشاء جداول مستقلة.

في إصدار BullMQ يدعم ذلك، اضبط التزامن العام للطابور المخصص على واحد. يحد ذلك الوظائف النشطة عبر العمال، بينما ضبط التزامن المحلي على واحد لكل عامل يسمح لعدة عمال بتشغيل وظائف مختلفة. [التزامن العام](https://docs.bullmq.io/guide/queues/global-concurrency).

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

## 3. احمِ الفاتورة وليس الوظيفة فقط

لنفترض أن عاملًا أنشأ فاتورة وتعطل قبل تسجيل اكتمال الوظيفة. قد تعيد الاستعادة تشغيل الوظيفة رغم وجود الفاتورة بالفعل.

```text
[Create invoice] -> [Crash before completion]
                              |
                            [Retry]
                              |
                  [Same business key: reuse result]
```

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

مع مزود خارجي، استخدم مفتاح منع التكرار الذي يوفره إن كان مدعومًا، وسوِّ النتائج غير المؤكدة. معرّف وظيفة الطابور أو سجلها المحتفظ به وحده ليس ضمانًا دائمًا لعدم تكرار إجراء تجاري. [الوظائف الآمنة عند التكرار](https://docs.bullmq.io/patterns/idempotent-jobs).

## 4. اعرف ما الذي يضمنه القفل وما لا يضمنه

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

يخلق الانتهاء حالة أخرى: يستأنف عامل متوقف بعد انتهاء إيجاره بينما يعمل عامل جديد بالفعل. قد تحتاج الكتابات الحساسة إلى fencing tokens، وهي أرقام ملكية متزايدة تتحقق منها الجهة المستقبلة لرفض العمال القدامى. مجرد تعيين مهلة طويلة لا يزيل هذا الخطر.

إذا تعذر التنسيق، قرر هل تنتظر المهمة بدل التنفيذ دون ملكية. غالبًا ما يكون ذلك الخيار الأكثر أمانًا للعمل ذي العواقب المهمة.

## 5. تحقق من حالات الفشل

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

**تذكر:** نسّق الجدولة ← حدّ التنفيذ المشترك ← اجعل إجراء العمل آمنًا عند الإعادة ← اختبر الاستعادة. «وظيفة نشطة واحدة» وحدها لا تثبت حدوث أثر تجاري واحد بالضبط.

الحالة	الخيار الذي يستحق التقييم	المسؤولية المتبقية
توفر المنصة مهام مجدولة أصلًا	شغّل الجدولة خارج نسخ الويب	اضبط التداخل والاستعادة والتعامل مع المواعيد الفائتة.
الفريق يشغّل BullMQ بالفعل	Job Scheduler مشترك وطابور مخصص	اضبط التزامن المشترك وإعادة المحاولة الآمنة.
يجب إبقاء المهمة الحالية على عقد التطبيق	قفل مشترك أو عقد إيجار	عالج الملكية والانتهاء والعامل القديم بشكل صحيح.

1. افهم لماذا تبدأ جميع العقد المهمة

2. اختر نموذج التنسيق

3. احمِ الفاتورة وليس الوظيفة فقط

4. اعرف ما الذي يضمنه القفل وما لا يضمنه

5. تحقق من حالات الفشل

أسئلة ذات صلة