使用 AMQP RabbitMQ 的 Spring Batch

Question

我想使用 String Batch 从 RabbitMQ / AMQP 获取数据。 我想加载 100 条消息（或者如果没有 100 条消息，则在超时后出现的消息数），然后将其放入列表中。 我有一个正在工作的 RabbitMQ，我只想以每 100 个包的形式从中获取数据并将其集中到列表中。

我已阅读有关 Spring Batch 的信息，我发现它可以使用 org.springframework.batch.item.file.FlatFileItemReader 从文件（例如 CSV）中读取。 但我不知道如何从兔子队列中读取？或者甚至有可能吗？

亲切的问候，

拉法尔

Answer 1

你看过 Spring-AMQP 吗？

• http://www.springsource.org/spring-amqp
• http://blog.codecentric.de/en/2011/04/amqp-messaging-with-rabbitmq/

Answer 2

这是一个 Spring Batch AMQP ItemReader / ItemWriter 实现。 https://dzone.com/articles/batch-processing-with-spring-batch-and-amqp-easier