import org.apache.commons.pool2.ObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPool;
import com.jcraft.jsch.*;
 public class SFTPConnectionPoolExample {
    private static final String HOST = "your_sftp_host";
    private static final int PORT = 22;
    private static final String USERNAME = "your_username";
    private static final String PASSWORD = "your_password";
     public static void main(String[] args) {
        // 创建SFTP连接配置
        SFTPConfig sftpConfig = new SFTPConfig(HOST, PORT, USERNAME, PASSWORD);
         // 创建连接池工厂
        SFTPConnectionFactory connectionFactory = new SFTPConnectionFactory(sftpConfig);
         // 创建连接池
        ObjectPool<ChannelSftp> pool = new GenericObjectPool<>(connectionFactory);
         try {
            // 获取连接
            ChannelSftp sftpChannel = pool.borrowObject();
             // 使用连接执行操作
            // 例如，上传文件
            sftpChannel.put("local_file_path", "remote_file_path");
             // 释放连接
            pool.returnObject(sftpChannel);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
 // SFTP连接配置类
class SFTPConfig {
    private String host;
    private int port;
    private String username;
    private String password;
     public SFTPConfig(String host, int port, String username, String password) {
        this.host = host;
        this.port = port;
        this.username = username;
        this.password = password;
    }
     // getter和setter方法
    // ...
}
 // SFTP连接池工厂类
class SFTPConnectionFactory extends BasePooledObjectFactory<ChannelSftp> {
    private SFTPConfig sftpConfig;
     public SFTPConnectionFactory(SFTPConfig sftpConfig) {
        this.sftpConfig = sftpConfig;
    }
     @Override
    public ChannelSftp create() throws Exception {
        JSch jsch = new JSch();
        Session session = jsch.getSession(sftpConfig.getUsername(), sftpConfig.getHost(), sftpConfig.getPort());
        session.setPassword(sftpConfig.getPassword());
        session.setConfig("StrictHostKeyChecking", "no");
        session.connect();
        Channel channel = session.openChannel("sftp");
        channel.connect();
        return (ChannelSftp) channel;
    }
     @Override
    public PooledObject<ChannelSftp> wrap(ChannelSftp sftpChannel) {
        return new DefaultPooledObject<>(sftpChannel);
    }
     @Override
    public void destroyObject(PooledObject<ChannelSftp> p) throws Exception {
        ChannelSftp sftpChannel = p.getObject();
        if (sftpChannel != null && sftpChannel.isConnected()) {
            sftpChannel.disconnect();
        }
        super.destroyObject(p);
    }
}