一尘不染

JDBC MySql连接池实践可避免连接池耗尽

mysql

我在GlassFish上有一个Java-JSF
Web应用程序,我想在其中使用连接池。因此,我创建了一个有application范围的Bean,可与Connection其他Bean的实例一起使用:

public class DatabaseBean {

    private DataSource myDataSource;

    public DatabaseBean() {
        try {
            Context ctx = new InitialContext();
            ecwinsDataSource = (DataSource) ctx.lookup("jdbc/myDataSource");
        } catch (NamingException ex) {
            ex.printStackTrace();
        }
    }

    public Connection getConnection() throws ClassNotFoundException, SQLException, InstantiationException, IllegalAccessException {
        Connection connection = myDataSource.getConnection();
        System.out.println("Succesfully connected: " + connection);
        //Sample: Succesfully connected: com.sun.gjc.spi.jdbc40.ConnectionHolder40@7fb213a5
        return connection;
    }
}

这样,连接池很快就会被填满。在“ db-related”视图中进行几次导航后,应用程序将停止以下操作:

RAR5117:无法从连接池[mysql_testPool]获取/创建连接。原因:使用中的连接等于最大池大小和已过期的最大等待时间。无法分配更多连接。RAR5114:分配连接时出错:[分配连接时出错。原因:使用中的连接等于最大池大小和过期的最大等待时间。无法分配更多的连接。]
java.sql.SQLException:分配连接时出错。原因:使用中的连接等于最大池大小和过期的最大等待时间。无法分配更多连接。

我将关闭每种方法的连接和其他资源。该应用程序可以通过独立连接正常运行。

我究竟做错了什么?任何提示或建议,将不胜感激。


阅读 859

收藏
2020-05-17

共1个答案

一尘不染

异常表明应用程序代码的典型情况是数据库连接泄漏。你需要确保你获得 关闭所有的人(ConnectionStatement
ResultSet)在try-with- resources按照正常的JDBC成语在非常相同的方法块的块。

public void create(Entity entity) throws SQLException {
    try (
        Connection connection = dataSource.getConnection();
        PreparedStatement statement = connection.prepareStatement(SQL_CREATE);
    ) { 
        statement.setSomeObject(1, entity.getSomeProperty());
        // ...
        statement.executeUpdate();
    }
}

或者,当您不使用Java 7时,请执行以下try-finally步骤。关闭它们finally将保证在有例外情况下也将它们关闭。

public void create(Entity entity) throws SQLException {
    Connection connection = null;
    PreparedStatement statement = null;

    try { 
        connection = dataSource.getConnection();
        statement = connection.prepareStatement(SQL_CREATE);
        statement.setSomeObject(1, entity.getSomeProperty());
        // ...
        statement.executeUpdate();
    } finally {
        if (statement != null) try { statement.close(); } catch (SQLException logOrIgnore) {}
        if (connection != null) try { connection.close(); } catch (SQLException logOrIgnore) {}
    }
}

是的,即使使用连接池,您仍然需要自己关闭连接。初学者常见的错误是,他们认为它将自动处理结局。这是 不正确的
。连接池即返回包装的连接,该连接在close()中执行以下操作:

public void close() throws SQLException {
    if (this.connection is still eligible for reuse) {
        do not close this.connection, but just return it to pool for reuse;
    } else {
        actually invoke this.connection.close();
    }
}

不关闭它们将导致连接不会释放回池以供重用,因此它将一次又一次获取新的连接,直到数据库用尽连接,这将导致应用程序崩溃。

也可以看看:

2020-05-17