java - 如何使用多个sftp出站网关

Question

我是 Spring Integration 的新手，我正在使用两个流程:

1.- 从sftp读取文件，保存信息。我使用方法“mget”。

2.- 保存信息后，使用“mput”方法重命名在 sftp 服务器中处理的文件。

这是我的配置:

<bean id="filePrinter" class="com.maven.integration.FilePrinter" />

<int:channel id="outboundChannel"></int:channel>

<int:channel id="aggregateResultsChannel"/>

<int:channel id="toGet"></int:channel>

<int:gateway id="simpleGateway" service-interface="com.maven.integration.FileGateway"
    default-request-channel="ftpChannel" />

<int-sftp:outbound-gateway 
    session-factory="sftpClientFactory"
    request-channel="ftpChannel" 
    command="mget" 
    command-options="-R -P"
    expression="payload" 
    filename-regex="(new|.*.csv)"
    mode="IGNORE"
    local-directory-expression="@targetDir.get() + #remoteDirectory"
    reply-channel="outboundChannel"
    >
    <int-sftp:request-handler-advice-chain>
        <int:retry-advice />
    </int-sftp:request-handler-advice-chain>
</int-sftp:outbound-gateway>

<int:splitter input-channel="outboundChannel" output-channel="toGet"/>

<bean id="targetDir" class="java.util.concurrent.atomic.AtomicReference">
    <constructor-arg value="${target}"/>
</bean>

<int:service-activator ref="filePrinter" method="print"
    input-channel="toGet"/>


    <int-sftp:outbound-gateway 
    session-factory="sftpClientFactory"
    request-channel="toGet" 
    command="mput" 
    command-options="-R"
    local-directory="src/test/"
    expression="payload" 
    filename-regex="(new|.*.csv)"
    mode="IGNORE"
    remote-filename-generator-expression="payload.getName() + '.ack'"
    remote-directory-expression="#remoteDirectory"
    reply-channel="aggregateResultsChannel"
    >
    <int-sftp:request-handler-advice-chain>
        <int:retry-advice />
    </int-sftp:request-handler-advice-chain>
</int-sftp:outbound-gateway>

<int:aggregator input-channel="aggregateResultsChannel"/>

目前只执行了第一个带有mget命令的outbound-gateway，但第二个outbound-gateway没有执行，第二个进程怎么可能运行？

Answer 1

因为你的toGet很简单DirectChannel具有“每个消息订阅者只有一个”逻辑。同时您的mput网关使用它作为其 request-channel="toGet"与
<int:service-activator> 共享此 channel 。从此is earlier in the config, it is a first subscriber in the获取and therefore only this one process the message sent to the toGet` 通过分割器。

我认为你需要做的事情(如果故事仍然是关于 mput )与你在 mget 中所做的完全相反。 。因此，您应该在拆分的同时执行该逻辑，而不是在拆分之后执行。因此您应该发送MGET结果到分离器和 MPUT在平行下。为此，我建议您更改您的 outboundChannel到<publish-subscribe-channel>并使用这个 outboundChannel在 mput其网关 request-channel .