【问题标题】:How to consume messages selectively from Spring AMQP?如何从 Spring AMQP 有选择地使用消息?
【发布时间】:2013-08-30 07:08:05
【问题描述】:

在队列中,我推送了 10K 个对象。时间戳是对象中的属性之一。那么,如何使用 spring amqp 编写消费者代码呢?

谁能帮我解决这个问题。

【问题讨论】:

    标签: rabbitmq message-queue producer-consumer spring-jms spring-amqp


    【解决方案1】:

    与 JMS 不同,AMQP 没有为消费者选择消息的概念。一种解决方案是使用主题交换并设置路由键 - 假设消费者 1 使用foo.bar 将他的队列绑定到交换,第二个使用 foo.baz 绑定;第三个与foo.* 绑定。第三个将获取所有消息(路由键以 foo. 开头);其他人只会使用各自的密钥获取消息。

    也可以使用直接交换;它需要在路由键上完全匹配。

    在此处提出更多问题之前,您可能应该通过所有 RabbitMQ tutorials 了解不同的交换类型。

    【讨论】:

    • 感谢罗素的回复。会调查的。
    猜你喜欢
    • 2011-03-26
    • 2016-12-13
    • 2014-07-08
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2019-06-21
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多