java - Spring Integration - 服务器重新启动后默认重新处理来自入站文件适配器的消息

Question

我有一个文件入站适配器连接到文件出站网关。下面是配置。

*

*

当天早些时候，在一个实例上按预期处理了一堆文件。另一个实例由于某种原因重新启动，几个小时后，它开始处理已经在另一个实例上处理过的消息。这导致来自出站网关的每条消息出现 filenotfound 异常

2015-02-19 00:46:15,761 [task-scheduler-8] 信息 org.springframework.integration.file.FileWritingMessageHandler - 无法移动文件“/tcserver/mounts/file_int/source/b31d688bc85c429bb4748f56a38f4e61”。使用复制和删除后备。

2015-02-19 00:46:15,762 [task-scheduler-8] 调试 org.springframework.integration.handler.LoggingHandler - (内部 bean)#8 收到消息:[Payload=org.springframework.integration.MessageHandlingException: 无法将消息负载写入文件][Headers={timestamp=1424328375761，id=ad4 94ba5-795f-40d0-b523-74998088028e}]

2015-02-19 00:46:15,762 [task-scheduler-8] 错误 org.springframework.integration.handler.LoggingHandler - org.springframework.integration.MessageHandlingException:无法将消息负载写入文件 在 org.springframework.integration.file.FileWritingMessageHandler.handleRequestMessage(FileWritingMessageHandler.java:293) 在org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) 在 org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:73)......

引起:java.io.FileNotFoundException:/tcserver/mounts/file_int/source/b31d688bc85c429bb4748f56a38f4e61(没有这样的文件或目录) 在 java.io.FileInputStream.open( native 方法) 在 java.io.FileInputStream.(FileInputStream.java:146) 在 org.springframework.util.FileCopyUtils.copy(FileCopyUtils.java:63) 在org.springframework.integration.file.FileWritingMessageHandler.handleFileMessage(FileWritingMessageHandler.java:352) 在 org.springframework.integration.file.FileWritingMessageHandler.handleRequestMessage(FileWritingMessageHandler.java:277)

1)spring是否将系统关闭前的系统状态保存在服务器中。2)任何关于为什么会发生这种情况的解释都会有很大帮助

Answer 1

如果您有多个实例引用同一源目录，则需要使用持久文件列表过滤器以及 MetadataStore(例如 Redis)来跨实例共享状态。

参见the documentation .