Spring SFTP入站chanel适配器删除本地文件

Question

我已经配置了spring SFTP以将文件从远程路径集中到本地，以处理一些作业，然后同时删除本地和远程文件。

下面的配置工作正常，除了删除本地文件外，我没有找到任何配置来删除本地文件，例如 delete-remote-files="true"

<bean id="sftpSessionFactory"
    class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory"
    p:host="${sftp.host}"
    p:port="${sftp.port}"
    p:user="${sftp.username}"
    p:password="${sftp.password}"
    p:allowUnknownKeys="${sftp.allowUnknownKeys}" />

<int:channel id="sftpChannel">
    <int:queue />
</int:channel>

<int-sftp:inbound-channel-adapter
    id="sftpInboundAdapter"
    channel="sftpChannel"
    session-factory="sftpSessionFactory"
    remote-directory="${sftp.remotedir}"
    local-directory="${sftp.localdir}"
    auto-create-local-directory="true"      
    delete-remote-files="true" 
    filename-pattern="*.TXT">
</int-sftp:inbound-channel-adapter>

<int:poller default="true" fixed-rate="${quartz.pick.repeatInterval}" max-messages-per-poll="${sftp.msg.per.poll}">
    <int:transactional synchronization-factory="syncFactory" />
</int:poller>

<int:transaction-synchronization-factory id="syncFactory">
    <int:after-rollback expression="@acceptOnceFilter.remove(payload)"/>
</int:transaction-synchronization-factory>

<bean id="acceptOnceFilter" class="org.springframework.integration.file.filters.AcceptOnceFileListFilter"/>

<int:service-activator input-channel="sftpChannel" ref="msgHandler" method="handleMessage"/>

<bean id="transactionManager" class="org.springframework.integration.transaction.PseudoTransactionManager"/>

<bean id="fileNameGenerator" class="org.springframework.integration.file.DefaultFileNameGenerator" />

这里，当文件从远程传输到本地时，服务激活器被调用。

服务激活器完成作业后，如何配置删除本地文件？

编辑：通过以下更改解决了从远程和本地删除有效负载的问题：

<int:transaction-synchronization-factory id="syncFactory">
    <int:after-commit expression="payload.delete()" channel="nullChannel"/>
    <int:after-rollback expression="@acceptOnceFilter.remove(payload)"/>
</int:transaction-synchronization-factory>

Answer 1

消息发送到流之后，入站适配器永远不会采取任何操作（自行执行）。它不了解有关下游流拓扑的任何信息-异步切换等。在删除文件之后和发送消息之前完成远程删除。

由于您已经在使用伪事务，并且在轮询程序线程上进行了所有操作，因此可以使用进行删除after-commit-expression。

另一种技术是将a添加request-handler-advice到最终使用者（在您的情况下为服务激活器）。这证明在该retry-and- more示例应用程序。

编辑：

回应您在下面的评论；否，使用SpEL不可能做两件事-但是，您可以使用

<int:after-commit expression="payload" channel="postProcess"/>

并在postProcess通道下游进行所需的操作。

但是，对于我来说，尚不清楚为什么要从过滤器中删除文件以获取成功和失败的信息-您应该只使用一个AcceptAllFileListFilter。

顺便说一句，我看不到您acceptOnceFilter在这里的任何地方使用过-您是否打算将其配置为local-filter属性？