2

我正在使用 hikaricp（这可能也适用于任何其他数据库连接池）。我有一个 DBPool 类，我在其中实例化了一个 HikariDataSource（使用 HikariConfig 对象）。我正在使用此 DBPool 的惰性持有者习语来限制每个 VM 一个池实例。但是，一旦获得对池的引用，您就可以检索 Connection 对象（无需任何进一步的锁/同步/信号量检查），因为我认为连接池会处理我的连接对象限制。每次我通过 DBPool 获得连接引用时，我都会在连接/preparedstatement/resultset 上调用 close。如果这导致问题，我可以尝试使用资源。我在日志中观察到以下内容：

2014-09-14 18:53:25,302 WARN c.z.h.p.LeakTask [Hikari Housekeeping Timer (pool testHikariCp)] Connection leak detection triggered, stack trace follows java.lang.Exception
        at com.akkadian.db.DBConnPool.getConnection(DBConnPool.java:67)
        at models.tester.storeload.testAlertLogStoreLoad.loadAll(testAlertChk.java:101)
        at com.testLib.map.MapStoreWrapper.loadAll(MapStoreWrapper.java:131)
        at com.testLib.map.mapstore.AbstractMapDataStore.loadAll(AbstractMapDataStore.java:40)
        at com.testLib.map.BasicRecordStoreLoader$MapLoadAllTask.run(BasicRecordStoreLoader.java:340)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at com.testLib.util.executor.CompletableFutureTask.run(CompletableFutureTask.java:57)
        at com.testLib.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:209)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
        at com.testLib.util.executor.testLibManagedThread.executeRun(testLibManagedThread.java:76)
        at com.testLib.util.executor.testLibManagedThread.run(testLibManagedThread.java:92)

我增加了连接超时并将leakDetectionthreshold设置如下：

     hikariConfig.setConnectionTimeout(90000); 
     hikariConfig.setLeakDetectionThreshold(10000);

即使不建议这样做，我也增加了池的大小——我不得不测试各种选项，因为我收到了来自数据库的连接超时。

4

1 回答 1

1

确保您确实将连接释放回池？您可以使用资源尝试（除了 Brett 提到的增加阈值）：

try (Connection conn = DBConnectionPool.getConnection(); 
        PreparedStatement ps = conn.prepareStatement(preparedQuery);) {

和结果集（因为某些驱动程序/数据库在清除连接时可能不会清除结果集，尽管不确定这是否对新的驱动程序/数据库仍然有效，但我不确定您使用的是什么）：

尝试（结果集 rs = ps.executeQuery();) {

如果需要，请增加泄漏检测阈值，但我认为如果必须将其设置得太大，则存在需要修复的问题。

于 2014-09-16T20:29:29.987 回答