Node.js-RabbitMQ队列空消息处理：接收空消息后服务停止后续处理

问题根源 #

1. 你遇到的message为null不是队列里存在“空消息”，而是RabbitMQ服务器主动取消了当前消费者（常见原因：队列被删除、连接异常断开、权限变更、队列参数修改等）。此时这个消费者已经失效，RabbitMQ不会再给它发消息，所以服务看起来停了。
2. 你之前调用channel.ack(message)或channel.nack(message)崩溃，是因为这两个方法必须传入有效的RabbitMQ消息对象，传入null必然触发报错。

解决方案 #

要解决这个问题，需要区分“消费者被取消（message为null）”和“消息内容为空”两种场景，同时在消费者失效时自动重启消费流程：

async GetMessageFromQueue() {
  // 抽离消费者初始化逻辑，方便重复调用
  const setupConsumer = async (channel) => {
    await channel.assertQueue(QueueEnum.MyQueue);
    channel.prefetch(1);
    // 保存消费者标签，用于后续取消操作
    const consumerTag = await channel.consume(QueueEnum.MyQueue, async (message) => {
      // 处理消费者被取消的核心逻辑
      if (message === null) {
        console.log("消费者已被RabbitMQ取消，重新启动消费");
        // 先尝试关闭当前失效的消费者
        if (consumerTag) {
          await channel.cancel(consumerTag).catch(err => console.error("取消失效消费者失败:", err));
        }
        // 重新创建消费者
        await setupConsumer(channel);
        return;
      }

      try {
        if (message.content) {
          // 这里写你的消息处理逻辑
        } else {
          console.log("收到内容为空的消息，确认并丢弃");
          channel.ack(message);
        }
      } catch (error) {
        console.error('处理消息出错:', error);
        // 可选：如果希望错误消息重新入队，把第三个参数改成true
        // channel.nack(message, false, false);
        channel.ack(message);
      }
    });
  };

  try {
    const connection = await amqp.connect(rabbitMQURL);
    // 监听连接关闭事件，连接断开时自动重启整个消费流程
    connection.on("close", () => {
      console.log("RabbitMQ连接已关闭，5秒后重新建立连接");
      setTimeout(() => this.GetMessageFromQueue(), 5000);
    });

    const channel = await connection.createChannel();
    await setupConsumer(channel);
  } catch (error) {
    console.error('启动消费流程出错:', error);
    // 启动失败后延迟重试
    setTimeout(() => this.GetMessageFromQueue(), 5000);
  }
}

关键修改说明 #

• 把消费者初始化逻辑抽成setupConsumer函数，方便消费者失效时快速重建。
• 当message为null时，先取消当前失效的消费者标签，再重新创建新的消费者，保证消费流程不中断。
• 监听连接关闭事件，一旦连接断开，自动重试重建连接和消费者。
• 区分“消息内容为空”和“消费者被取消”两种情况，前者正常ack即可，后者需要重启消费。
• 增加全局异常重试机制，避免单次启动失败就彻底停掉服务。

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