آپ background jobs اور queues کو کیسے سنبھالتے ہیں؟

Question

Accepted Answer

**background jobs** (یہ کام جو HTTP response کو block نہیں کرنا چاہیے) کے لیے، NestJS **BullMQ** (ایک Redis-backed queue) کے ساتھ `@nestjs/bullmq` کے ذریعے integrate کرتا ہے۔ آپ ایک queue میں jobs شامل کرتے ہیں اور انہیں الگ الگ workers میں asynchronously process کرتے ہیں — requests کو تیز رکھتے ہوئے اور بھاری یا deferred work کو قابل اعتماد انداز میں سنبھالتے ہوئے۔

## مسئلہ جو queues حل کرتے ہیں

```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
```

## Queue سیٹ اپ کرنا

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

## Queue میں jobs شامل کرنا (producer)

```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
    });
  }
}
```

Producer ایک job شامل کرتا ہے (retries, backoff, delay جیسی options کے ساتھ) اور فوری طور پر واپس آتا ہے — صارف email بھیجنے کا انتظار نہیں کرتا۔

## Jobs کو process کرنا (worker/consumer)

```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` worker queue سے jobs consume کرتا ہے اور actual work asynchronously کرتا ہے — request/response cycle سے الگ (اور یہاں تک کہ ایک الگ process میں چل سکتا ہے)۔

## Queues کیا فراہم کرتے ہیں

```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
```

## یہ کیوں ضروری ہے

Background job processing queues کے ساتھ مضبوط، responsive، اور scalable back-ends بنانے کے لیے ضروری ہے — اور NestJS کی BullMQ integration کو سمجھنا اہم senior-level knowledge ہے۔

بنیادی قیمت یہ ہے کہ وہ کام جو HTTP response کو block نہیں کرنا چاہیے اسے offload کرنا: emails بھیجنا، images/video process کرنا، reports بنانا، data sync کرنا، یا سست external services کو call کرنا۔

ایسے کام کو inline کرنے سے صارفین کا انتظار بڑھتا ہے، request timeouts کا خطرہ ہوتا ہے، اور ناکامی میں کام ضائع ہو جاتا ہے — جبکہ **queuing** سے آپ فوری جواب دے سکتے ہیں جبکہ background **worker** اسے قابل اعتماد انداز میں process کرتا ہے۔

Async offloading سے ہٹ کر، queues اہم production features فراہم کرتے ہیں: **automatic retries with backoff** (عارضی failures کے خلاف لچکداری)، **delayed اور scheduled jobs**، **concurrency/rate-limiting control**، اور **persistence** (Redis-backed jobs crashes/restarts میں محفوظ رہتے ہیں، تو کام ضائع نہیں ہوتا)۔

یہ **decouple** بھی کرتے ہیں producers اور consumers کو، جو independent scaling کی اجازت دیتا ہے۔

یہ جاننا کہ queues سیٹ اپ کریں، appropriate options (retries, delays) کے ساتھ jobs شامل کریں، اور انہیں workers میں process کریں، حقیقی applications بنانے کے لیے قیمتی ہے جو بھاری یا deferred work کو gracefully سنبھالتے ہیں۔

یہ production NestJS systems میں ایک عام اور اہم pattern ہے اور responsive، reliable back-ends بنانے کی پختہ سمجھ کو ظاہر کرتا ہے جو سادہ request-response handling سے ہٹ کر جاتے ہیں۔