在队列中，我推送了 10K 个对象。时间戳是对象中的属性之一。那么，如何使用 spring amqp 编写消费者代码呢？
谁可以帮我这个事。
问问题
452 次
1 回答
2
与 JMS 不同，AMQP 没有为消费者选择消息的概念。一种解决方案是使用主题交换并设置路由键 - 假设消费者 1 将他的队列绑定到交换，foo.bar第二个绑定与foo.baz; 第三个与foo.*. 第三个将获取所有消息（路由键以 foo 开头）；其他人只会使用各自的密钥获得消息。
也可以使用直接交换；它需要在路由键上完全匹配。
在此处提出更多问题之前，您可能应该阅读所有RabbitMQ 教程以了解不同的交换类型。
于 2013-08-30T12:47:08.690 回答