有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java使用Spring AMQP监听许多短暂的、动态创建的队列

我正在使用RabbitMQ/Spring/Spring AMQP构建一个应用程序,在处理队列布局时遇到了问题

基本上,我有一个每个消费者都要听的队列,每个消息基本上都说“这个队列已经准备好由单个消费者处理”。然后,消费者将侦听消息中指示的队列,使用该队列中的所有消息,最后在完成后将其删除

这些短命队列都是在数据进入进行处理时动态创建的,不能被多个消费者使用(无论哪个消费者在“就绪”队列中获得消息)

在这种情况下,我很难优雅地对待消费者。现在,每当消费者从“就绪”队列中收到消息时,我只需创建一个新的DirectMessageListenerContainer,然后在它收到所有需要的消息后停止它。看来这个解决方案并不理想。Spring AMQP/RabbitMQ有没有更好的方法来处理这种情况


共 (0) 个答案