您只需要为消费者分配不同的组。

我能让每个消费者收到相同的消息吗?也就是说，两个消费者都得到消息1,2,3,4,5,6 ?这在AMQP/RabbitMQ中被称为什么?它通常是如何配置的?

不，如果消费者在同一个队列上，就不会。摘自RabbitMQ的AMQP概念指南:

重要的是要理解，在AMQP 0-9-1中，消息在消费者之间是负载均衡的。

这似乎意味着队列中的循环行为是给定的，不可配置。也就是说，为了让多个使用者处理相同的消息ID，需要单独的队列。

这种做法普遍吗?我是否应该让交换器将消息路由到两个单独的队列中，只有一个消费者?

不，它不是，单个队列/多个消费者，每个消费者处理相同的消息ID是不可能的。让交换器将消息路由到两个单独的队列确实更好。

由于我不需要太复杂的路由，扇出交换机将很好地处理这个问题。我之前没有过多关注exchange，因为node-amqp具有“默认交换”的概念，允许您直接将消息发布到连接，但是大多数AMQP消息都发布到特定的交换。

以下是我的扇出交换，包括发送和接收:

var amqp = require('amqp');
var connection = amqp.createConnection({ host: "localhost", port: 5672 });
var count = 1;

connection.on('ready', function () {
  connection.exchange("my_exchange", options={type:'fanout'}, function(exchange) {   
 
    var sendMessage = function(exchange, payload) {
      console.log('about to publish')
      var encoded_payload = JSON.stringify(payload);
      exchange.publish('', encoded_payload, {})
    }

    // Recieve messages
    connection.queue("my_queue_name", function(queue){
      console.log('Created queue')
      queue.bind(exchange, ''); 
      queue.subscribe(function (message) {
        console.log('subscribed to queue')
        var encoded_payload = unescape(message.data)
        var payload = JSON.parse(encoded_payload)
        console.log('Recieved a message:')
        console.log(payload)
      })
    })
  
    setInterval( function() {    
      var test_message = 'TEST '+count
      sendMessage(exchange, test_message)  
      count += 1;
    }, 2000) 
 })
})

在这种情况下，有一个有趣的选项，我在这里没有找到答案。

您可以在一个使用者中使用“requeue”特性对消息进行Nack，以便在另一个使用者中处理它们。 一般来说，这不是一种正确的方式，但也许它对某人来说已经足够好了。

https://www.rabbitmq.com/nack.html

注意循环(当所有消费者nack+requeue消息时)!

请阅读rabbitmq教程。你发布消息是为了交换，而不是为了排队;然后将其路由到适当的队列。在本例中，您应该为每个消费者绑定单独的队列。这样，它们就可以完全独立地使用消息。

如果你碰巧像我一样使用amqplib库，他们有一个发布/订阅RabbitMQ教程的实现示例，你可能会觉得很方便。

最后几个答案几乎是正确的——我有大量的应用程序，它们生成的消息需要最终传递给不同的消费者，所以这个过程非常简单。

如果希望同一消息有多个使用者，请执行以下步骤。

创建多个队列，用于接收消息的每个应用程序，在每个队列属性中，用amq“绑定”一个路由标记。直接交换。更改您的发布应用程序发送到amq。直接使用路由标记(不是队列)。然后AMQP将消息复制到具有相同绑定的每个队列中。工作就像一个魅力:)

例子:假设我有一个我生成的JSON字符串，我将它发布到“amq。使用路由标签“new-sales-order”直接交换，我有一个order_printer应用程序打印订单的队列，我有一个计费系统的队列，它将发送订单的副本和发票给客户端，我有一个web存档系统，我存档订单的历史/合规原因，我有一个客户端web界面，订单被跟踪，因为其他信息来自订单。

因此，我的队列是:order_printer、order_billing、order_archive和order_tracking 它们都绑定了“new-sales-order”绑定标签，所有4个都将获得JSON数据。

这是一种理想的发送数据的方式，而发布应用程序不知道或关心接收应用程序。