你如何处理后台任务和队列？

Question

你如何处理后台任务和队列？

Accepted Answer

对于**后台任务**（不应阻塞 HTTP 响应的工作），NestJS 通过 `@nestjs/bullmq` 与**BullMQ**（Redis 支持的队列）集成。你将任务添加到队列中，并在单独的 worker 中异步处理它们——保持请求快速响应，并可靠地处理繁重或延迟的工作。

## 队列解决的问题

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

生产者添加任务（带有重试、退避、延迟等选项），并立即返回——用户无需等待电子邮件发送。

## 处理任务（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 从队列消费任务并异步执行实际工作——与请求/响应周期分离（甚至可以在单独的进程中运行）。

## 队列提供的功能

```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 响应的工作：发送电子邮件、处理图像/视频、生成报告、同步数据或调用缓慢的外部服务。

内联执行此类工作会让用户等待，有请求超时的风险，如果失败也会丢失工作——而**队列化**它则允许你立即响应，同时后台**worker** 可靠地处理它。

除了异步卸载，队列还提供关键的生产功能：**带退避的自动重试**（针对瞬时故障的容错）、**延迟和计划任务**、**并发/速率限制控制**和**持久化**（Redis 支持的任务在崩溃/重启时存活，所以工作不会丢失）。

它们还**解耦**生产者和消费者，允许独立扩展。

知道如何设置队列、使用适当的选项（重试、延迟）添加任务以及在 worker 中处理它们，对于构建优雅处理繁重或延迟工作的真实应用程序很有价值。

这是生产 NestJS 系统中常见的、重要的模式，反映了构建超越简单请求-响应处理的响应式、可靠后端的成熟理解。