时间戳

首页 > 解决方案 > 本地和远程连接池，Java DBCP

java - 本地和远程连接池，Java DBCP

问题描述

我有以下用例：我有一个需要使用两个不同连接池的系统，一个用于“本地”数据库（表示在本地计算机上运行的数据库），另一个是“远程”数据库。（表示在远程不同服务器上运行的数据库）

远程数据库是配置共享数据库，而本地数据库是不同类型的数据。

我创建了两个类以连接到这些数据库：

public class ConnectionPool {

    private static BasicDataSource ds = createNewDatasource();

    private static BasicDataSource createNewDatasource() {
        BasicDataSource ds = new BasicDataSource();

        String url = "jdbc:mysql://127.0.0.1:3306/SOME_DB"
        ds.setUrl(url);
        ds.setUsername(...);
        ds.setPassword(...);

        return ds;
    }

    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

}

另一个类看起来完全一样，只是它被称为 RemoteConnection 并且 url 更改为：

String url = "jdbc:mysql://<REMOTE_IP>:3306/SOME_DB_2"

运行上述课程，我在日志中不断收到以下消息：

ERROR (RemoteConnection.java:40) - Failed on getConnection
java.sql.SQLException: Cannot create PoolableConnectionFactory (Access denied for user '...'@'<MACHINE_LOCAL_IP>' (using password: YES))
at org.apache.commons.dbcp2.BasicDataSource.createPoolableConnectionFactory(BasicDataSource.java:2291)
at org.apache.commons.dbcp2.BasicDataSource.createDataSource(BasicDataSource.java:2038)
at org.apache.commons.dbcp2.BasicDataSource.getConnection(BasicDataSource.java:1533)
at Censored.RemoteConnection.getConnection(RemoteConnection.java:59)
...
Caused by: java.sql.SQLException: Access denied for user '...'@'<MACHINE_LOCAL_IP>' (using password: YES)
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:965)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3973)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3909)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:873)
at com.mysql.jdbc.MysqlIO.proceedHandshakeWithPluggableAuthentication(MysqlIO.java:1710)
at com.mysql.jdbc.MysqlIO.doHandshake(MysqlIO.java:1226)
at com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2188)
at com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2219)
at com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2014)
at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:776)
at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:47)
at sun.reflect.GeneratedConstructorAccessor31.newInstance(Unknown Source)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:57)
at java.lang.reflect.Constructor.newInstance(Constructor.java:437)
at com.mysql.jdbc.Util.handleNewInstance(Util.java:425)
at com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:386)
at com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:330)
at org.apache.commons.dbcp2.DriverConnectionFactory.createConnection(DriverConnectionFactory.java:39)
at org.apache.commons.dbcp2.PoolableConnectionFactory.makeObject(PoolableConnectionFactory.java:256)
at org.apache.commons.dbcp2.BasicDataSource.validateConnectionFactory(BasicDataSource.java:2301)
at org.apache.commons.dbcp2.BasicDataSource.createPoolableConnectionFactory(BasicDataSource.java:2287)
...

首先，上面的错误很奇怪。我从来没有使用过机器本地IP。所以我不明白它是从哪里来的。此外，这似乎不是特权问题，因为我尝试通过 cli 登录远程数据库，使用：

mysql -u'...' -p'...' -h <REMOTE_IP> SOME_DB_2

并且连接成功。对我来说，它闻起来像是 JDBC 驱动程序或连接定义问题，但我似乎找不到问题所在。

知道我做错了什么吗？

标签： javamysqldatabase-connectionconnection-pooling

解决方案

我发现了问题。这是一个 SSL 问题。我使用的用户必须使用 SSL 证书连接。

这也是我在错误中看到本地机器IP的原因。

一种检查方法是：

Select * from mysql.user where user='...';

我发现的是：

ssl_type != ''

所以我必须定义：

jdbc:mysql://<REMOTE_IP>:3306/SOME_DB_2&useSSL=true

配置相关证书，一切正常。

推荐阅读