Spring Integration出站文件适配器

Question

我在实现某些功能时遇到了一些问题，当我删除文件时，我注意到了一些不一致。

1）当我删除多个文件时，有时并不是所有文件都被转移到正确的目录。

<!-- Adapter for reading files in the incoming directory -->
<int-file:inbound-channel-adapter id="incomingFileAdapter"
                                  channel="fileInputChannel"
                                  prevent-duplicates="false"
                                  scanner="recursiveDirectoryScanner"
                                  filename-regex="^.*\.(?i)(avi|divx|xvid|flv|f4v|mkv|m1v|m2v|m4v|mpeg|mpg|mp4|mov|vob|wmv|asf|ts|mxf)$"
                                  directory="${file.listener.path.incoming}">
    <int:poller id="filePoller" default="true" max-messages-per-poll="5" fixed-rate="5000">
        <int:transactional transaction-manager="pseudoTransactionManager" />
    </int:poller>
</int-file:inbound-channel-adapter>

<!-- Adapter for writing files to the processed directory -->
<int-file:outbound-channel-adapter id="processedFileAdapter"
                                   mode="REPLACE"
                                   channel="fileInputChannel"
                                   delete-source-files="true"
                                   auto-create-directory="true"
                                   order="1"
                                   directory-expression="@dynamicDirectoryGenerator.generateDirectory(payload)" />

<int:service-activator
        input-channel="fileInputChannel"
        output-channel="nullChannel"
        order="2"
        ref="fileInputActivator"
        method="processMessage"/>

<bean id="fileInputActivator" class="com.nfl.dm.shield.ingestion.file.activator.FileInputActivator" />
<bean id="recursiveDirectoryScanner" class="org.springframework.integration.file.RecursiveLeafOnlyDirectoryScanner" />
<bean id="dynamicDirectoryGenerator" class="com.nfl.dm.shield.ingestion.file.dynamic.DynamicDirectoryGenerator" />
<bean id="pseudoTransactionManager" class="org.springframework.integration.transaction.PseudoTransactionManager" />

Answer 1

a）由于没有FileInputChannel的声明，因此它是DirectChanel，这意味着消息将交替地转到出站适配器和服务激活器。

将其声明为 ，每个文件将转到两个订阅服务器（基于顺序)。

b）不清楚您的意思，既然您想要将文件发送到服务，为什么要在它到达之前删除它？如果您确实想要这样做，那么您可以使用ExpressionEvaluatingRequestHandlerAdvise将 添加到文件适配器。有关如何使用该建议的示例，请参见重试和更多示例。

c）不，伪事务不是必需的，因为您没有对成功或失败采取任何行动。