如何解决订阅 RMQ 消息队列中的特定消息
我有一个 RM 队列 test-queue
。在那里,我需要为 3 个单独的服务中的 3 个单独的进程处理 3 个单独的消息 (message-1,message-2,message-3
)。
我使用 @RabbitListener
如下所示访问消息
@RabbitListener(queues = "test-queue")
public void getMessage1(Message message) {
System.out.println(message);
}
但我只需要在此函数中访问特定消息 ex:message-1
。
有什么要注意的吗?
解决方法
这是 AMQP 协议的错误设计。您需要为这些消息考虑 3 个不同的队列,并从具有正确路由的单个交换中为它们正确绑定。然后,您可以轻松地从这些队列中获得 3 个消费者。
我的观点是队列实体是消费者的责任。生产者只是将消息转储到交换中。因此,您只需从您的消费者应用程序中决定您希望如何获得生成的消息。
如果你真的不能改变你的 RabbitMQ 结构,你可以研究一下 Spring Integration 路由器模式的实现:https://docs.spring.io/spring-integration/docs/current/reference/html/message-routing.html#messaging-routing-chapter
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。