java - Spring 集成: process files line by line persisting read state

Question

我想使用 Spring 集成文件逐行处理文件，这似乎可以使用 FileReadingMessageSource 和 FileSplitter 实现。

但是，当 Spring 集成应用程序在处理文件时崩溃或重新启动时，我不希望重新处理行(至少不要太多)或丢失。

有没有办法在 Spring 集成中保持文件的读取状态，以便处理从中断处重新开始？有人有这种情况的例子吗？

Answer 1

无法在FileSplitter 中保持读取状态，但是我建议您查看幂等接收器 模式。因此，处理文件中的行的端点可以跳过那些已经处理过的行。

在文档中查看更多信息:https://docs.spring.io/spring-integration/docs/5.3.0.M4/reference/html/messaging-endpoints.html#idempotent-receiver