spring集成sftp的探讨

Question

我使用Spring Integrationsftp下载和上传文件。

Spring Integration通过提供三个客户端endpoint支持通过SFTP发送和接收文件：入站通道适配器、出站通道适配器和出站网关

当我要下载文件时，我必须分配本地目录，当我要上传文件时，我必须分配远程目录，但如果我不能在编写代码时分配目录，如我的目录与日期相关联，我如何在运行时分配目录？

下面是我的代码：

@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。当我想按天更改我的localDirectory时，我必须将文件下载到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（有效载荷）”）

等等。

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