如何解决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 个不同的队列:
- queue1:com.my.queue.DataModel1
- queue2:com.my.queue.DataModel2
使用上述方法,所有消息都将在 queue1 和 queue2 中处理。 queue1 中的某些消息(特定于 queue2 的消息)将被忽略,反之亦然。
有没有办法只在一个队列中处理这些类型的消息?不确定使用相关 ID 区分这些消息是否是一种好方法。例如在消费者中:if 相关 id 存在 then 执行特定于数据模型 2 的逻辑 else 执行特定于数据模型 1 的逻辑
解决方法
AMPQ 协议中的消息被放置到来自生产者的交换中。交换器决定将这个或那个消息放置到哪个绑定队列。因此,您关于两个队列的逻辑是正确的,只是真正找出正确的路由逻辑的问题。
请考虑调查不同的交换类型,以确定哪一种是基于元数据的最佳逻辑:
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。