如何使用Java JSch客户端连接多台SFTP服务器并读取文件？

JSch完全支持为每台SFTP服务器建立独立连接——你可以为4台服务器分别创建独立的Session和ChannelSftp实例，实现并行或串行读取文件的需求。

核心实现思路 #

每台SFTP服务器的连接都是独立的，互不干扰。基本步骤如下：

• 为每台服务器配置独立的连接参数（主机地址、端口、用户名、认证方式）
• 针对每个参数集，创建单独的JSch会话（Session）并完成认证
• 打开对应的SFTP通道（ChannelSftp）执行文件读取操作
• 操作完成后，依次关闭通道和会话，释放资源

代码示例 #

下面是一个简单的实现示例，展示如何处理多台SFTP服务器的文件读取：

import com.jcraft.jsch.*;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

public class MultiSftpReader {

    // 定义SFTP服务器配置类
    static class SftpServerConfig {
        String host;
        int port;
        String username;
        String password;

        public SftpServerConfig(String host, int port, String username, String password) {
            this.host = host;
            this.port = port;
            this.username = username;
            this.password = password;
        }
    }

    public static void main(String[] args) {
        // 配置4台SFTP服务器的参数
        List<SftpServerConfig> serverConfigs = new ArrayList<>();
        serverConfigs.add(new SftpServerConfig("sftp1.example.com", 22, "user1", "pass1"));
        serverConfigs.add(new SftpServerConfig("sftp2.example.com", 22, "user2", "pass2"));
        serverConfigs.add(new SftpServerConfig("sftp3.example.com", 22, "user3", "pass3"));
        serverConfigs.add(new SftpServerConfig("sftp4.example.com", 22, "user4", "pass4"));

        JSch jSch = new JSch();
        for (SftpServerConfig config : serverConfigs) {
            Session session = null;
            ChannelSftp channelSftp = null;
            try {
                // 创建会话并连接
                session = jSch.getSession(config.username, config.host, config.port);
                session.setConfig("StrictHostKeyChecking", "no"); // 生产环境建议改为"yes"并配置已知主机
                session.setPassword(config.password);
                session.connect(30000); // 30秒连接超时

                // 打开SFTP通道
                channelSftp = (ChannelSftp) session.openChannel("sftp");
                channelSftp.connect();

                // 读取文件示例：读取远程文件到输入流
                String remoteFilePath = "/path/to/target/file.txt";
                InputStream inputStream = channelSftp.get(remoteFilePath);
                // 这里可以添加文件内容处理逻辑，比如写入本地文件或解析内容
                System.out.println("成功读取服务器 " + config.host + " 上的文件: " + remoteFilePath);
                inputStream.close();

            } catch (JSchException | SftpException | java.io.IOException e) {
                System.err.println("连接服务器 " + config.host + " 或读取文件失败: " + e.getMessage());
            } finally {
                // 释放资源
                if (channelSftp != null && channelSftp.isConnected()) {
                    channelSftp.disconnect();
                }
                if (session != null && session.isConnected()) {
                    session.disconnect();
                }
            }
        }
    }
}

关键注意事项 #

• Session和ChannelSftp实例都是线程不安全的，若使用多线程处理，需为每个线程分配独立的连接实例
• 生产环境中，建议关闭StrictHostKeyChecking的"no"配置，改为"yes"并通过jSch.setKnownHosts()配置已知主机列表，避免安全风险
• 可以根据需求实现并行处理（比如使用线程池），提升多服务器文件读取的效率
• 务必在finally块中关闭通道和会话，避免资源泄漏

内容的提问来源于stack exchange，提问作者D'DAS