如何从上传文件到 sftp 获得响应？

Question

如果文件成功上传到 sftp，我如何获得响应？这是我的代码

@Bean
public SessionFactory<LsEntry> axisSftpSessionFactory() {
    DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true);
    factory.setHost(axisSftpProperties.getSftpHost());
    factory.setPort(axisSftpProperties.getSftpPort());
    factory.setUser(axisSftpProperties.getSftpUser());
    factory.setPassword(axisSftpProperties.getSftpPassword());
    factory.setAllowUnknownKeys(true);
    return new CachingSessionFactory<>(factory);
}

/**
 * Handler message handler.
 *
 * @return the message handler
 */
@Bean
@ServiceActivator(inputChannel = TO_SFTP_CHANNEL)
public MessageHandler handler() {
    SftpMessageHandler handler = new SftpMessageHandler(axisSftpSessionFactory());
    handler.setRemoteDirectoryExpression(new LiteralExpression(axisSftpProperties.getSftpRemoteDirectory()));
    handler.setFileNameGenerator(message -> (String) message.getHeaders().get(FILENAME));
    return handler;
}


@Component
@MessagingGateway
public interface UploadGateway {


    @Gateway(requestChannel = TO_SFTP_CHANNEL)
    String upload(@Header(FILENAME) String filename, @Payload byte[] bytes);
}

这里的想法是，如果文件没有成功上传到 sftp 以便能够重试，则捕获任何错误。

如果我使用 SftpOutboundGateway 如何设置远程目录路径？ SftpOutboundGateway 网关 = new SftpOutboundGateway(sessionFactory(), "put", "payload");

Answer 1

查看文档：

put 操作产生的消息负载是一个字符串，其中包含传输后服务器上文件的完整路径。

因为你有一个 void return，它被丢弃了。

所以...

String upload(File file);

编辑

使用网关时，第三个构造函数参数是文件名的表达式；远程文件模板中提供了远程目录...

@Bean
public SftpRemoteFileTemplate template() {
    SftpRemoteFileTemplate template = new SftpRemoteFileTemplate(sessionFactory());
    template.setRemoteDirectoryExpression(new LiteralExpression("foo/test"));
    return template;
}

和

new SftpOutboundGateway(template(). "put", "headers['file_name']")

和

System.out.println(gate.upload("foo.txt", "foo".getBytes()));

和

foo/test/foo.txt