Java SSH 秘钥连接mysql数据库的方法

下面是详细讲解“Java SSH 秘钥连接mysql数据库的方法”的完整攻略，步骤如下：

1. 生成密钥文件

在本地电脑上生成密钥文件，使用如下命令：

$ ssh-keygen -t rsa -b 2048

然后你会看到生成了两个文件：id_rsa 和 id_rsa.pub，这两个文件一个是私钥，一个是公钥。将公钥文件 id_rsa.pub 发送给服务器管理员，并让他把公钥添加到服务器上的~/.ssh/authorized_keys 文件中。

2. 开启SSH转发

在你的 Java 代码中需要使用 SSH 转发来访问远程 MySQL 服务器。你需要在本地启动 SSH 连接并配置端口转发（-forwarding）功能。假设你的私钥文件为 id_rsa，服务器的 IP 地址为 123.123.123.123，用户名为 root ，则可以使用如下命令：

$ ssh -i /path/to/id_rsa -fN -L 33306:localhost:3306 root@123.123.123.123

在这个命令中，-i 表示使用指定的私钥文件，-fN 表示将 SSH 连接作为守护进程在后台运行，并且不打开远程 shell。 -L 表示端口转发的本地端口 33306将被转发到远程服务器的本地端口 3306。

3. 配置 MySQL 数据库连接

在 Java 代码中使用如下配置信息连接远程 MySQL 数据库：

spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:33306/your_schema?autoReconnect=true&useSSL=false
spring.datasource.username=your_root_user_name
spring.datasource.password=your_root_password

spring.datasource.url 中的 localhost:33306 是转发后的本地端口号，your_schema 是你要连接的数据库名称。

示例

下面给出两个示例说明。

示例 1

一个名为 SSHDatabaseConnection 的类，连接远程的 MySQL 数据库，使用 Spring 框架的 JDBC 与数据库进行交互。代码如下：

import org.springframework.jdbc.datasource.DriverManagerDataSource;

public class SSHDatabaseConnection {
    public static void main(String[] args) {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:33306/your_schema?autoReconnect=true&useSSL=false");
        dataSource.setUsername("your_root_user_name");
        dataSource.setPassword("your_root_password");
        // ... 使用 Spring JDBC 进行相应的数据库操作 ...
    }
}

示例 2

使用 Mybatis 框架连接远程的 MySQL 数据库。代码中使用的是 Spring Boot 框架启动的应用。

import org.apache.ibatis.session.SqlSession;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.sql.DataSource;

@Service
public class UserService {
    @Autowired private DataSource dataSource;

    @Autowired private DataSourceTransactionManager dataSourceTransactionManager;

    @Autowired private MybatisSqlSessionFactoryBean mybatisSqlSessionFactoryBean;

    @Transactional
    public User getUser(long id) {
        SqlSession sqlSession = mybatisSqlSessionFactoryBean.getObject().openSession(true);
        try {
            // 获取 mapper 实例
            UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
            return userMapper.findById(id);
        } finally {
            sqlSession.close();
        }
    }
}

其中的 DataSource 和 DataSourceTransactionManager 的配置与示例 1 中相同，这里不再赘述。MybatisSqlSessionFactoryBean 是 Mybatis 框架提供的一个工厂 Bean，其配置如下：

import org.mybatis.spring.SqlSessionFactoryBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.Resource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.stereotype.Component;
import javax.sql.DataSource;
import java.io.IOException;

@Component
public class MybatisSqlSessionFactoryBean extends SqlSessionFactoryBean {
    @Autowired private DataSource dataSource;
    @Override
    public void afterPropertiesSet() throws Exception {
        PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        try {
            // 扫描 Mybatis 配置文件
            Resource[] resources = resolver.getResources("classpath:/mybatis/mapper/*.xml");
            setDataSource(dataSource);
            setMapperLocations(resources);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }
}

这里将 Mybatis 的 mapper 配置文件放到 classpath:/mybatis/mapper/ 目录下。Mybatis 的 mapper 配置文件与 Java 定义的 DAO 接口对应，所以还需要一个名为 UserMapper 的接口：

public interface UserMapper {
    User findById(long id);
}

这个接口对应的查询语句需要写在 classpath:/mybatis/mapper/UserMapper.xml 文件中。

到此为止，我们就完成了使用 Java SSH 秘钥连接 MySQL 数据库的方法的攻略了。