消费RabbitMQ消息遇Web服务无响应时，如何将Unacked消息移至Ready队列？

阿华AIGC实验室

2026-5-21

如何让RabbitMQ消息在处理失败时回到Ready队列重新处理？

你的问题核心是当Web服务调用失败时，如何主动将UNACKED状态的消息放回Ready队列，而不是让它一直挂着。当前代码里，你只在调用成功时确认消息（ch.ack），失败时什么都不做，导致消息卡在UNACKED状态——只有当消费者进程意外断开时，RabbitMQ才会把这些消息放回队列，但这显然不是你想要的主动控制方式。

解决方案：使用`ch.nack()`主动否定确认并重新入队

RabbitMQ提供了nack方法（Negative Acknowledgment），可以明确告诉RabbitMQ：这个消息处理失败了，请把它放回队列重新处理。你只需要在result为nil时调用这个方法，并设置requeue: true参数。

修改后的代码如下：

require File.expand_path('../config/environment.rb', __FILE__)
conn=Rabbit.connect
conn.start
ch = conn.create_channel
x = ch.exchange("d_notification_ex", :type=> "x-delayed-message", :arguments=> { "x-delayed-type" => "direct"})
q = ch.queue("d_notification_q", :durable =>true)
q.bind(x)
p 'Wait ....'
q.subscribe(:manual_ack => true, :block => true) do |delivery_info, properties, body|
  datos=JSON.parse(body)
  result = if datos['status']=='request'
             # 调用Web服务处理JSON
             Notification.send_payment_notification(datos.to_json)
           else
             # 调用Web服务处理原始body
             Notification.send_payment_notification(body)
           end

  if result.nil?
    # 处理失败：否定确认并重新入队
    ch.nack(delivery_info.delivery_tag, requeue: true)
  else
    # 处理成功：确认消息，从队列移除
    ch.ack(delivery_info.delivery_tag)
  end
end

关键细节说明

ch.nack(delivery_tag, requeue: true)：这个方法会告诉RabbitMQ，当前消息处理失败，需要重新放回Ready队列，等待下一次消费。
如果设置requeue: false，消息会被直接丢弃（如果没有配置死信队列的话），所以一定要设为true才能达到你的需求。