通过Jumpbox/代理从我的本地机器连接远程MySQL。

huangapple
未分类评论52阅读模式
英文:

Connect to remote MySQL from my local machine through Jumpbox/Proxy

问题

我可以通过跳板机/代理从我的本地机器连接到远程MySQL吗？

我在AWS机器(A)上部署了一个Java应用程序，该应用程序可以访问并连接到远程MySQL服务器(B)。现在，当我需要在本地测试我的Java应用程序时，无法连接到远程MySQL服务器(B)。

因此，基本上我的Java应用程序能否通过AWS机器从本地机器连接到远程服务器。

具体方式如下：
本地机器（Java应用程序）===》AWS机器(A)===》MySQL服务器(B)

AWS机器(A)只能通过SSH连接。:(

隧道技术可以在这里有所帮助。

英文:

Can I connect to remote Mysql via Jumpbox/proxy from my local machine.

I have a java application deployed in AWS machine(A) which has access and can connect to remote Mysql server(B). Now when I need to test my Java application locally I can not connect to Remote Mysql server(B).

So basically can my Java application connect to remote server from my local machine via AWS machine.

This way
Local Machine(java Application) ===> AWS machine(A)==> Mysql Server(B)

AWS Machine(A) can only be connected through SSH. 通过Jumpbox/代理从我的本地机器连接远程MySQL。

Can tunneling help here?

答案1

得分: 0

  1. you can use JSch
  3. http://www.jcraft.com/jsch/
  5. an example of how to use it
  7. package com.journaldev.java.ssh
  9. import java.sql.DriverManager;
  10. import java.sql.PreparedStatement;
  11. import java.sql.ResultSet;
  12. import java.sql.SQLException;
  14. import com.jcraft.jsch.JSch;
  15. import com.jcraft.jsch.Session;
  16. import java.sql.Connection;
  18. public class MySqlConnOverSSH {
  20.     /**
  21.      * Java Program to connect to the remote database through SSH using port forwarding
  22.      * author Pankaj@JournalDev
  23.      * throws SQLException
  24.      */
  25.     public static void main(String[] args) throws SQLException {
  27.         int lport=5656;
  28.         String rhost="secure.journaldev.com";
  29.         String host="secure.journaldev.com";
  30.         int rport=3306;
  31.         String user="sshuser";
  32.         String password="sshpassword";
  33.         String dbuserName = "mysql";
  34.         String dbpassword = "mysql123";
  35.         String url = "jdbc:mysql://localhost:"+lport+"/mydb";
  36.         String driverName="com.mysql.jdbc.Driver";
  37.         Connection conn = null;
  38.         Session session= null;
  39.         try{
  40.             //Set StrictHostKeyChecking property to no to avoid UnknownHostKey issue
  41.             java.util.Properties config = new java.util.Properties(); 
  42.             config.put("StrictHostKeyChecking", "no");
  43.             JSch jsch = new JSch();
  44.             session=jsch.getSession(user, host, 22);
  45.             session.setPassword(password);
  46.             session.setConfig(config);
  47.             session.connect();
  48.             System.out.println("Connected");
  49.             int assinged_port=session.setPortForwardingL(lport, rhost, rport);
  50.             System.out.println("localhost:"+assinged_port+" -> "+rhost+":"+rport);
  51.             System.out.println("Port Forwarded");
  52.             
  53.             //mysql database connectivity
  54.             Class.forName(driverName).newInstance();
  55.             conn = DriverManager.getConnection (url, dbuserName, dbpassword);
  56.             System.out.println ("Database connection established");
  57.             System.out.println("DONE");
  58.         }catch(Exception e){
  59.             e.printStackTrace();
  60.         }finally{
  61.             if(conn != null && !conn.isClosed()){
  62.                 System.out.println("Closing Database Connection");
  63.                 conn.close();
  64.             }
  65.             if(session !=null && session.isConnected()){
  66.                 System.out.println("Closing SSH Connection");
  67.                 session.disconnect();
  68.             }
  69.         }
  70.     }
  72. }
  74. Reference:
  75. https://www.journaldev.com/235/java-mysql-ssh-jsch-jdbc
英文:

you can use JSch

http://www.jcraft.com/jsch/

an example of how to use it

  1. package com.journaldev.java.ssh
  3. import java.sql.DriverManager;
  4. import java.sql.PreparedStatement;
  5. import java.sql.ResultSet;
  6. import java.sql.SQLException;
  8. import com.jcraft.jsch.JSch;
  9. import com.jcraft.jsch.Session;
  10. import java.sql.Connection;
  13. public class MySqlConnOverSSH {
  15. 	/**
  16. 	 * Java Program to connect to the remote database through SSH using port forwarding
  17. 	 * @author Pankaj@JournalDev
  18. 	 * @throws SQLException 
  19. 	 */
  20. 	public static void main(String[] args) throws SQLException {
  22. 		int lport=5656;
  23. 	    String rhost="secure.journaldev.com";
  24. 	    String host="secure.journaldev.com";
  25. 	    int rport=3306;
  26. 	    String user="sshuser";
  27. 	    String password="sshpassword";
  28. 	    String dbuserName = "mysql";
  29.         String dbpassword = "mysql123";
  30.         String url = "jdbc:mysql://localhost:"+lport+"/mydb";
  31.         String driverName="com.mysql.jdbc.Driver";
  32.         Connection conn = null;
  33.         Session session= null;
  34. 	    try{
  35. 	    	//Set StrictHostKeyChecking property to no to avoid UnknownHostKey issue
  36. 	    	java.util.Properties config = new java.util.Properties(); 
  37. 	    	config.put("StrictHostKeyChecking", "no");
  38. 	    	JSch jsch = new JSch();
  39. 	    	session=jsch.getSession(user, host, 22);
  40. 	    	session.setPassword(password);
  41. 	    	session.setConfig(config);
  42. 	    	session.connect();
  43. 	    	System.out.println("Connected");
  44. 	    	int assinged_port=session.setPortForwardingL(lport, rhost, rport);
  45. 	        System.out.println("localhost:"+assinged_port+" -> "+rhost+":"+rport);
  46. 	    	System.out.println("Port Forwarded");
  47. 	    	
  48. 	    	//mysql database connectivity
  49.             Class.forName(driverName).newInstance();
  50.             conn = DriverManager.getConnection (url, dbuserName, dbpassword);
  51.             System.out.println ("Database connection established");
  52.             System.out.println("DONE");
  53. 	    }catch(Exception e){
  54. 	    	e.printStackTrace();
  55. 	    }finally{
  56. 	    	if(conn != null && !conn.isClosed()){
  57. 	    		System.out.println("Closing Database Connection");
  58. 	    		conn.close();
  59. 	    	}
  60. 	    	if(session !=null && session.isConnected()){
  61. 	    		System.out.println("Closing SSH Connection");
  62. 	    		session.disconnect();
  63. 	    	}
  64. 	    }
  65. 	}
  67. }

Reference:
https://www.journaldev.com/235/java-mysql-ssh-jsch-jdbc

huangapple
  • 本文由 发表于 2020年7月24日 20:43:32
  • 转载请务必保留本文链接：https://java.coder-hub.com/63073824.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定