Updated 如何定位Druid连接池的连接泄漏问题？.md (markdown)

+## 3.2 powerjob连接泄露日志

+

+a、为什么连接没还

+这是 Druid 连接池检测到的“连接泄露”（abandon connection），泄露点就在

+com.sie.snest.job.worker.processors.StandaloneProcessor.process(StandaloneProcessor.java:161)。

+根本原因是：

+线程 powerjob-worker-light-task-execute-4 从 Druid 借走一条连接；

+随后该线程进入 CompletableFuture.get() 无限等待（WAITING），一直不 close() 连接；

+Druid 的 DestroyTask 在超时后强制回收，于是打出 abandon 日志。

+

+```

+2025-09-20 17:13:46.429 [Druid-ConnectionPool-Destroy-221036634] ERROR com.alibaba.druid.pool.DruidDataSource -abandon connection, owner thread: powerjob-worker-light-task-execute-4, connected at : 1758359324553, open stackTrace

+ at java.lang.Thread.getStackTrace(Thread.java:1559)

+ at com.alibaba.druid.pool.DruidDataSource.getConnectionDirect(DruidDataSource.java:1498)

+ at com.alibaba.druid.filter.FilterChainImpl.dataSource_connect(FilterChainImpl.java:5059)

+ at com.alibaba.druid.filter.stat.StatFilter.dataSource_getConnection(StatFilter.java:726)

+ at com.alibaba.druid.filter.FilterChainImpl.dataSource_connect(FilterChainImpl.java:5055)

+ at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:1407)

+ at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:1399)

+ at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:100)

+ at com.sie.snest.engine.db.relationdb.RelationDBAccessor.<init>(RelationDBAccessor.java:188)

+ at com.sie.snest.engine.db.relationdb.TransactionRelationDBAccessor.<init>(TransactionRelationDBAccessor.java:40)

+ at com.sie.snest.engine.a.a.getNewAccessorFromDataSource(AbstractDataSourceStrategy.java:126)

+ at com.sie.snest.engine.a.a.getDbAccessor(AbstractDataSourceStrategy.java:109)

+ at com.sie.snest.engine.a.h.getRelationDBAccessor(ModelMetaDataSourceStrategy.java:59)

+ at com.sie.snest.engine.a.h.getRelationDBAccessor(ModelMetaDataSourceStrategy.java:32)

+ at com.sie.snest.engine.data.access.BussModelDataAccess.getRelationDBAccessor(BussModelDataAccess.java:135)

+ at com.sie.snest.engine.db.relationdb.FilterExpression.<init>(FilterExpression.java:443)

+ at com.sie.snest.engine.data.access.BussModelDataAccess.a(BussModelDataAccess.java:2385)

+ at com.sie.snest.engine.data.access.BussModelDataAccess.search(BussModelDataAccess.java:601)

+ at sun.reflect.GeneratedMethodAccessor397.invoke(Unknown Source)

+ at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

+ at java.lang.reflect.Method.invoke(Method.java:498)

+ at com.sie.snest.engine.model.MethodMeta.execute(MethodMeta.java:274)

+ at com.sie.snest.engine.model.MethodMeta.invoke(MethodMeta.java:197)

+ at com.sie.snest.engine.data.RecordSet.callSuper(RecordSet.java:476)

+ at com.sie.snest.sdk.db.DbUtils.search(DbUtils.java:388)

+ at com.sie.snest.sdk.BaseModel.search(BaseModel.java:351)

+ at com.sie.snest.job.worker.model.JobInfo.search(JobInfo.java:282)

+ at com.sie.snest.job.worker.model.JobInfo$$EnhancerByCGLIB$$edeee016.CGLIB$search$16(<generated>)

+ at com.sie.snest.job.worker.model.JobInfo$$EnhancerByCGLIB$$edeee016$$FastClassByCGLIB$$e58b7ebf.invoke(<generated>)

+ at net.sf.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228)

+ at com.sie.snest.engine.model.ModelInterceptor.intercept(ModelInterceptor.java:84)

+ at com.sie.snest.job.worker.model.JobInfo$$EnhancerByCGLIB$$edeee016.search(<generated>)

+ at sun.reflect.GeneratedMethodAccessor562.invoke(Unknown Source)

+ at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

+ at java.lang.reflect.Method.invoke(Method.java:498)

+ at com.sie.snest.engine.model.MethodMeta.execute(MethodMeta.java:274)

+ at com.sie.snest.engine.model.MethodMeta.invoke(MethodMeta.java:204)

+ at com.sie.snest.engine.api.distributed.MethodMetaInvoker.invokeFirstMethod(MethodMetaInvoker.java:23)

+ at com.sie.snest.engine.api.distributed.RpcInvocationV2.invoke(RpcInvocationV2.java:168)

+ at com.sie.snest.engine.data.RecordSet.call(RecordSet.java:360)

+ at com.sie.snest.sdk.db.DbUtils.select(DbUtils.java:341)

+ at com.sie.snest.sdk.BaseModel.select(BaseModel.java:314)

+ at com.sie.snest.job.worker.processors.StandaloneProcessor.process(StandaloneProcessor.java:89)

+ at tech.powerjob.worker.core.tracker.task.light.LightTaskTracker.processTask(LightTaskTracker.java:213)

+ at java.util.concurrent.FutureTask.run(FutureTask.java:266)

+ at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

+ at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

+ at java.lang.Thread.run(Thread.java:748)

+ownerThread current state is WAITING, current stackTrace

+ at sun.misc.Unsafe.park(Native Method)

+ at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)

+ at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1693)

+ at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)

+ at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1729)

+ at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)

+ at com.sie.snest.job.worker.processors.StandaloneProcessor.process(StandaloneProcessor.java:161)

+ at tech.powerjob.worker.core.tracker.task.light.LightTaskTracker.processTask(LightTaskTracker.java:213)

+ at tech.powerjob.worker.core.tracker.task.light.LightTaskTracker$$Lambda$2051/1714736853.call(Unknown Source)

+ at java.util.concurrent.FutureTask.run(FutureTask.java:266)

+ at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

+ at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

+ at java.lang.Thread.run(Thread.java:748)

+```

+