NestJS集成RabbitMQ无法发送消息至队列问题排查求助

你的核心问题在于消息发送逻辑未正确触发，同时main.ts存在初始化不完整的潜在问题，以下是具体修正步骤：

1. main.ts 的优化 #

当前main.ts仅启动了HTTP服务，但RMQ客户端的连接可能未被提前初始化（首次请求时才会尝试连接，可能导致延迟或失败）。可以添加客户端连接初始化逻辑，确保服务启动时完成RMQ连接：

import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module';

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  
  // 提前初始化RMQ客户端连接
  const rmqClient = app.get('RMQ_CLIENT');
  await rmqClient.connect();
  
  await app.listen(3000);
}
bootstrap();

2. AppService 消息发送逻辑的关键修正 #

ClientProxy.send()返回的是RxJS Observable对象，不订阅或转换为Promise的话，消息根本不会被发送——这是你调用后无反应的核心原因。修正后的代码如下：

import { Inject, Injectable } from "@nestjs/common";
import { PdfRequest } from "./model/pdf-request";
import { ClientProxy } from "@nestjs/microservices";
import { lastValueFrom } from "rxjs";

@Injectable()
export class AppService {
  private readonly queue: any[] = [];

  constructor(@Inject("RMQ_CLIENT") private readonly pdfClient: ClientProxy) {
  }

  async sendIntoQueue(pdfRequest: PdfRequest) {
    try {
      this.queue.push(pdfRequest);
      // 将Observable转为Promise，确保消息发送并等待结果
      const result = await lastValueFrom(this.pdfClient.send("test", {"test": "test"}));
      console.log("消息发送成功:", result);
    } catch (e){
      console.error("消息发送失败:", e);
    }
  }
}

如果不需要等待发送结果，也可以直接通过subscribe触发：

this.pdfClient.send("test", {"test": "test"}).subscribe({
  next: () => console.log("消息发送成功"),
  error: (err) => console.error("发送失败:", err)
});

3. 额外排查点 #

• 确认RabbitMQ用户权限：你配置的quest用户需拥有目标队列的写入权限
• 检查队列匹配：确保C#脚本监听的队列名称与你配置的dev完全一致
• 开启NestJS调试日志：启动时添加日志级别，便于排查连接或发送错误

  const app = await NestFactory.create(AppModule, {
    logger: ['debug', 'error', 'warn']
  });
  

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