NestJS + Redis + BullMQ: تصميم Background Jobs موثوقة وقابلة لإعادة المحاولة

متى أستخدم Background Job؟

استخدم Job عندما تكون العملية مثل:

• إرسال بريد أو Push Notification.
• توليد تقرير أو PDF.
• معالجة صور أو ملفات.
• مزامنة بيانات مع نظام خارجي.
• تنفيذ مهمة مجدولة.

مسار التنفيذ

Producer واضح وصغير

@Injectable()
export class NotificationsProducer {
  constructor(
    @InjectQueue('notifications')
    private readonly queue: Queue,
  ) {}
 
  enqueueWelcome(userId: string) {
    return this.queue.add('welcome-email', { userId }, {
      jobId: 'welcome:' + userId,
      attempts: 4,
      backoff: { type: 'exponential', delay: 2_000 },
      removeOnComplete: 500,
    });
  }
}

Worker آمن عند التكرار

@Processor('notifications')
export class NotificationsProcessor extends WorkerHost {
  async process(job: Job<{ userId: string }>) {
    const key = 'welcome-email:' + job.data.userId;
 
    const alreadySent = await this.deliveryRepo.exists(key);
    if (alreadySent) return { skipped: true };
 
    await this.mailer.sendWelcome(job.data.userId);
    await this.deliveryRepo.markDelivered(key);
 
    return { delivered: true };
  }
}

Retry ليس حلًا لكل خطأ

مراقبة الطابور

• عدد Jobs المنتظرة
• عدد Failed jobs
• مدة التنفيذ p95
• Retry count
• Alert عندما يتجاوز Queue lag حدًا تشغيليًا

يمكن دمج هذا النمط مع بنية SaaS قابلة للتوسع بدل إبقاء العمليات الثقيلة داخل الـ API.