RabbitMQ未确认消息求助：队列显示为空但存在未ACK消息

首先明确：你在管理页面点击Get Messages看到队列空，是因为默认只查询就绪（Ready）状态的消息，而你那些未确认（Unacked）的消息已经被消费者获取但未完成确认，不在Ready队列里，但它们依然存在于RabbitMQ中。

要确保消息在被确认前一直保留，按以下要点检查和配置：

1. 确认消费者手动确认模式是否正确开启 #

消费者必须设置autoAck=false（不同客户端API的参数名可能有差异，比如Java客户端是autoAck，Python的pika是auto_ack），否则RabbitMQ会在消息投递后自动确认，不管你的业务逻辑是否执行成功。

示例（Python pika）：

channel.basic_consume(queue='your_queue', on_message_callback=your_callback, auto_ack=False)

2. 查看队列的完整消息状态 #

在RabbitMQ管理页面的队列详情页，关注三个核心数值：

• Ready：等待被消费者获取的消息数
• Unacked：已被消费者获取但未确认的消息数
• Total：Ready + Unacked的总消息数
  你发送了4条消息的话，Total应该显示为4，Unacked为4，Ready为0，这说明消息确实处于未确认状态，没有丢失。

3. 确保消息+队列的双重持久化 #

仅设置队列persistent=true不够，发送消息时必须同时设置消息持久化：

• 队列持久化：确保RabbitMQ重启后队列结构保留
• 消息持久化：确保RabbitMQ重启后消息不会丢失

示例（Java客户端）：

AMQP.BasicProperties props = new AMQP.BasicProperties.Builder()
    .deliveryMode(2) // 2代表持久化消息
    .build();
channel.basicPublish("", "your_queue", props, "message_body".getBytes());

4. 正确处理未确认消息的回收 #

如果消费者处理失败（比如写入数据库失败），不要直接忽略，应该调用**nack（否定确认）**并设置requeue=true，让消息重新回到Ready队列等待重试：

示例（Python pika）：

def your_callback(ch, method, properties, body):
    try:
        # 尝试写入数据库的逻辑
        write_to_db(body)
        ch.basic_ack(delivery_tag=method.delivery_tag) # 处理成功后确认
    except Exception as e:
        # 处理失败，将消息重新入队
        ch.basic_nack(delivery_tag=method.delivery_tag, requeue=True)

如果消费者进程崩溃或连接断开，RabbitMQ会自动把Unacked消息放回Ready队列，无需手动干预。

5. 查看Unacked消息的正确方式 #

在管理页面点击Get Messages时，在弹出的窗口中，将**"Type"**选项从默认的"Ready"改为"Unacked"或"All"，就能看到那些未确认的消息了。

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