如何确认消息已发送至RabbitMQ队列？消费无接收问题排查

嘿，先揪出一个最可能的低级错误——你发送消息用的队列名是config.asteriskAmi.queue，但声明队列用的是config.amqp.queue！这俩配置值如果不一样，消息直接发去了另一个队列，你当前检查的tasks队列自然看不到消息，消费者也收不到。先立刻核对这两个配置项的内容，这大概率是问题的核心。

如果队列名没问题，下面是几个确认消息是否成功发送到RabbitMQ的实用方法：

• 检查sendToQueue的返回值
  sendToQueue会返回一个布尔值，直接告诉你消息是否被RabbitMQ的缓冲区接收。修改发送代码：

  const isSent = channel.sendToQueue(config.amqp.queue, Buffer.from('string'));
  console.log('消息发送状态:', isSent);
  

  如果返回false，说明RabbitMQ暂时无法接收消息（比如队列不存在、连接异常或流量控制），这时需要监听channel的drain事件，等缓冲区可用后重试发送：

  channel.on('drain', () => {
    console.log('缓冲区已清空，可以重新发送消息');
    // 这里重发未成功的消息
  });
  

• 启用消息确认机制（Confirm模式）
  开启Confirm模式后，RabbitMQ会明确通知你消息是否被持久化或成功入队，这是最可靠的验证方式：

  // 开启confirm模式
  await channel.confirmSelect();
  
  // 发送消息并监听确认回调
  channel.sendToQueue(
    config.amqp.queue, 
    Buffer.from('string'), 
    { persistent: true }, // 配合durable队列，确保消息持久化
    (err, ok) => {
      if (err) {
        console.error('消息发送失败，RabbitMQ未确认:', err);
      } else {
        console.log('消息已被RabbitMQ成功接收:', ok);
      }
    }
  );
  

• 检查RabbitMQ管理面板的所有队列
  既然你当前查看的tasks队列消息数为0，去管理面板的「Queues」页面，搜索所有队列，看看有没有和你发送时用的队列名匹配的队列——说不定消息全跑到那个队列里了。

• 验证消费者的队列配置
  确认消费者监听的队列名和生产者完全一致，并且声明队列的参数（比如durable）也和生产者匹配。RabbitMQ不允许同名队列存在不同属性，若参数不一致会直接报错，所以可以检查消费者的assertQueue代码是否和生产者对齐。

• 查看RabbitMQ日志
  去RabbitMQ的日志目录（Linux默认是/var/log/rabbitmq/，Windows可在服务日志中查看），搜索发送相关的错误信息，比如队列不存在、权限不足、连接中断等问题，日志会给出明确的线索。

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