如何触发和轮询 ftp 出站网关

Question

我正在尝试使用递归方法的 ftp 出站网关从 ftp 服务器传输文件，因为我的 ftp 服务器将生成新的随机名称文件夹，并且我需要获取所有内容。我只知道这种方法有效，除非有人可以建议更简单的方法。无论如何，这是我的代码。

@Bean(value = "ftpTolocal")
public IntegrationFlow fileToFile() {
    IntegrationFlow flow = IntegrationFlows
            .from("inputChannel")
            .handle(Ftp.outboundGateway(defaultFtpSessionFactory(),
                    AbstractRemoteFileOutboundGateway.Command.MGET,
                    null)
                    //.regexFileNameFilter("(.*n.txt)")
                    .autoCreateDirectory(true)
                    .options(AbstractRemoteFileOutboundGateway.Option.RECURSIVE)
                    .localDirectoryExpression("'/localDirectory/' + #remoteDirectory"))
            .channel("nullChannel")
            
            .get();
    return flow;
}

我进行了搜索，我总是得到的答案是创建一条 inputChannel 消息，但我找不到真正告诉我如何执行此操作的消息。我也看到了很多xml解决方案，但我找不到如何实现它。 FTP集成指南似乎很少见，而且对于像我这样的菜鸟来说，解释似乎很难理解。提前致谢。

Answer 1

@Bean
IntegrationFlow polled() {
    return IntegrationFlows.fromSupplier(() -> "testMessage",
                    e -> e.poller(Pollers.fixedDelay(Duration.ofSeconds(5))))
            .handle(System.out::println)
            .get();
}