Nest.js RabbitMQ收发异常：send/MessagePattern失效求助

问题 #

我有两个基于Nest.js的微服务，均已连接RabbitMQ服务（一个作为消息发布端，一个作为接收端）。尝试通过发布端向接收端发送消息，但完全没有任何反应，既无报错信息，RabbitMQ Web监控中也看不到任何消息。但使用emit搭配EventPattern时却能正常工作，请问这是什么原因？

发布端代码 #

// auth.module.ts
imports: [
  ClientsModule.registerAsync([
    {
      name: 'RMQ_SERVICE',
      imports: [ConfigModule],
      useFactory: (configService: ConfigService) => ({
        transport: Transport.RMQ,
        options: {
          urls: [`amqp://${configService.get('RMQ_HOST')}:5672`],
          queue: 'api-queue',
          queueOptions: {
            durable: false,
          },
        },
      }),
      inject: [ConfigService],
    },
  ]),
]

// auth.service.ts
@Inject('RMQ_SERVICE') private readonly client: ClientProxy,

// 使用方式
this.client.send({ cmd: 'create-user-data' }, {});

接收端代码 #

// main.ts
app.connectMicroservice<MicroserviceOptions>({
  transport: Transport.RMQ,
  options: {
    noAck: false,
    urls: [`amqp://${process.env.RMQ_HOST}:5672`],
    queue: 'api-queue',
    queueOptions: {
      durable: false,
    },
  },
});
await app.startAllMicroservices();

// users-data.controller.ts
@MessagePattern({ cmd: 'create-user-data'})
async createUserData() {
  console.log('create-user-data');
}

原因分析与解决办法 #

核心问题在于ClientProxy.send()是请求-响应模式，它会强制等待接收端返回响应。你的接收端方法没有返回任何值，Nest.js的RMQ客户端会一直等待响应超时，导致消息卡在内部流程中，甚至不会被发送到RabbitMQ队列（或发送后因无响应被丢弃）。而emit是单向事件模式，不需要接收端返回响应，所以能正常触发。

解决办法 #

1. 让接收端返回响应
   修改接收端的处理方法，确保返回一个值（哪怕是空对象或null），让send方法的请求-响应流程完整闭环：

@MessagePattern({ cmd: 'create-user-data'})
async createUserData() {
  console.log('create-user-data');
  return {}; // 返回任意值即可完成响应流程
}

2. 改用emit（无需响应场景）
   如果业务是单向通知、不需要接收端返回数据，直接将发布端的send替换为emit：

// auth.service.ts 中修改调用方式
this.client.emit({ cmd: 'create-user-data' }, {});

额外检查点 #

• 确认发布端与接收端的RabbitMQ队列配置（名称、queueOptions）完全一致
• 查看服务日志，确认两端均已成功连接RabbitMQ
• 若坚持使用send，务必保证接收端有返回值，避免客户端无限等待超时

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