使用Spring Integration读取文件，并希望使用过滤器进行订购和文件提取

如何解决使用Spring Integration读取文件，并希望使用过滤器进行订购和文件提取

我正在尝试实现一种方案，其中在Kubernetes环境中的多个Pod上运行的spring集成应用程序试图从一个目录中读取文件。

1. 在阅读时，我在文件上应用了锁定，但是在应用了锁定的情况下，我无法处理文件并将文件重命名或移动到另一个文件夹。
   file：nio-locker /

2. 释放锁后，我便可以读取文件并处理文件。

FileLocker locker = new NioFileLocker();
locker.unlock(file);

1. 为避免发生任何冲突，在释放锁定后，两个实例读取相同的数据文件，而我要创建一个临时文件，其文件名和前缀为_processing。

2. 因此，从目录中读取文件进行处理的任何文件适配器都不应读取具有另一个文件名和_processing后缀的文件。

摘要：

a。文件适配器（将选择未锁定且不包含带有_processing前缀的另一个文件的文件）。
b。读取文件后加锁。
C。使用文件名和_processing前缀创建临时文件。
d解锁文件并使用转换器和批处理作业对其进行处理。
e。从目录中读取文件的另一个Pod将检查未锁定且没有临时文件的文件。

 <file:inbound-channel-adapter
             channel="input"
             directory="C:/Users/*****/TestFileIntegration/inputWithData"
             auto-startup="true"
             prevent-duplicates="true"
             queue-size="10"
             use-watch-service="true">
        <int:poller id="poller" fixed-delay="1" />
        <file:nio-locker/>
     </file:inbound-channel-adapter>

我需要两点帮助
1。以某种方式读取文件，代码会首先选择最早的文件，最后选择最新的文件。
2。筛选并读取没有名为fileName_Processing且未锁定的临时文件的文件。

解决方法

请考虑不要使用<file:nio-locker/>，而是使用共享的FileSystemPersistentAcceptOnceFileListFilter配置MetadataStore。因此，您的应用程序的每个实例都将在轮询文件之前先咨询该存储。并且如果有文件条目，则当前实例将跳过它：https://docs.spring.io/spring-integration/docs/5.3.2.RELEASE/reference/html/file.html#file-reading

对于您要寻找的订单，comparator上有一个 <file:inbound-channel-adapter>选项：

<xsd:attribute name="comparator" type="xsd:string">
            <xsd:annotation>
                <xsd:documentation><![CDATA[
Specify a Comparator to be used when ordering Files. If none is provided,the
order will be determined by the java.io.File implementation of Comparable.  MUTUALLY EXCLUSIVE with queue-size.
                ]]></xsd:documentation>
            </xsd:annotation>
        </xsd:attribute>