在RabbitMQ中，如何使用特定密钥使用多条消息或读取队列中的所有消息或exchange中的所有消息？

Question

我想使用来自特定队列或具有给定密钥的特定交换的多个消息。

因此，场景如下所示：

发布者发布消息1在队列1发布者发布消息2在队列1发布者发布消息3在队列1发布者发布消息4在队列2发布者发布消息5在队列2...消费者从队列1中消费消息一次获取[消息1，消息2，消息3]，并在一次回调中处理它们

listen_to(queue_name , num_of_msg_to_fetch or all, function(messages){
//do some stuff with the returned list
});

这些消息不是同时出现的，就像事件一样，我希望将它们收集到队列中，打包并发送给第三方。

我也读过这篇文章：

http://rabbitmq.1065348.n5.nabble.com/Consuming-multiple-messages-at-a-time-td27195.html

谢谢

Answer 1

您可能需要在概念上将域消息与RMQ消息分开。作为生产者，您可以将多个域消息捆绑到单个RMQ消息和。product（）将其发送到RMQ。请记住，这种设计由于存在窗口而引入超时和延迟（您可能会从Kafka那里得到一些印象，Kafka以延迟为代价进行捆绑以优化I/O）。

作为一个消费者，你会有一个消费者，典型的。handleDelivery将转换接收的正文以进行处理的实现：字节[]-

Answer 2

如果您想使用特定队列中的多条消息，可以尝试如下操作。

channel.queueDeclare(QUEUE_NAME, false, false,false, null);
Consumer consumer = new DefaultConsumer(channel){
   @Override
   public void handleDelivery(String consumerTag,
                                       Envelope envelope,
                                       AMQP.BasicProperties properties,
                                       byte[] body)
                    throws IOException {
                
                    String message = new String(body, "UTF-8");
                    logger.info("Recieved Message --> " + message);
                
   }
};

Answer 3

不要直接从队列中消耗，因为队列遵循循环算法（AMQP授权）使用铲子将队列内容传输到扇出交换，并直接消耗来自该交换的消息。您可以跨所有连接的消费者获取所有消息。：）