Nest bull 队列和 api 的独立进程

使用Nest.js和Bull队列以及独立的API进程来构建应用程序是一种非常强大和可靠的方式。Nest.js是一个基于Node.js的框架，它提供了一种优雅、模块化的方式来构建可扩展的Web应用程序。Bull队列是一个强大的后台任务处理库，它允许我们将耗时的任务异步处理，以提高应用程序的性能和响应能力。通过将Nest.js和Bull队列与独立的API进程结合使用，我们可以进一步提高应用程序的可靠性和可维护性。

shell
$ npm install @nestjs/core bull

typescript
// email.module.ts
import { Module } from '@nestjs/common';
import { BullModule } from '@nestjs/bull';
@Module({
  imports: [
    BullModule.registerQueue({
      name: 'email',
    }),
  ],
})
export class EmailModule {}
// email.controller.ts
import { Controller, Post, Body } from '@nestjs/common';
import { Queue } from 'bull';
@Controller('email')
export class EmailController {
  constructor(private readonly emailQueue: Queue) {}
  @Post()
  async sendEmail(@Body() data: { to: string, subject: string, content: string }) {
    await this.emailQueue.add('sendEmail', data);
    return { message: 'Email sent to queue for processing' };
  }
}

typescript
// worker.ts
import { BullQueueProcessor } from '@nestjs/bull';
import { Job } from 'bull';
@BullQueueProcessor('email')
export class EmailWorker {
  async sendEmail(job: Job<{ to: string, subject: string, content: string }>) {
    const { to, subject, content } = job.data;
    // Send email logic here
    console.log(`Email sent to ${to} with subject "${subject}" and content "${content}"`);
  }
}

shell
$ npm run start:dev