连接池泄漏原因

Question

我的连接池一直遇到（我认为）问题。 具体来说，我的日志显示了以下消息：

org.apache.tomcat.dbcp.pool2.impl.DefaultPooledObject$AbandonedObjectCreatedException: 以下代码创建的池化对象 [时间] 尚未返回到池中

我检查了日志显示的堆栈跟踪中列出的方法，但找不到罪魁祸首（我总是在每个方法的末尾关闭 ResultSet、PreparedStatement 和 Connection）。

我有一个执行两个查询的方法，也许我没有正确执行它。

它的布局如下：

ConnectionPool pool = ConnectionPool.getInstance();
Connection connection = pool.getConnection();
PreparedStatement ps = null;
PreparedStatement rowsPs = null;
ResultSet rs = null;
ResultSet rowsRs = null;

String query = "SELECT SQL_CALC_FOUND_ROWS ...";
String totalRowsQuery = "SELECT FOUND_ROWS() AS RowCount";

try {
    ps = connection.prepareStatement(query);
    [set ps params]
    rs = ps.executeQuery();
    [process rs]

    rowsPs = connection.prepareStatement(totalRowsQuery);
    rowsRs = rowsPs.executeQuery();
    [process rowsRs]
} catch (SQLException e) {
    [handle e]
} finally {
    DBUtil.closeResultSet(rs);
    [close rowsRs]
    [close ps]
    [close rowsPs]
    [close connection]
}

DBUtils 方法的一个例子是：

public static void closeResultSet(ResultSet rs)
{
    try
    {
        if (rs != null)
            rs.close();
    }
    catch (SQLException sqle)
    {
        sqle.printStackTrace();
    }
}

这种方法的总体布局看起来不错吗？我应该以不同的方式处理连接吗？还是其他导致错误被记录的方法？

谢谢。

其他信息

我也收到了SQLException：

java.sql.SQLException: Connection com.mysql.jdbc.JDBC4Connection@[some number] is closed

在线：rowsPs = connection.prepareStatement(totalRowsQuery);

意味着在某处之前，连接已关闭。 我没有在任何地方明确关闭连接。 是否有可能调用的其他一些数据访问方法以某种方式关闭了此方法中的连接？ （pool.getConnection() 打电话给dataSource.getConnection()）

更新： 我已尝试按照建议使用 try-with-resources，但问题仍然存在。

上面第一个代码sn-p中引用的ConnectionPool类：

public class ConnectionPool 
{

    private static ConnectionPool pool = null;
    private static DataSource dataSource = null;

    public synchronized static ConnectionPool getInstance()
    {

        if ( pool == null ) {
            pool = new ConnectionPool();
        }
            return pool;
    }

    private ConnectionPool()
    {
        try {
            InitialContext ic = new InitialContext();
            dataSource = (DataSource) 
                    ic.lookup([jdbc/dbName]);
        }

        catch (Exception e) {
            e.printStackTrace();
        } 
    }

    public Connection getConnection()
    {
        try {
            return dataSource.getConnection();
        }
        catch (SQLException sqle) {
            sqle.printStackTrace();
            return null;
        }
    }
    public void freeConnection(Connection c)
    { 
        try {
            c.close();
        }
        catch (SQLException sqle) {
            sqle.printStackTrace();
        }
    }
}

更多来源： 我的池资源元素：

<Resource auth="Container" driverClassName="com.mysql.jdbc.Driver"  
            logAbandoned="true" maxActive="100" maxIdle="30" maxWait="10000" 
            removeAbandonedOnBorrow="true" 
            removeAbandonedTimeout="60" type="javax.sql.DataSource" 
            testWhileIdle="true" testOnBorrow="true" 
            validationQuery="SELECT 1 AS dbcp_connection_test"/>

更新： 我已经打开了慢查询日志，但是尽管再次抛出Exceptions，慢查询日志没有记录任何内容（没有查询需要超过 10 秒）。

所以看起来查询花费的时间不超过 60 秒。

仍然不确定是什么原因造成的。

Answer 1

这两行需要 60 多秒，因此连接池决定您的连接被放弃并关闭它。稍后您的代码尝试使用连接，但它已被连接池取消。

rs = ps.executeQuery();
[process rs]

既然您确定它不长 executeQuery()，请使用连接/线程/请求 ID 和 [process rs] 部分的时间进行调试打印。如果您看到这部分的时间超过 50 秒，您应该优化 [process rs] 或读取数据并将它们存储在内存中，然后再进行处理。

Answer 2

尝试将 removeAbandonedTimeout 值减小到 20 或 15 之类的值。您的 maxWait 为 10 秒，但如果连接被放弃，那么您将等待 60 秒再返回它们。

请注意，这不是解决方案，而只是测试您的连接是否真的挂起。

Answer 3

mysql 服务器是否超时连接？这也可能是内核问题，如果连接长时间处于空闲状态，则底层 tcp 连接可能会被终止。

Answer 4

作为使用池化 JDBC 连接时的一般经验法则：

1. 不要在每个连接上同时打开多个 ResultSet。在打开第二个之前关闭第一个 ResultSet 及其关联的 Statement。

2. 始终按照您创建资源的相反顺序关闭资源：create(s1)->execute(r1)->close(r1)->close(s1)->create(s2)->执行(r2)->关闭(r2)->关闭(s2)

3. 确保长时间运行的查询处理不超过池允许的最大连接寿命。

4. 即使您没有超过最大连接寿命，也可能由于网络链接中的小中断而丢失连接。