Java连接

Question

我如何在Java代码中实现这一点？

ssh -L 1234:localhost:3306 mysql.server.remote

我有一个Java 桌面应用程序，它的数据库位于共享服务器(internet)中，可以从任何地方访问。使用该软件的人将不会打开终端执行命令前后将使用该软件.

因此，当应用程序启动并关闭连接(conn.close()和ssh)时，我需要一个解决方案来将应用程序与数据库连接起来。为此，所有这些(上面的代码)都应该在我的脚本中.这是我无法达到的..。

我使用了JSch，并成功地创建了SSH隧道(在端口22上)，但无法连接MySQL.任何帮助都欢迎。

这里的整个代码：

public static void main(String[] args) throws SQLException {

    String host="ssh.Mysite.com";
    String rhost="localhost";
    int rport=3306;
    int lport=4321;

    String user="userMysite.com";
    String password="passMysite.com";

    String dbuserName = "UserDB.com";
    String dbpassword = "PassDB.com";
    String url = "jdbc:mysql://localhost:3306/DB.com";
    String driverName="com.mysql.jdbc.Driver";
    Session session= null;

    try{
  //ssh tunnel creation          
        java.util.Properties config = new java.util.Properties();
        config.put("StrictHostKeyChecking", "no");
        JSch jsch = new JSch();
        session=jsch.getSession(user, host, 22);
        session.setPassword(password);
        session.setConfig(config);
        session.connect();
        int assinged_port=session.setPortForwardingL(lport, rhost, rport);

  //mysql database connect                  
        Class.forName(driverName).newInstance();
        dbConn  = DriverManager.getConnection (url, dbuserName, dbpassword);

 String sql = "SELECT * FROM client ";      
     PreparedStatement ps = dbConn.prepareStatement(sql);
     ResultSet rs = ps.executeQuery();
            while (rs.next()){
                  System.out.println(rs.getString("name"));
            }

    }catch(JSchException e){
        e.printStackTrace();            
    }finally{
        if(dbConn != null && !dbConn.isClosed()){
            dbConn.close();
        }
        if(session !=null && session.isConnected()){
            session.disconnect();
        }
    }
}

为了测试目的，我编写了以下代码：

String url = "jdbc:mysql://localhost:3306";
String driverName="com.mysql.jdbc.Driver";
Class.forName(driverName);
Connection dbConn = DriverManager.getConnection (url, dbuserName, dbpassword); 

        try {
           ResultSet rs = dbConn.getMetaData().getCatalogs();
                        while (rs.next()) {
                            System.out.println("TABLE_CAT = " + rs.getString("TABLE_CAT") );
                        }           
         }catch(SQLException e){
                         e.printStackTrace(); 
         }

结果：

localhost:3306 =>打印我计算机本地主机上的所有数据库；

remote.server.mysql:3306、remote.server.mysql:4321或localhost:4321 =>错误

com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.

谢谢!

Answer 1

你能试着从Java运行ssh二进制文件吗？例如：

Runtime rt = Runtime.getRuntime();
Process pr = rt.exec("ssh -L 1234:localhost:3306 mysql.server.remote");

显然，这需要系统将ssh安装在路径中。