Spring 集成文件轮询。如果移动文件，是否需要使用 AcceptOnceFileListFilter？

Question

我正在编写一个文件轮询实现并试图确定是否需要使用 AcceptOnceFileListFilter。 FileProcessor 将执行的第一步是将文件移动到另一个目录。

轮询器“batchFilePoller”在轮询时是否使用多个线程？一个文件将被多个线程读取的情况下会出现竞争条件吗？在这种情况下，我假设我需要使用 AcceptOnceFileListFilter。

但是，如果轮询器仅使用池中的一个线程。 那么如果文件在下一个轮询时间之前移动并且它成功了，我假设文件没有被处理两次的可能性？

<int-file:inbound-channel-adapter id="batchFileInAdapter" directory="/somefolder" auto-create-directory="true" auto-startup="false" channel="batchFileInChannel" >
    <int:poller id="batchFilePoller" fixed-rate="6000" task-executor="batchTaskExecutor" max-messages-per-poll="1" error-channel="batchPollingErrorChannel" />
</int-file:inbound-channel-adapter>

<int:channel id="batchFileInChannel"/>

<int:service-activator input-channel="batchFileInChannel" >
    <bean class="com.foo.FileProcessor" />
</int:service-activator>

<task:executor id="batchTaskExecutor" pool-size="5" queue-capacity="20"/>

Answer 1

<int-file:inbound-channel-adapter> 具有 prevent-duplicates 选项，默认为 true，这是您的情况，因为您没有提供任何其他选项来阻止 prevent-duplicates 成为 true。

是的：如果您使用fixed-rate，任何轮询适配器都是多线程的。在这种情况下，新的轮询任务可以在前一个任务完成之前运行。

即使它是单线程的（使用fixed-delay），AcceptOnceFileListFilter 也必须存在，因为新的轮询任务不知道文件是否已被处理。它会再次读取同一个文件。

AcceptOnceFileListFilter 正好适用于您不想再读取同一个文件的情况。您可以使用<int:transactional synchronization-factory=""/> 来克服<int-file:inbound-channel-adapter> 的<poller> 的问题：

<int:transaction-synchronization-factory id="txSyncFactory">
    <int:after-commit expression="payload.delete()"/>
</int:transaction-synchronization-factory>

和PseudoTransactionManager。

您可以在 Spring 集成参考手册中找到更多信息。