【发布时间】:2013-08-30 07:08:05
【问题描述】:
在队列中,我推送了 10K 个对象。时间戳是对象中的属性之一。那么,如何使用 spring amqp 编写消费者代码呢?
谁能帮我解决这个问题。
【问题讨论】:
标签: rabbitmq message-queue producer-consumer spring-jms spring-amqp
在队列中,我推送了 10K 个对象。时间戳是对象中的属性之一。那么,如何使用 spring amqp 编写消费者代码呢?
谁能帮我解决这个问题。
【问题讨论】:
标签: rabbitmq message-queue producer-consumer spring-jms spring-amqp
与 JMS 不同,AMQP 没有为消费者选择消息的概念。一种解决方案是使用主题交换并设置路由键 - 假设消费者 1 使用foo.bar 将他的队列绑定到交换,第二个使用 foo.baz 绑定;第三个与foo.* 绑定。第三个将获取所有消息(路由键以 foo. 开头);其他人只会使用各自的密钥获取消息。
也可以使用直接交换;它需要在路由键上完全匹配。
在此处提出更多问题之前,您可能应该通过所有 RabbitMQ tutorials 了解不同的交换类型。
【讨论】: