NestJS Bull模块忽略自定义Redis端口始终连接localhost:6379问题求助

核心原因 #

你遇到的配置不生效问题90%以上是由NestJS Bull模块的配置优先级或队列重复注册导致的，对应排查步骤如下： #

1. 检查全局Bull默认配置 #

NestJS中如果在根模块（通常是app.module.ts）调用了BullModule.forRoot()方法，该方法传入的全局Redis配置优先级高于单个队列registerQueue传入的配置。

• 如果forRoot()没有指定redis参数，默认就是{host: 'localhost', port: 6379}，会直接覆盖你单个队列的6380配置
• 解决方法：要么在forRoot()中统一配置正确的6380 Redis连接信息，要么删除全局forRoot()注册，完全使用单个队列的独立配置

2. 确认REDIS_QUEUE_URL常量值正确 #

你当前mail.module.ts中注册队列时传入的是redis: REDIS_QUEUE_URL，请直接打印该常量确认取值：

• 如果是Redis连接字符串，格式应为redis://localhost:6380
• 如果是配置对象，格式应为{host: 'localhost', port: 6380}
  避免常量定义错误指向了6379端口。

3. 排查队列重复注册问题 #

你的MailModule导入了UserModule，而UserService中注入了MAIL_QUEUE队列，如果UserModule自身也通过BullModule.registerQueue({name: MAIL_QUEUE})注册了该队列且没有指定Redis配置，就会使用默认的6379端口配置，覆盖MailModule中的配置。
解决方法：

• 不要在多个模块重复注册同一个队列
• 在MailModule的exports数组中添加BullModule，将注册好的队列导出
• UserModule直接导入MailModule即可直接使用@InjectQueue(MAIL_QUEUE)，无需额外注册队列

4. 额外优化点（非本次问题根因） #

你user.service.ts中的this.mailQueue.add()没有加await，也没有异常捕获，会导致队列添加失败时无法抛出明确的错误信息，建议修改为：

async mailPrincipalOnSchoolCreate(data) {
  try {
    const school_name = data.event.data.new.name;
    const email = data.event.data.new.principal_email;
    const firstname = data.event.data.new.principal_name;
    const lastname = data.event.data.new.principal_surname;

    await this.mailQueue.add('mail_principal_on_school_create', {
      email: email,
      firstname: firstname,
      lastname: lastname,
      schoolname: school_name,
    });
  } catch (err) {
    console.error('队列添加失败：', err);
    throw err;
  }
}

内容的提问来源于stack exchange，提问作者yasnil