ਤੁਸੀਂ ਬੈਕਗ੍ਰਾਉਂਡ ਜੌਬਸ ਅਤੇ ਕਿਊ ਨੂੰ ਕਿਵੇਂ ਹੈਂਡਲ ਕਰਦੇ ਹੋ?

Question

Accepted Answer

**ਬੈਕਗ੍ਰਾਉਂਡ ਜੌਬਸ** (ਅਜਿਹਾ ਕਾਰਜ ਜੋ 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 ਸਿਸਟਮਾਂ ਵਿੱਚ ਇੱਕ ਆਮ, ਮਹੱਤਵਪੂਰਨ ਪੈਟਰਨ ਹੈ ਅਤੇ ਸਧਾਰਨ ਬੇਨਤੀ-ਜਵਾਬ ਹੈਂਡਲਿੰਗ ਤੋਂ ਪਰੇ ਜਾਣ ਵਾਲੇ ਪ୍ਰਤੀਕਿਰਿਆਸ਼ੀਲ, ਭਰੋਸੇਮੰਦ ਬੈਕ-ਐਂਡ ਬਣਾਉਣ ਦੀ ਪਕਵਾਨ ਸਮਝ ਨੂੰ ਪ੍ਰਦਰਸ਼ਿਤ ਕਰਦਾ ਹੈ۔