使用Spring集成在不同服务器上传输文件（sftp）

Question

我需要在SI中构建一个应用程序，它读取一个输入目录，该目录可能包含1000个文件，并将它们复制到远程服务器，例如10个服务器，处理器实例将在其中接收它们进行处理。文件的移动应该是循环方式，以便在处理它们时不会给任何服务器带来额外的负担。再详细一点——假设我们在输入目录中有10个文件，那么应用程序应该在服务器1上复制文件1，在服务器2上复制文件2......服务器10上的文件10。

顺序并不重要，重要的是每个服务器的负载应该相等。我对Spring集成相当陌生，但我发现了一个使用SI进行文件sftp的示例

https://github.com/spring-projects/spring-integration-samples/tree/master/basic/sftp

但我不确定如何为多个服务器配置它，并使用一个算法以循环方式移动文件。

如果有任何提示或建议，我将不胜感激。

我能够使用下面的配置进行sftp。

<context:property-placeholder location="classpath:app.properties" />

<int-file:inbound-channel-adapter id="ReaderChannel"
    directory="file:${input.file.dir}" filename-pattern="*.*"
    prevent-duplicates="true" ignore-hidden="true" auto-startup="true">
    <int:poller id="poller" fixed-rate="1" task-executor="myTaskExecutor" />
</int-file:inbound-channel-adapter>

<int-task:executor id="myTaskExecutor"  pool-size="${file.concurrentFilesNum}" queue-capacity="0"   rejection-policy="CALLER_RUNS" />

<int-sftp:outbound-channel-adapter  id="sftpOutboundAdapter" session-factory="sftpSessionFactory" channel="ReaderChannel"
    charset="UTF-8" remote-directory="${output.file.dir}" auto-startup="true">
    <int-sftp:request-handler-advice-chain>
        <int:retry-advice />
    </int-sftp:request-handler-advice-chain>
</int-sftp:outbound-channel-adapter>

<beans:bean id="sftpSessionFactory"     class="org.springframework.integration.file.remote.session.CachingSessionFactory">
    <beans:constructor-arg ref="defaultSftpSessionFactory" />
</beans:bean>

<beans:bean id="defaultSftpSessionFactory"
    class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory">
    <beans:property name="host" value="${sftp.host}" />
    <beans:property name="privateKey" value="${sftp.private.keyfile}" />
    <beans:property name="privateKeyPassphrase" value="${sftp.private.passphrase}" />
    <beans:property name="port" value="${sftp.serverPort}" />
    <beans:property name="user" value="${sftp.username}" />
    <beans:property name="allowUnknownKeys" value="true" />
</beans:bean>

Answer 1

循环隐藏在DirectChannel中，使用单播Dispatcher在循环负载平衡策略上。

因此，当您有多个订阅者访问同一个DirectChannel时，消息将以循环方式发送给他们。

您需要为用例配置10

<代码>