Spring Integration：处理后将文件移动到远程 SFTP 位置

Question

我有一个条件，我应该通过以下步骤从 SFTP 远程位置读取文件：

1. 从 SFTP 位置读取文件，例如 input 文件夹。

2. 处理文件并使用文件内容调用 REST API。

3. 如果调用成功，将远程 SFTP 文件移动到archive 文件夹，否则将远程 SFTP 文件移动到 error 文件夹。

我正在考虑两种方法。我不知道哪些是可能的。

首先，从 SFTP 远程位置读取文件到本地并从远程删除它。然后调用 REST API。根据 REST 调用的响应，将文件上传到远程文件夹成功或错误。

其次，将文件从 SFTP 远程位置读取到本地。然后调用 REST API。根据 REST 调用的响应，将文件上传到远程文件夹成功或错误。

谁能告诉我哪种方法可行且方便？如果您也可以提及通道适配器，我将不胜感激。

到目前为止，我可以调用 REST API。

<int-sftp:inbound-channel-adapter id="sftpInbondAdapter"
        auto-startup="true" 
        channel="receiveChannel" 
        session-factory="sftpSessionFactory"
        local-directory="${local.dir}" 
        remote-directory="${sftp.dir.input}"
        auto-create-local-directory="true" 
        delete-remote-files="true"
        filename-pattern="*.txt">
        <int:poller fixed-rate="60000" max-messages-per-poll="1" />
    </int-sftp:inbound-channel-adapter>
    <int:channel id="receiveChannel"/>

    <int:splitter input-channel="receiveChannel" output-channel="singleFile"/>
    <int:channel id="singleFile"/>

    <int:service-activator input-channel="singleFile"
        ref="sftpFileListenerImpl" method="processMessage" output-channel="costUpdate" />
    <int:channel id="costUpdate" /> 

     <int:header-enricher input-channel="costUpdate" output-channel="headerEnriched">
         <int:header name="content-type" value="application/json" />
     </int:header-enricher>
     <int:channel id="headerEnriched" />

     <int-http:outbound-gateway
        url="${cost.center.add.rest.api}" request-channel="headerEnriched"
        http-method="POST" expected-response-type="java.lang.String" reply-channel="costAdded" >
    </int-http:outbound-gateway>
    <int:publish-subscribe-channel id="costAdded" />

在评估 API 调用响应后，一旦 API 调用成功，我想将远程文件移动到远程文件夹中的另一个位置。我的问题是如何根据http:outbound-gateway的响应将远程文件移动到另一个远程位置？

Answer 1

查看retry-and-more sample，特别是Expression Evaluating Advice Demo - 它显示了如何根据上传的成功/失败采取不同的操作。

编辑：

回应您的 cmets 对 Artem 的回答；由于您有delete-remote-files="true"，因此没有要移动的远程文件；您必须先将其设置为 false。

然后，使用我建议的建议来处理成功或失败 - 使用ftp:outbound-gateway 和mv 远程文件。请参阅gateway documentation for the mv command。