首页 文章

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

提问于
浏览 次
0

我已配置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>
java spring spring-integration spring-integration-sftp

1 回答

  • 2

    消息发送到流后，入站适配器从不采取任何操作（自行）;它对下游流拓扑没有任何了解 - 异步切换等 . 远程删除是在获取文件之后和发送消息之前完成的 .

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

    另一种技术是将 request-handler-advice 添加到最终消费者（在您的情况下为服务激活器） . 这在the retry-and-more sample app中得到证明 .

    EDIT:

    回应您的评论如下;不可以用SpEL做两件事 - 但是，你可以使用

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

    并在 postProcess Channels 下游的流程中执行任何操作 .

    但是，我不清楚为什么要从过滤器中删除成功和失败的文件 - 您应该只使用 AcceptAllFileListFilter .

    顺便说一句，我没有看到你的 acceptOnceFilter 在这里被使用 - 你是否打算将它配置为 local-filter 属性？

    回复于

相关问题