关于 spring 集成 sftp 的讨论

Question

我使用 spring integration sftp 下载和上传 files.In 文件，我找到了

Spring Integration supports sending and receiving files over SFTP by providing three client side endpoints: Inbound Channel Adapter, Outbound Channel Adapter, and Outbound Gateway

下载文件时必须指定本地目录，上传文件时必须指定远程directory.But如果我写代码时无法指定目录，例如我的目录与 date.How 关联我可以在运行时分配目录吗？

这是我的代码：

@Bean
public SessionFactory<LsEntry> sftpSessionFactory(){
    DefaultSftpSessionFactory defaultSftpSessionFactory = new DefaultSftpSessionFactory();
    defaultSftpSessionFactory.setHost(host);
    defaultSftpSessionFactory.setPort(Integer.parseInt(port));
    defaultSftpSessionFactory.setUser(username);
    defaultSftpSessionFactory.setPassword(password);
    defaultSftpSessionFactory.setAllowUnknownKeys(true);
    return new CachingSessionFactory<LsEntry>(defaultSftpSessionFactory);
}

@Bean
public SftpRemoteFileTemplate sftpRemoteFileTemplate(){
    SftpRemoteFileTemplate sftpRemoteFileTemplate = new SftpRemoteFileTemplate(sftpSessionFactory());
    return sftpRemoteFileTemplate;
}

@Bean
@ServiceActivator(inputChannel = "sftpChannel")
public MessageHandler handlerGet() {
    SftpOutboundGateway sftpOutboundGateway = new SftpOutboundGateway(sftpSessionFactory(), "mget", "payload");
    sftpOutboundGateway.setLocalDirectory(new File(localDirectory));
    sftpOutboundGateway.setFilter(new SftpSimplePatternFileListFilter("*.txt"));
    sftpOutboundGateway.setSendTimeout(1000);
    return sftpOutboundGateway;
}

在messageHandler 中，我必须在outboundGateway 中分配localDirectory。当我想通过 days.I 更改我的 localDirectory 时，必须将文件下载到 localDirectory 并移动到目标目录。如何在运行时分配本地目录。例如今天我下载到 20170606/ 明天我下载到 20170607？

编辑

这是我的选择和测试

public interface OutboundGatewayOption {
    @Gateway(requestChannel = "sftpChannel")
    public List<File> getFiles(String dir);
}

@Test
public void test2(){
    outboundGatewayOption.getFiles("upload/20160920/");
}

Answer 1

sftpOutboundGateway.setLocalDirectoryExpression(
    new SpelExpressionParser().parseExpression("headers['whereToPutTheFiles']");

或parseExpression("@someBean.getDirectoryName(payload)")

等等

表达式的计算结果必须为表示目录绝对路径的字符串。

在计算表达式时，远程目录可用作变量 #remoteDirectory。

关于 spring 集成 sftp 的讨论

Discussion about spring integration sftp

spring

spring-integration

spring-integration-sftp

编辑