training_data/apps/server/src/queue/queue.module.ts

import { BullModule } from '@nestjs/bullmq';
import { Logger, Module } from '@nestjs/common';
import { ConfigModule, ConfigService } from '@nestjs/config';
import { join } from 'path';
import { PostQueueService } from './models/post/post.queue.service';

@Module({
  imports: [
    ConfigModule.forRoot(), // 导入 ConfigModule
    BullModule.forRootAsync({
      imports: [ConfigModule],
      useFactory: async (configService: ConfigService) => ({
        connection: {
          password: configService.get<string>('REDIS_PASSWORD'),
          host: configService.get<string>('REDIS_HOST'),
          port: configService.get<number>('REDIS_PORT', 6379),
        },
      }),
      inject: [ConfigService],
    }),
    BullModule.registerQueue(
      {
        name: 'general',
        processors: [join(__dirname, 'worker/processor.js')],
      },
      {
        name: 'file-queue', // 新增文件处理队列
        processors: [join(__dirname, 'worker/file.processor.js')], // 文件处理器的路径
      },
    ),
  ],
  providers: [Logger, PostQueueService],
  exports: [],
})
export class QueueModule {}