如何逐个消耗RabbitMQ死信队列中的消息

Question

这种需求类似于通过公开的REST服务API（Spring Boot）处理来自死信队列的消息。以便一旦调用REST服务,就会从DL队列中消耗一条消息,并将再次发布到主队列中进行处理。@RabbitListener(queues=“queue_name”）立即使用消息，这在场景中是不需要的。该消息只需由REST服务API使用。有什么建议或解决办法吗？

Answer 1

我认为rabbitlistener在这里没有帮助。

但是，您可以手动实现此行为。

Spring Boot自动创建rabbitMQ连接工厂，以便您可以使用它。当http调用只是手动读取队列中的单个消息时，您可以使用basic.get同步获取一条消息：

@Autowire 
private ConnectionFactory factory 

void readSingleMessage() {
   Connection connection = null;
   Channel channel = null;
   try {
      connection = factory.newConnection();
      channel = connection.createChannel();

      channel.queueDeclare(QUEUE_NAME, true, false, false, null);

      GetResponse response = channel.basicGet(QUEUE_NAME, true);
      if (response != null) {
         //Do something with the message
      }
   } finally {
     //Check if not null
     channel.close();
     connection.close();
   }

}