时间戳

首页 > 解决方案 > 如何将文件从一个文件夹移动到远程 sftp 服务器上的另一个文件夹，使用 Java Config 动态提供文件名？

java - 如何将文件从一个文件夹移动到远程 sftp 服务器上的另一个文件夹，使用 Java Config 动态提供文件名？

问题描述

我被这个问题困住了。我的 sftp 服务器上有一个文件夹，里面有一个文件：folder/file.txt。我要做的只是将此文件移动到另一个目录：文件夹/子文件夹/file.txt。在文档中写道，您只需将 OutboundGateway 与 MV 命令一起使用。没关系，但主要问题是我不确切知道文件的名称是什么，所以我需要动态提供这个名称。我怎样才能做到这一点？

@Bean
@InboundChannelAdapter(value = "toSftpChannel",
        poller = @Poller(fixedDelay = "60000", maxMessagesPerPoll = "-1"))
public MessageSource<File> sftpMessageSource() {
    SftpInboundFileSynchronizingMessageSource source =
            new SftpInboundFileSynchronizingMessageSource(sftpInboundFileSynchronizer());
    source.setLocalDirectory(new File(localDirectory));
    source.setAutoCreateLocalDirectory(true);
    source.setLocalFilter(new AcceptOnceFileListFilter<File>());
    return source;
}

@Bean
public SftpInboundFileSynchronizer sftpInboundFileSynchronizer() {
    SftpInboundFileSynchronizer fileSynchronizer = new SftpInboundFileSynchronizer(getSftpSessionFactory());
    fileSynchronizer.setDeleteRemoteFiles(false);
    fileSynchronizer.setRemoteDirectory("/folder");
    fileSynchronizer.setFilter(new FtpSimplePatternFileListFilter("*.txt"));
    return fileSynchronizer;
}

@Bean
@ServiceActivator(inputChannel = "toSftpChannel")
public SftpOutboundGateway moveFileHandler() {
     SftpOutboundGateway sftpOutboundGateway = new SftpOutboundGateway(getSftpSessionFactory(), "mv", "'folder/" + "file.txt" + "'");                                                  
        sftpOutboundGateway.setRenameExpression(new LiteralExpression("/folder/subfolder/" + "file.txt"));
        return sftpOutboundGateway;
    }

标签： javaspring-bootspring-integrationconfigspring-integration-sftp

解决方案

不要使用文字表达式，而是使用动态表达式。

例如，而不是

"'folder/" + "file.txt" + "'"

利用

"'folder/' + headers['file_relativePath']"

和

sftpOutboundGateway.setRenameExpression(parser.parseExpression("'/folder/subfolder/' + headers['file_relativePath']";

（相对路径头由入站适配器设置）。

推荐阅读