Nest bull 队列和 api 的独立进程

typescript
// mAIn.ts
import { NestFactory } from '@nestJS/core';
import { AppModule } from './app.module';
import { QueueProcess } from './queue.process';
async function bootstrap() {
  const app = awAIt NestFactory.create(AppModule);
  const queueProcess = new QueueProcess();
  queueProcess.start();
  awAIt app.listen(3000);
}
bootstrap();

typescript
// queue.process.ts
import { Process, Processor } from '@nestJS/bull';
import { Job } from 'bull';
@Processor('task_queue')
export class QueueProcess {
  @Process('task_job')
  async processTask(job: Job) {
    // 处理任务逻辑
    console.log(<code>Processing task ${job.id}</code>);
    // 模拟任务处理时间
    awAIt new Promise(resolve => setTimeout(resolve, 5000));
    console.log(<code>Task ${job.id} processed</code>);
  }
  start() {
    console.log('Queue process started');
  }
}