Spring Integration - перерабатывает сообщения из входящего файлового адаптера по умолчанию после перезапуска сервера.

Question

У меня есть входящий адаптер файла, подключенный к файловому шлюзу. Ниже приведена конфигурация.

*

*

куча файлов были обработаны, как ожидается, на одном экземпляре ранее в тот же день. Еще один экземпляр был перезапущен по какой-то причине, через несколько часов позже, и он начал обрабатывать сообщения, которые были обработаны еще на другом экземпляре. Это привело к исключению filenotfound для каждого сообщения frm исходящий шлюз

2015-02-19 00:46 : 15,761 [task-scheduler-8] INFO org.springframework.integration.file.FileWritingMessageHandler - Не удалось переместить файл '/ tcserver/mounts/file_int/source/b31d688bc85c429bb4748f56a38f4e61'. Использование копирования и удаления.

2015-02-19 00: 46: 15,762 [task-scheduler-8] DEBUG org.springframework.integration.handler.LoggingHandler - (внутренняя боба) # 8 полученное сообщение: [Payload = org.springframework.integration. MessageHandlingException: не удалось записать полезную нагрузку Message в файл] [Headers = {timestamp = 1424328375761, id = ad494ba5-795f-40d0-b523-74998088028e}]

2015-02-19 00: 46: 15,762 [task-scheduler- 8] ERROR org.springframework.integration.handler.LoggingHandler - org.springframework.integration.MessageHandlingException: не удалось написать полезную нагрузку сообщения в файл по адресу org.springframework.integration.file.FileWritingMessageHandler.handleRequestMessage (FileWritingMessageHandler.java:293) at org.springframework.integration.handl er.AbstractReplyProducingMessageHandler.handleMessageInternal (AbstractReplyProducingMessageHandler.java:134) в org.springframework.integration.handler.AbstractMessageHandler.handleMessage (AbstractMessageHandler.java:73) .....

Вызванный: java.io.FileNotFoundException :/tcserver/крепления/file_int/источник/b31d688bc85c429bb4748f56a38f4e61 (Нет такого файла или каталога) в java.io.FileInputStream.open (Native Method) в java.io.FileInputStream (FileInputStream.java:146) в орг.. springframework.util.FileCopyUtils.copy (FileCopyUtils.java:63) at org.springframework.integration.file.FileWritingMessageHandler.handleFileMessage (FileWritingMessageHandler.java:352) на org.springframework.integration.file.FileWritingMessageHandler.handleRequestMessage (FileWritingMessageHandler.java:277)

1) Сохраняет ли весна состояние системы до выключения системы на сервере. 2) Любое объяснение того, почему это может произойти, может очень помочь

Answer 1

Если у вас несколько экземпляров, ссылающихся на один и тот же исходный каталог, вам нужно использовать фильтр постоянных файлов, а также MetadataStore (например, Redis) для совместного использования состояния через экземпляров.

См. the documentation.