Spring Integration向动态SFTP服务器上传文件的优化实现咨询

直接使用Spring Integration的SftpRemoteFileTemplate #

不需要创建大量静态或动态Integration Flow，也不用配置poller，直接用SftpRemoteFileTemplate处理单个上传请求，完美适配动态服务器配置的场景：

• 动态构建SftpSessionFactory
  从PubSub消息解析SFTP服务器配置（主机、端口、用户名、密码/密钥等），动态创建DefaultSftpSessionFactory实例：

  DefaultSftpSessionFactory createSftpSessionFactory(SftpConfig config) {
      DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true);
      factory.setHost(config.getHost());
      factory.setPort(config.getPort());
      factory.setUser(config.getUsername());
      factory.setPassword(config.getPassword());
      // 密钥认证可替换为setPrivateKey/setPrivateKeyPassphrase
      return factory;
  }
  

• 执行上传操作
  基于动态生成的SessionFactory初始化SftpRemoteFileTemplate，直接调用上传方法，支持字节数组、InputStream等多种文件内容形式：

  void uploadToDynamicSftp(SftpConfig config, String remoteFilePath, byte[] fileContent) {
      SftpRemoteFileTemplate template = new SftpRemoteFileTemplate(createSftpSessionFactory(config));
      // 按需上传，无冗余poller
      template.execute(session -> {
          session.write(new ByteArrayInputStream(fileContent), remoteFilePath);
          return null;
      });
  }
  

  这种按需调用的方式，既不需要配置poller，也不用维护大量Integration Flow，每处理一个PubSub消息就创建一次临时Template（或根据配置缓存SessionFactory复用）。

优化：缓存SessionFactory降低开销 #

如果存在重复的SFTP服务器配置请求，可通过Guava Cache或Spring Cache缓存SftpSessionFactory实例，避免重复创建的资源消耗：

@Cacheable(value = "sftpSessionFactories", key = "#config.host + '-' + #config.username")
DefaultSftpSessionFactory getCachedSftpSessionFactory(SftpConfig config) {
    return createSftpSessionFactory(config);
}

轻量化替代：直接使用JSch库 #

若觉得Spring Integration依赖过重，可直接用SFTP底层库JSch实现上传，代码更精简：

void uploadWithJSch(SftpConfig config, String remoteFilePath, byte[] fileContent) throws JSchException, SftpException {
    JSch jsch = new JSch();
    try (Session session = jsch.getSession(config.getUsername(), config.getHost(), config.getPort());
         ChannelSftp channel = (ChannelSftp) session.openChannel("sftp")) {
        session.setConfig("StrictHostKeyChecking", "no"); // 生产环境建议配置合法主机密钥
        session.setPassword(config.getPassword());
        session.connect();
        channel.connect();

        channel.put(new ByteArrayInputStream(fileContent), remoteFilePath);
    }
}

此方式完全脱离Spring Integration，直接操作底层连接，适合对依赖体积有要求的场景，注意用try-with-resources自动释放资源。

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