Spring Integration - 具有不同文件夹的动态多 sftp/ftp 会话

Question

我不太确定 Spring 集成是否适合我。

我想将连接数据 (SFTP/FTP) 输入到数据库中，并使用预定的时间来获取数据。

但是我现在有几个问题，

1. 我可以在 spring 集成中动态添加 SFTP /FTP 作业吗？

2. 我可以集群 Spring 集成作业吗？

我找到了几个解决方案来进行多个 SFTP 轮询，但它们不起作用。 例如：spring integration : solutions/tips on connect multiple sftp server?

感谢您的反馈。

Answer 1

您可以使用 Spring Integration Java DSL 动态流来做到这一点：https://docs.spring.io/spring-integration/docs/current/reference/html/dsl.html#java-dsl-runtime-flows

所以：

1. 您使用 JDBC 入站通道适配器从数据库中轮询设置：https://docs.spring.io/spring-integration/docs/current/reference/html/jdbc.html#jdbc-inbound-channel-adapter
2. 您使用 IntegrationFlowContext 创建动态流，将 SFTP 服务器连接工厂和远程目录填充到 SFTP 入站通道适配器并启动该动态流：https://docs.spring.io/spring-integration/docs/current/reference/html/sftp.html#sftp-inbound

另一种选择是考虑使用RotatingServerAdvice：https://docs.spring.io/spring-integration/docs/current/reference/html/sftp.html#sftp-rotating-server-advice

要使这样的解决方案在集群中健壮，您应该使用配置了共享MetadataStore 的SftpPersistentAcceptOnceFileListFilter：https://docs.spring.io/spring-integration/docs/current/reference/html/system-management.html#metadata-store。

此示例演示了如何为 TCP/IP 使用动态流的技术，但原理相同：https://github.com/spring-projects/spring-integration-samples/tree/master/advanced/dynamic-tcp-client。

另请参阅此 SO 线程：how can i connect with different SFTP server dynamically?