从SFTP访问文件而不将其下载到本地使用Spring Integration

Question

我目前有以下配置：

    @Bean
public SessionFactory<ChannelSftp.LsEntry> sftpSessionFactory() {
    DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true);
    factory.setHost(sftpHost);
    factory.setPort(sftpPort);
    factory.setUser(sftpUser);
    if (null != sftpPrivateKey) {
        factory.setPrivateKey(sftpPrivateKey);
        factory.setPrivateKeyPassphrase(sftpPrivateKeyPassphrase);
    } else {
        factory.setPassword(sftpPassword);
    }
    factory.setAllowUnknownKeys(true);
    return new CachingSessionFactory<>(factory);
}

@Bean
public SftpInboundFileSynchronizer sftpInboundFileSynchronizer() {
    SftpInboundFileSynchronizer fileSynchronizer = new SftpInboundFileSynchronizer(sftpSessionFactory());
    // fileSynchronizer.setDeleteRemoteFiles(true);
    fileSynchronizer.setRemoteDirectory(sftpRemoteDirectory);
    fileSynchronizer
            .setFilter(new SftpSimplePatternFileListFilter(sftpRemoteDirectoryFilter));
    return fileSynchronizer;
}

@Bean
@InboundChannelAdapter(channel = "fromSftpChannel", poller = @Poller(cron = "0/5 * * * * *"))
public MessageSource<File> sftpMessageSource() {
    SftpInboundFileSynchronizingMessageSource source = new SftpInboundFileSynchronizingMessageSource(
            sftpInboundFileSynchronizer());
    source.setLocalDirectory(new File(sftpLocalDirectory));
    source.setAutoCreateLocalDirectory(true);
    source.setLocalFilter(new AcceptOnceFileListFilter<>());
    return source;
}

@Bean
@ServiceActivator(inputChannel = "fromSftpChannel")
public MessageHandler resultFileHandler() {
    return message -> System.err.println(message.getPayload());
}

该配置将任何内容从远程目录下载到本地目录。但是我有一个REST控制器，我想从SFTP服务器中返回文件的字节数组，而不是将其下载到本地计算机。在Spring Integration/Boot中是否有可能？请问您有一些代码示例吗？

Answer 1

由于您说您有一个REST控制器来提出SFTP文件的请求，因此我建议您查看sftpoutboundgateway，这确实是为请求和答复而设计的。请参阅其command.get和option.stream：

    /**
     * (-stream) Streaming 'get' (returns InputStream); user must call {@link Session#close()}.
     */
    STREAM("-stream"),

请参阅文档中的更多信息： https://docs.spring.io/spring-integration/docs/current/current/referent/referent/reference/reference/html/html/sftp.html ＃使用the-get-command

不确定是什么导致您进入sftpinboundfilesynchronizingmessagesource用于您的请求 - 重新任务...

Answer 2

您可以使用ftpclient并调用retievieffilestream从远程SFTP服务器读取文件。请参阅 https://commons.apache.org/proper/commons-net/opidocs/org/apache/commons/net/net/ftppplp/ftppclient.html#retrievefilefrievefilestream-java-java-java.lang.lang.string-string-.string-c. string-

Answer 3

我认为您可以使用 远程filetemplate