列出远程服务器目录中的文件名

Question

我想递归地列出远程目录及其子目录中的文件。我知道可以通过将 ListGateway 的 listFiles 方法调用为：

List list = listGateway.listFiles("/ussama/providers")

@MessagingGateway
public interface ListGateway {

    @Gateway(requestChannel = "listSftpChannel")
    List<File> listFiles(String dir);

}

@Bean
@ServiceActivator(inputChannel = "listSftpChannel")
public MessageHandler handler() {
    SftpOutboundGateway sftpOutboundGateway = new SftpOutboundGateway(sftpSessionFactory(), "ls", "'/directory'");
    return  sftpOutboundGateway;
}

@Bean
public IntegrationFlow sftpOutboundListFlow() {
    return IntegrationFlows.from("listSftpChannel")
            .handle(new SftpOutboundGateway(sftpSessionFactory(), "ls", "payload")
            ).get();
}

但我想每隔 x 分钟执行一次。有没有一种方法可以每隔 x 分钟轮询一次远程目录以列出文件。请给出java配置。

Answer 1

轮询目录的简单 POJO 消息源并根据需要配置轮询器...

@Bean
public IntegrationFlow pollLs(SessionFactory<LsEntry> sessionFactory) {
    return IntegrationFlows.from(() -> "foo/bar", e -> e
                .poller(Pollers.fixedDelay(5, TimeUnit.SECONDS)))
            .handle(Sftp.outboundGateway(sessionFactory, Command.LS, "payload")
                    .options(Option.RECURSIVE))
            .handle(System.out::println)
            .get();
}

显然您需要 .handle 中的一些服务才能收到 List<LsEntry> 结果。

顺便说一下，有一个工厂 class Sftp 提供了创建端点的便捷方法。

列出远程服务器目录中的文件名

list file names from a remote server directory

java

spring-boot

spring-integration

sftp

spring-integration-sftp