Nest RabbitMQ RPC场景下NACK未触发Promise拒绝的问题咨询

嘿，我明白你遇到的问题了——你希望消费端抛出错误时，请求端的await amqpConnection.request()能直接触发Promise拒绝，而不是等到超时才报错。咱们来一步步解决这个问题：

为什么默认NACK行为没生效？ #

首先得搞清楚：当你设置errorBehavior: MessageHandlerErrorBehavior.NACK时，NestJS RabbitMQ只会做一件事——给RabbitMQ发送NACK信号（告诉它这个消息处理失败了），但不会自动把错误信息打包成RPC响应发回请求端的回复队列。所以请求端会一直傻等回复，直到超时才抛出超时错误，根本拿不到消费端的实际错误。

正确的解决方案：用REJECT替代NACK #

NestJS其实内置了专门处理RPC错误回传的行为，就是MessageHandlerErrorBehavior.REJECT。这个行为会自动把消费端的错误信息封装成响应，发送回请求端的回复队列，同时给RabbitMQ发送NACK（默认不重新入队）。

修改你的消费端代码就行：

import { RabbitRPC, MessageHandlerErrorBehavior } from '@golevelup/nestjs-rabbitmq';

@RabbitRPC({
  exchange: 'user',
  routingKey: 'test',
  queue: 'test',
  // 把NACK改成REJECT
  errorBehavior: MessageHandlerErrorBehavior.REJECT
})
public async rpcHandler(payload: any): Promise<any> {
  throw new Error("Error text that should be proxied to console.error");
}

这样一改，当消费端抛出错误时，请求端的await this.amqpConnection.request()会立刻reject，你在catch块里就能直接拿到消费端抛出的错误信息，完全不用手动处理错误格式。

如果你非要用NACK怎么办？ #

要是你因为某些原因必须保留NACK行为，那只能手动捕获错误并返回约定格式的响应，然后在请求端判断并主动reject。不过这种方式比较繁琐，不推荐：

消费端代码： #

import { RabbitRPC, MessageHandlerErrorBehavior } from '@golevelup/nestjs-rabbitmq';

@RabbitRPC({
  exchange: 'user',
  routingKey: 'test',
  queue: 'test',
  errorBehavior: MessageHandlerErrorBehavior.NACK
})
public async rpcHandler(payload: any): Promise<any> {
  try {
    // 你的业务逻辑代码
    throw new Error("Error text that should be proxied to console.error");
  } catch (err) {
    // 手动返回错误格式的响应
    return {
      isError: true,
      message: err.message,
      stack: err.stack
    };
  }
}

请求端代码： #

async sendMessage(payload: any) {
  try {
    const result = await this.amqpConnection.request({
      exchange: 'user',
      routingKey: 'test',
      queue: 'test',
      payload,
      // 可以根据需要调整超时时间
      timeout: 5000
    });
    // 判断响应是否为错误
    if (result.isError) {
      throw new Error(result.message);
    }
    console.log(result);
  } catch (e) {
    console.error(e); // 现在会进入这里拿到实际错误
  }
}

最后验证一下 #

确保你的RabbitMQ交换器、队列绑定都配置正确，另外如果需要调整超时时间，可以在request()方法里传入timeout参数。

总的来说，REJECT行为是NestJS为RPC场景专门设计的错误回传机制，用它最省心，完全符合你的需求。

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