演示

队列

自定义后台任务使用 BullMQ Queue 实例。周期性调度请用 CronJobService(见 Cron job)。

用 @Bean 注册队列

当需要 CronJobService 之外的自定义队列时,通过 DI 容器暴露 BullMQ Queue 实例。完整 @Bean 规则见 Bean 注解页。

TSXservice
1import { Queue } from "bullmq"; 2import { Bean, Service } from "@quan-erp/shared-backend-core"; 3 4@Service() 5export class QueueRegistryService { 6 @Bean() 7 private registerQueue() { 8 return new Queue("my-queue", { connection: redisOptions }); 9 } 10}

定时任务

定时调度优先使用内置 CronJobService(BullMQ + Redis + Postgres)。详见 Cron job 页。