我需要为我的新项目选择一个新的队列代理。这一次，我需要一个可扩展的队列，支持发布/订阅，并且必须保持消息顺序。
我看了Alexis的评论: 他写道：
"实际上，我们认为RabbitMQ比Kafka提供更强的排序"
我读了rabbitmq文档中关于消息排序的部分：
"可以使用带有重新排队参数（basic.recover、basic.reject和basic.nack）的AMQP方法或由于通道关闭而保留未确认消息的方式将消息返回到队列...从2.7.0版本开始，如果队列有多个订阅者，个别消费者仍然可以观察到无序的消息。这是由于其他订阅者重新排队消息的操作。从队列的角度来看，消息始终按照发布顺序保持。"
如果我需要按照它们的顺序处理消息，我只能使用每个消费者的专用队列来使用RabbitMQ吗？
目前RabbitMQ是否仍被认为是有序消息排队的好解决方案？
好的，让我们更仔细地看一下您上面描述的情况。我认为立即在问题段落前粘贴文档以提供上下文非常重要：
AMQP 0-9-1核心规范的第4.7节解释了保证排序的条件：在一个通道中发布的消息，通过一个交换和一个队列和一个出站通道将按照发送顺序接收到。从RabbitMQ 2.7.0版本开始，它提供了更强的保证。
使用带有重新排队参数（basic.recover，basic.reject和basic.nack）的AMQP方法或由于持有未确认消息而关闭通道会导致消息返回到队列。任何这些情况都会导致消息在早于2.7.0版本的RabbitMQ版本中重新加入队列的末尾。从RabbitMQ 2.7.0版本开始，消息始终按发布顺序保留在队列中，即使存在重新排队或通道关闭也是如此。 （强调添加）
因此，很明显，从2.7.0版本开始，RabbitMQ在消息排序方面比原始的AMQP规范做出了相当大的改进。
使用多个（并行）消费者时，无法保证处理顺序。
第三段（被粘贴到问题中）继续给出免责声明，我来描述一下：“如果队列中有多个处理器，则不再保证以正确的顺序处理消息。”这里他们所说的只是RabbitMQ不能违背数学定律。
考虑银行的客户队伍。这家特殊的银行以按照进入银行的顺序为客户提供帮助而自豪。客户排队，由3个可用的出纳员中的下一个服务。
今天早上，碰巧三个出纳员同时有空，接下来的三位客户分别前来办理业务。突然间，排在第一个的出纳员突发重病，无法为排队的第一位顾客服务。这时，第二个出纳员已经完成了第二位顾客的服务，而第三个出纳员已经开始为第三位顾客服务。Kafka保留消息在分区内的顺序，但不是全局顺序。如果您的数据需要全局顺序和分区，这会使事情变得困难。然而，如果您只需要确保同一用户的所有相同事件等被正确排序地放置在同一个分区中，您可以这样做。生产者负责写入的分区，因此如果您能够逻辑上分区您的数据，这可能更可取。
有适当的方法可以保证RabbitMQ订阅中消息的顺序。
如果您使用多个消费者，它们将使用共享的ExecutorService处理消息。另请参见ConnectionFactory.setSharedExecutor(...)。您可以设置一个Executors.newSingleThreadExecutor()。
如果您使用一个Consumer和一个队列，您可以使用多个bindingKeys（它们可能带有通配符）绑定此队列。消息将按照它们被消息代理接收到的顺序放入队列中。
例如，您有一个单一的发布者发布消息，其中顺序很重要：
try (Connection connection2 = factory.newConnection();
Channel channel2 = connection.createChannel()) {
// publish messages alternating to two different topics
for (int i = 0; i < messageCount; i++) {
final String routingKey = i % 2 == 0 ? routingEven : routingOdd;
channel2.basicPublish(exchange, routingKey, null, ("Hello" + i).getBytes(UTF_8));
}
}
// declare a queue for the consumer
final String queueName = channel.queueDeclare().getQueue();
// we bind to queue with the two different routingKeys
final String routingEven = "even";
final String routingOdd = "odd";
channel.queueBind(queueName, exchange, routingEven);
channel.queueBind(queueName, exchange, routingOdd);
channel.basicConsume(queueName, true, new DefaultConsumer(channel) { ... });
Consumer现在将按照发布的顺序接收消息，无论您使用了不同的topics。
redelivered将是false而不是像正常重新排队一样的true。 - Kien Nguyen