使用 Java 通过 SSH 连接到 MySQL

我想使用 Java 连接到 Amazon EC2 服务器上的 MySQL 数据库。我可以使用 Jsch 库创建 ssh 隧道并将端口转发到该服务器，但是连接到数据库总是以异常结束

java.io.EOFException：无法从服务器读取响应。预计读取 4 个字节，但在连接意外丢失之前读取了 0 个字节。

我想我和Hei陷入了同样的境地（通过 SSH 隧道远程访问 MySQL 数据库 https://stackoverflow.com/questions/14976504/ssh-tunneling-to-remote-access-mysql-database)

这是我的代码：

    public static void main(final String[] args) throws SQLException {
            final int lport = 3306;
            final String host = "xxx.xxx.xxx.xxx";
             final String rhost = "xxx.xxx.xxx.xxx";
             final int rport = 3306;
            final String user = "user";
            final String dbuserName = "user";
             final String dbpassword = "password";
            final String dburl = "jdbc:mysql://localhost:" + rport  + "/information_schema?useUnicode=true&characterEncoding;=UTF-8";
             final String driverName = "com.mysql.jdbc.Driver";
             Session session = null;

            try {
                //Set StrictHostKeyChecking property to no to avoid UnknownHostKey issue
                final java.util.Properties config = new java.util.Properties();
                config.put("StrictHostKeyChecking", "no");
                final JSch jsch = new JSch();
                session = jsch.getSession(user, host, 22);
                jsch.addIdentity("path\\to\\pemfile.pem");
                session.setConfig(config);
                session.connect();
                System.out.println("Connected");
                final int assinged_port = session.setPortForwardingL(lport, rhost, rport);
                System.out.println("localhost:" + assinged_port + " -> " + rhost + ":" + rport);
                System.out.println("Port Forwarded");

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

                System.out.println("Database connection established");
                System.out.println("DONE");

            } catch (final Exception e) {
                e.printStackTrace();
            } finally {
                if (dbConn != null && !dbConn.isClosed()) {
                    System.out.println("Closing Database Connection");
                    dbConn.close();
                }
                if (session != null && session.isConnected()) {
                    System.out.println("Closing SSH Connection");
                    session.disconnect();
                }
            }
        }

任何人都可以帮助解决这个问题吗？谢谢

我在使用 AppFog 时遇到了完全相同的问题（在 AWS 前面）。解决此问题的唯一方法是从连接字符串中删除以下内容：

"?useUnicode=true&characterEncoding=UTF-8"

当然，您应该确保这不会影响您的应用程序要求。