كيف تتعامل مع المهام الخلفية والرتل (Queues)؟

Question

Accepted Answer

للمهام الخلفية **(Background jobs)** (العمل الذي لا يجب أن يحجب استجابة HTTP)، يتكامل NestJS مع **BullMQ** (رتل مدعوم بـ Redis) عبر `@nestjs/bullmq`. تضيف مهام إلى رتل ومعالجتها بشكل غير متزامن في عمال منفصلين — مما يحافظ على سرعة الطلبات ويتعامل مع العمل الثقيل أو المؤجل بشكل موثوق.

## المشكلة التي تحلها الرتل

```text
Some work is too slow or shouldn't block the request:
  ✗ sending emails, processing images/video, generating reports, calling slow APIs
  → doing it inline makes the user wait and risks timeouts/failures
  ✓ QUEUE the work → respond immediately → a worker processes it in the background
```

## إعداد الرتل

```ts
@Module({
  imports: [
    BullModule.forRoot({ connection: { host: "localhost", port: 6379 } }),  // Redis
    BullModule.registerQueue({ name: "email" }),                            // a named queue
  ],
})
export class AppModule {}
```

## إضافة مهام إلى الرتل (المنتج)

```ts
@Injectable()
export class NotificationService {
  constructor(@InjectQueue("email") private emailQueue: Queue) {}

async register(user: User) {
    await this.saveUser(user);
    // queue the email INSTEAD of sending it inline → respond to the user immediately
    await this.emailQueue.add("welcome", { userId: user.id }, {
      attempts: 3,                          // retry up to 3 times on failure
      backoff: { type: "exponential", delay: 5000 },
      delay: 60000,                          // optionally delay the job
    });
  }
}
```

المنتج يضيف مهمة (مع خيارات مثل المحاولات الجديدة، التراجع، التأخير) ويعود فوراً — المستخدم لا ينتظر لإرسال البريد الإلكتروني.

## معالجة المهام (العامل/المستهلك)

```ts
@Processor("email")
export class EmailProcessor extends WorkerHost {
  async process(job: Job) {
    switch (job.name) {
      case "welcome":
        await this.sendWelcomeEmail(job.data.userId);   // the actual work, in the background
        break;
    }
  }
}
```

عامل `@Processor` يستهلك المهام من الرتل ويقوم بالعمل الفعلي بشكل غير متزامن — منفصل عن دورة الطلب/الاستجابة (ويمكن حتى أن يعمل في عملية منفصلة).

## ما توفره الرتل

```text
✓ Async processing — offload slow work, respond to users instantly
✓ Retries & backoff — failed jobs retry automatically (reliability)
✓ Delayed/scheduled jobs — run work later or on a schedule (repeatable jobs)
✓ Rate limiting & concurrency control — bound how fast/many jobs run
✓ Persistence (via Redis) — jobs survive restarts; not lost if the app crashes
✓ Decoupling — producers and workers scale independently
```

## لماذا يهم

معالجة المهام الخلفية مع الرتل أساسية لبناء خوادم خلفية قوية وسريعة الاستجابة وقابلة للتوسع — وفهم تكامل NestJS مع BullMQ معرفة مهمة على مستوى أعلى.

القيمة الأساسية هي نقل العمل الذي لا يجب أن يحجب استجابة HTTP: إرسال رسائل البريد الإلكتروني، معالجة الصور/الفيديو، إنشاء التقارير، مزامنة البيانات، أو استدعاء الخدمات الخارجية البطيئة.

القيام بمثل هذا العمل بشكل مباشر يجعل المستخدمين ينتظرون، ويخاطر بانقطاع الطلب، ويفقد العمل في حالة الفشل — بينما **وضعه في الرتل** يتيح لك الرد فوراً بينما **عامل** خلفي يعالجه بشكل موثوق.

بما يتجاوز نقل العمل غير المتزامن، توفر الرتل ميزات إنتاج حرجة: **إعادة المحاولة التلقائية مع التراجع** (المرونة ضد الأعطال العابرة)، **المهام المؤجلة والمجدولة**، **التحكم في التزامن/تحديد المعدل**، و**الاستمرارية** (المهام المدعومة بـ Redis تبقى بعد الانهيارات/إعادة التشغيل، لذلك لا يُفقد العمل).

كما أنها **فصل** المنتجين عن المستهلكين، مما يسمح بالتوسع المستقل.

معرفة كيفية إعداد الرتل، إضافة مهام مع الخيارات المناسبة (المحاولات الجديدة، التأخيرات)، ومعالجتها في العمال قيّم لهندسة التطبيقات الحقيقية التي تتعامل مع العمل الثقيل أو المؤجل بأناقة.

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