时间戳

首页 > 解决方案 > RabbitMq：使用同一个队列消费不同的消息

java - RabbitMq：使用同一个队列消费不同的消息

问题描述

我对 rabbitmq 消费者有以下问题：

消息模型 1：

String name; //apple  //audi
String type; //fruit  //car

消息模型 2：

String name; //apple  //audi
String type; //fruit  //car
+
correlation_id: e.g a mapping id used in business logic: 1234567

（它们之间的唯一区别是关联 ID，它是元数据）

当我发布消息时，我使用以下路由键：com.my.routingKey。（对于数据模型 1 和数据模型 2）

当我使用消息时，我使用 2 个不同的队列：

  1. queue1：com.my.queue.DataModel1
  2. queue2：com.my.queue.DataModel2

使用上述方法，所有消息都将在 queue1 和 queue2 中处理。queue1 中的某些消息将被忽略（那些特定于 queue2 的消息），反之亦然。

有没有办法只在一个队列中处理这些类型的消息？不确定使用相关 ID 区分这些消息是否是一种好方法。例如在消费者中：如果相关 id 存在，则执行特定于数据模型 2的逻辑，否则执行特定于数据模型 1 的逻辑

标签： javarabbitmqspring-rabbit

解决方案

AMPQ 协议中的消息被放置到生产者的交换中。交换决定将这个或那个消息放置到哪个绑定队列。因此，您关于两个队列的逻辑是正确的，只有真正找出正确路由逻辑的问题。

请考虑调查不同的交换类型，以确定哪一个是基于该元数据的最佳逻辑：

https://www.rabbitmq.com/tutorials/amqp-concepts.html

推荐阅读