Spring Integration Sftp流入站通道适配器多次处理同一文件

Question

我正在使用spring integration sftp入站流通道适配器，它每隔几秒钟就轮询一次。入站适配器正在多次挑选相同的文件进行处理。下面是配置。

<int-sftp:inbound-streaming-channel-adapter id="ftpInbound"
        channel="ftpChannel"
        session-factory="sessionFactory"
        filter="filter"
        remote-file-separator="/"
        remote-directory="/sampleFolder" auto-startup="true">
    <int:poller fixed-rate="30000" max-messages-per-poll="1" />
</int-sftp:inbound-streaming-channel-adapter>



<int:stream-transformer id="withCharset" charset="UTF-8"
input-channel="ftpChannel" output-channel="outputChannel"/> 

<bean id="filter"
class="org.springframework.integration.file.filters.CompositeFileListFilter">
<constructor-arg>
    <list>
        <bean
            class="sample.CustomFilter">

</bean>
         <bean
class="org.springframework.integration.file.filters. 
AcceptOnceFileListFilter"/>
    </list>
</constructor-arg>

上面代码中的sample.customFilter是SftpRegexPatternFileListFilter的一个子类，其中我将accept方法修改如下，以便根据Spring SFTP vanging filename-regex中提供的解决方案，只接受名称中有当前日期的文件

public boolean accept(ChannelSftp.LsEntry file){
setPattern(new java.text.SimpleFormat("yyyyMMDD").format(new 
java.util.Date())+".txt$"
super.accept(file);
}

面临的问题是同一个文件被处理多个文件。该文件在处理后保留在同一远程目录中。我的过滤器配置有问题吗？有人能帮我解决这个问题吗。

Answer 1

AcceptonCeFileListFilter基于对象哈希，同时SFTPStreamingMessageSource生成LSentry，其中创建的每个新对象都有自己的新哈希，即使文件名相同。

您需要使用SFTPpersistentAcceptonceFileListFilter，它已经实现了您想要实现的功能。

此外，我建议使用ChainFileListFilter而不是CompositeFileListFilter。这样，如果文件不传递CustomFilter，它就不会到达SFTPpersistentAcceptonCefileListFilter。因此，对于我们根本不感兴趣的文件，没有额外的内存消耗。

请参阅参考手册中的更多信息：

https://docs.spring.io/spring-integration/docs/current/reference/html/sftp.html#sftp-inbound

https://docs.spring.io/spring-integration/docs/5.0.7.release/reference/html/files.html#文件读取