Java使用JSCH搭建SSH隧道后连接PostgreSQL失败如何解决？

核心错误点 #

• 端口转发参数逻辑错误：你调用setPortForwardingL的参数含义理解错误，该方法作用是将本地端口的流量通过SSH隧道转发到目标数据库地址和端口，你错误将转发目标地址填为了SSH跳板机地址（如果数据库和跳板机非同机则直接失效）。
• JDBC连接地址错误：隧道建立后，流量需要走本地转发端口，你仍填写远程数据库IP，相当于绕开了SSH隧道直接请求数据库，公网环境下大多数据库不会开放公网访问，所以连接失败。

修复步骤 #

1. 修正端口转发逻辑，setPortForwardingL的正确参数顺序为：setPortForwardingL(本地绑定IP, 本地监听端口, 目标数据库IP, 目标数据库端口)，如果需要系统自动分配空闲本地端口，本地监听端口可传0，避免端口占用冲突。
2. 修改JDBC连接地址为本地回环地址127.0.0.1，使用端口转发返回的本地端口建立连接。
3. 注意SSH Session对象的生命周期，不能在数据库连接建立后就销毁Session，否则隧道会被关闭导致连接中断，建议将Session与Connection绑定存储。

修复后代码示例 #

// 自定义返回类存储连接和会话，避免Session被GC回收导致隧道中断
public static class DBConnectionHolder {
    private final Connection connection;
    private final Session sshSession;

    public DBConnectionHolder(Connection connection, Session sshSession) {
        this.connection = connection;
        this.sshSession = sshSession;
    }

    public Connection getConnection() {
        return connection;
    }

    // 关闭资源时同时关闭SSH会话和数据库连接
    public void close() throws SQLException {
        if (connection != null && !connection.isClosed()) {
            connection.close();
        }
        if (sshSession != null && sshSession.isConnected()) {
            sshSession.disconnect();
        }
    }
}

public static DBConnectionHolder connectDBAWS(String dbIp, int dbPort, String dbName, String dbUsername, String dbPassword, 
                                               String tunnelHost, int sshPort, String tunnelUsername, String tunnelPassword) {
    Connection connection = null;
    Session session = null;
    try {
        // 建立SSH隧道
        JSch jsch = new JSch();
        session = jsch.getSession(tunnelUsername, tunnelHost, sshPort);
        session.setPassword(tunnelPassword);
        session.setConfig("StrictHostKeyChecking", "no");
        session.connect();
        System.out.println("SSH连接成功");
        // 本地端口转发：本地自动分配空闲端口，流量转发到目标数据库地址端口
        int localForwardPort = session.setPortForwardingL("127.0.0.1", 0, dbIp, dbPort);
        System.out.println("本地转发端口：" + localForwardPort);

        // 走本地转发端口连接数据库
        String dbUrl = "jdbc:postgresql://127.0.0.1:" + localForwardPort + "/" + dbName;
        Class.forName("org.postgresql.Driver");
        connection = DriverManager.getConnection(dbUrl, dbUsername, dbPassword);
        System.out.println("数据库连接成功");
        return new DBConnectionHolder(connection, session);
    } catch (Exception e) {
        // 异常时主动释放资源
        if (connection != null) {
            try { connection.close(); } catch (SQLException ex) {/* 忽略关闭异常 */}
        }
        if (session != null && session.isConnected()) {
            session.disconnect();
        }
        e.printStackTrace();
        return null;
    }
}

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