Spring批处理集成使用RabbitMq消息

Question

当RabbitMq消息到达队列时，我目前正在使用IntegrationFlow来触发作业执行。IntegrationFlow的AmqpInFronChannelAdapter和作业的第一步的ItemReader都配置为从同一队列中读取消息。

我遇到的问题是IntegrationFlow的AmqpInboundChannelAdapter读取RabbitMQ消息，然后ItemReader再也找不到该消息。可能是因为IntegrationFlow在作业启动之前确认了该消息。

是否有办法防止IntegrationFlow消费/确认消息，将其留在队列中，以便ItemReader可以按预期工作？我尝试配置AmqpInboundChannelAdapter来重新获取消息，但这只会导致适配器无限循环地重新读取它自己的消息。

这个问题在某种程度上描述了我的问题，除了我没有进行任何处理之外，我只是试图将IntegrationFlow用作JobLaunching触发器。因此，解决方案似乎是一种反模式。

Spring Batch集成-传递数据b/w集成和批处理

任何帮助都将不胜感激

Answer 1

如果批处理作业只需要来自该消息的信息，我建议绑定第二个队列，使用相同的路由密钥；一个队列用于触发器，一个队列用于项目读取器。

如果第一条消息是触发器并且项目阅读器随后读取多条消息，您可以将消息内容添加到JobParameters。您还需要将适配器的预取设置为1，以便在处理此消息时不会发送任何其他消息。