Spring集成（SFTP）：从子目录下载文件时出现问题

Question

我在Spring Boot应用程序中使用Spring集成版本5.4.4。我需要从“server_sftp”目录下的子目录中获取所有的XML文件。为此，我使用带有mget命令的SFTP流入站通道适配器和SFTP出站网关。不幸的是，应用程序只从根目录（server_sftp）下载文件，而不从子目录下载文件。

我哪里出错了？

@Bean
@InboundChannelAdapter(channel = "downloadXmlFileInputChannel", poller = @Poller(fixedDelay = "300000"))
public MessageSource<InputStream> sftpXmlFileMessageSource() {
    SftpStreamingMessageSource messageSource = new SftpStreamingMessageSource(template());
    messageSource.setRemoteDirectory("server_sftp/");
    return messageSource;
}

@Bean
public IntegrationFlow xmlFilesReadingFlow() {
    return IntegrationFlows
            .from(sftpXmlFileMessageSource(), e -> e.poller(Pollers.fixedDelay(Duration.ofSeconds(5))))
            .handle(Sftp
                    .outboundGateway(template(), Command.MGET, "'server_sftp/*'")
                    .options(Option.RECURSIVE)
                    .autoCreateLocalDirectory(true)
                    .localDirectoryExpression("'../webapps/event_report_app-1.0/xmlFilesLocalDirectory/' + #remoteDirectory")
                    .localFilenameExpression("#remoteFileName.replaceFirst('sftpSource', 'localTarget')"))
            .channel("downloadXmlFileOutputChannel")
            .get();
}

@Bean
public PollableChannel downloadXmlFileInputChannel() {
    return new QueueChannel();
}

@Bean
public DirectChannel downloadXmlFileOutputChannel() {
    return new DirectChannel();
}

sftp服务器上的目录结构

Answer 1

使用带有递归MGET命令的出站网关来获取完整的树。

使用mget命令mget基于模式检索多个远程文件，并支持以下选项：

-p：保留远程文件的时间戳。

-R：递归地检索整个目录树。

-x：如果没有文件与模式匹配，则抛出异常（否则，返回空列表）。

-D：成功传输后删除每个远程文件。如果忽略传输，则不会删除远程文件，因为FileExistsMode是IGNORE，而本地文件已经存在。

mget操作产生的消息负载是List对象（即，List of File对象，每个对象代表一个检索到的文件）。