バックグラウンドジョブ（HTTPレスポンスをブロックすべきでない処理）の場合、NestJSは@nestjs/bullmqを通じてBullMQ（Redisベースのキュー）と統合されています。ジョブをキューに追加し、別のワーカーで非同期に処理します — リクエストを高速に保ちながら、重い処理や遅延処理を確実に処理できます。
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
@Module({
imports: [
BullModule.forRoot({ connection: { host: "localhost", port: 6379 } }), // Redis
BullModule.registerQueue({ name: "email" }), // a named queue
],
})
export class AppModule {}
@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
});
}
}
プロデューサーはジョブを追加し（リトライ、バックオフ、遅延などのオプション付き）、すぐに戻る — ユーザーはメール送信を待つ必要がありません。
@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ワーカーはキューからジョブを消費し、実際の処理を非同期に実行します — リクエスト/レスポンスサイクルから独立して（別プロセスで実行することも可能）。
✓ 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システムにおける一般的で重要なパターンであり、シンプルなリクエスト/レスポンス処理を超えた、応答性に優れた信頼性の高いバックエンド構築の成熟した理解を反映しています。