Spring Integration-SFTP：远程目录间文件归档拷贝问题咨询

你完全没必要换掉已经在用的Spring Integration，它本身就提供了几种实现远程SFTP文件归档的方式，不用额外引入其他技术栈。下面是几个最实用的方案：

1. 直接使用 SftpRemoteFileTemplate 执行远程拷贝（最高效） #

因为是同一SFTP服务器，不需要把文件下载到本地再上传，直接调用SFTP协议的远程拷贝命令就行。Spring Integration的SftpRemoteFileTemplate封装了这个能力，你只需要注入模板后调用copy方法：

@Autowired
private SftpRemoteFileTemplate sftpRemoteFileTemplate;

public void archiveRemoteFile(String sourcePath, String archivePath) {
    // 注意路径格式要符合SFTP服务器的规范，比如"/source-dir/file.txt"和"/archive-dir/file.txt"
    sftpRemoteFileTemplate.copy(sourcePath, archivePath);
}

你可以把这个逻辑集成到你的文件拉取流程里——比如在拉取文件之前先归档（避免拉取过程中文件被修改），或者拉取完成后再归档。

2. 用 SftpOutboundGateway 执行远程拷贝命令 #

如果想通过Spring Integration的消息流来实现，可以使用SftpOutboundGateway，它支持SFTP的cp命令来完成远程拷贝。配置示例如下：

@Bean
public MessageHandler sftpArchiveGateway() {
    SftpOutboundGateway gateway = new SftpOutboundGateway(sftpSessionFactory(), "cp", "payload");
    gateway.setRemoteDirectoryExpression(new LiteralExpression("/archive-dir"));
    // 如果需要重命名归档文件，可以设置文件名生成器
    gateway.setFileNameGenerator(message -> {
        String originalName = (String) message.getHeaders().get(FileHeaders.FILENAME);
        return originalName + ".archived";
    });
    return gateway;
}

然后在你的拉取流程里，把源文件路径作为消息payload发送给这个网关，就能自动完成远程归档。

3. 拉取本地后再上传归档（适合需要修改文件的场景） #

如果你的业务需要先把文件拉取到本地做修改，再归档，那可以在拉取完成后，用SftpMessageHandler把本地文件上传到SFTP的归档目录：

@Bean
public MessageHandler sftpArchiveHandler() {
    SftpMessageHandler handler = new SftpMessageHandler(sftpSessionFactory());
    handler.setRemoteDirectoryExpression(new LiteralExpression("/archive-dir"));
    handler.setFileNameGenerator(message -> (String) message.getHeaders().get(FileHeaders.FILENAME));
    return handler;
}

这种方式虽然需要两次文件传输（下载+上传），但能满足有本地处理需求的场景。

总结 #

这几种方案都能在Spring Integration内部完成，完全不需要更换技术栈。优先推荐第一种远程拷贝的方式，因为它最高效，减少了不必要的网络传输。

内容的提问来源于stack exchange，提问作者DTnapaT