java jdbc通过SSH隧道连接数据库

系统管理员 2023-02-18 03:21 9阅读 0赞

# java jdbc通过SSH隧道连接数据库 #

例如要拦截数据库a，不能直接连，必须通过ecs连接（Navicat配置ssh连接相当简单，但是Java程序怎么弄呢?）

### 实现步骤 ###

*  新建 springboot 或 maven项目（普通的java项目也可以，只是引入依赖没那么方便）
 *  pom.xml 中新增依赖

<dependency>
        <groupId>com.jcraft</groupId>
        <artifactId>jsch</artifactId>
        <version>0.1.55</version>
    </dependency>

*  建 SSH.properties，用来配置ssh服务器/数据库服务器等，详细见文件

#本地端口（就是本地访问这个端口，会被转发到所配置的数据库服务器）
    lport=10010
    
    
    #SSH服务器ip
    host=47.103.66.213
    #SSH访问端口
    port=22
    #SSH连接用户名
    user=root
    #SSH连接密码
    password=
    #秘钥文件路径（跟密码只要配置其中一个即可，优先级高于password）
    pem_file_path=/Users/stonewang/dev/pem/aaa.pem
    
    
    # 远程数据库服务器（是数据库的! 注意数据库的账号密码不需要在这里指定，在jdbc里指定或springboot里配置）
    rhost=rm-uf6g910h266zyrc40.pg.rds.aliyuncs.com
    #远程数据库服务端口
    rport=3433

*  建 `SSHService.java`

package com.wyf.test.sshforword;
    
    import com.jcraft.jsch.JSch;
    import com.jcraft.jsch.Session;
    
    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.Properties;
    
    /** * SSH端口转发 */
    public class SSHService { 
        static Integer lport;//本地端口
        static String rhost;//远程数据库服务器
        static int rport;//远程数据库服务端口
    
        static String user;//SSH连接用户名
        static String password;//SSH连接密码
        static String pem_file_path;//SSH连接密码
        static String host;//SSH服务器
        static int port;//SSH访问端口
    
        static { 
            //读取配置文件
            try { 
                // 获取hive.properties文件的路径
                InputStream is = SSHService.class.getClassLoader().getResourceAsStream("SSH.properties");
                Properties prop = new Properties();
                prop.load(is);
                // 读取配置文件的值
                lport = Integer.valueOf(prop.getProperty("lport"));
                rhost = prop.getProperty("rhost");
                rport = Integer.valueOf(prop.getProperty("rport"));
                user = prop.getProperty("user");
                password = prop.getProperty("password");
                pem_file_path = prop.getProperty("pem_file_path");
                host = prop.getProperty("host");
                port = Integer.valueOf(prop.getProperty("port"));
    
            } catch (FileNotFoundException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
    
    
        public static void sshRun() { 
            JSch jsch = new JSch();
            Session session = null;
            try { 
                if (pem_file_path != null) { 
                    jsch.addIdentity(pem_file_path);
                }
                session = jsch.getSession(user, host, port);
    
                if (pem_file_path == null) { 
                    session.setPassword(password);
                }
    
                session.setConfig("StrictHostKeyChecking", "no");
                // step1：建立ssh连接
                session.connect();
                System.out.println(session.getServerVersion());//这里打印SSH服务器版本信息
                //step2： 设置SSH本地端口转发，本地转发到远程
                int assinged_port = session.setPortForwardingL(lport, rhost, rport);
                System.out.println("localhost:" + assinged_port + " -> " + rhost + ":" + rport);
            } catch (Exception e) { 
                if (null != session) { 
                    //关闭ssh连接
                    session.disconnect();
                }
                e.printStackTrace();
            }
        }
    
        public static void main(String[] args) { 
            sshRun();
        }
    
    }

*  启动 `SSHService.java` 后项目会一直运行在后台进行监听

### 使用者如何连接 ###

连接配置

spring.datasource.url=jdbc:postgresql://localhost:10010/mydb?currentSchema=my_schema
    spring.datasource.username=my_user
    spring.datasource.password=my_password
    spring.datasource.driver-class-name=org.postgresql.Driver

> 注意：
> 
> 1、连接的host是localhost，请求localhost的10010，都将被转发到目的数据库。

例子

@Test
    public void testConnectDbBySSHTunnel() { 
      User user = userMapper.selectById(1);
    }