Интеграция Spring: обрабатывать файлы построчно в состоянии чтения

Question

Я хочу обрабатывать файлы построчно, используя файл интеграции Spring, что представляется возможным при использовании FileReadingMessageSource и FileSplitter.

Однако, когда приложение интеграции Spring падает или перезапускается во время обработки файл, я не хочу, чтобы строки обрабатывались повторно (по крайней мере, не слишком много) или терялись.

Существует ли способ сохранить состояние чтения файла в интеграции с Spring, чтобы обработка выполнялась перезапустил, где он остановился? У кого-нибудь есть пример такого сценария?

Answer 1

Невозможно сохранить состояние чтения в FileSplitter, однако я могу предложить вам взглянуть на шаблон Idempotent Receiver. Таким образом, конечная точка, которая обрабатывает строку из файла, может пропустить уже обработанные.

См. Дополнительную информацию в Документах: https://docs.spring.io/spring-integration/docs/5.3.0.M4/reference/html/messaging-endpoints.html#idempotent -receiver