记录一次解决数据库连接池连接泄露BUG

1 BUG现象

系统并发请求，系统停滞无法使用，所有接口都是无法与后端进行交互的状态，系统并没有宕机
2 BUG的业务流程

• 插入分数方法 涉及插入表ABCD 加了声明式事务
  
• 查询分数方法 涉及表ABCD
  

1. controller() {
2.         @Transactional
3.         insertVo();
4.         selectById();
5. }

复制代码

3 排查原因

因为代码不是我写的，一开始我就是怀疑是死锁导致的BUG，然后我用Jconsole，去检测一下死锁，并没有发现死锁，接下来我去Mysql看有没有死锁，结果也没有发现，然后我就懵了，jvm没有锁，mysql也没有锁且没有SQL在执行，为什么请求就会全注阻塞？
然后我去开始去看这个代码了，我发现他在控制层调用了两个业务层，通常我们只在控制层去做校验去调用一个service啊，然后我就继续看，insertVo插入了很多查询了很多，耗时3秒钟左右，selectById查询了一条SQL，这两个明面上的代码并没有什么加锁或什么飞天操作，想了半天搞不懂为什么。
然后我开始用排除法，把这些代码一一注释调试一下。我把insertVo注释掉，这个毋庸置疑，那只有一个简单的操作了，就查一表返回，这个绝对是没问题的，然后我把selectById注释掉，居然就好了？,selectById只有一条查询SQL啊也没有加锁，这个能解决但是肯定也不是这个原因。
然后我用druid监控到可使用连接数一直在占用，没有释放，我就去查druid配置，发现配置了

1. initial-size: 20 #初始大小
2. min-idle: 20 #最小空闲
3. max-active: 40 #最大链接
4. max-wait: 10000 #配置获取连接等待超时的时间

复制代码

这个配置也没有毛病啊，没办法了我只能去看线程的具体信息了，查出来所有的线程池连接线程都是这样的

1. "pool-6-thread-10" #244 prio=5 os_prio=31 tid=0x00007fe94235f000 nid=0x22803 waiting on condition [0x00000003150ce000]
2.    java.lang.Thread.State: WAITING (parking)
3.         at sun.misc.Unsafe.park(Native Method)
4.         - parking to wait for  <0x00000006c109e090> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
5.         at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
6.         at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
7.         at com.alibaba.druid.pool.DruidDataSource.takeLast(DruidDataSource.java:2315)
8.         at com.alibaba.druid.pool.DruidDataSource.getConnectionInternal(DruidDataSource.java:1781)
9.         at com.alibaba.druid.pool.DruidDataSource.getConnectionDirect(DruidDataSource.java:1494)
10.         at com.alibaba.druid.filter.FilterChainImpl.dataSource_connect(FilterChainImpl.java:5058)
11.         at com.alibaba.druid.filter.stat.StatFilter.dataSource_getConnection(StatFilter.java:704)
12.         at com.alibaba.druid.filter.FilterChainImpl.dataSource_connect(FilterChainImpl.java:5054)
13.         at com.alibaba.druid.filter.FilterAdapter.dataSource_getConnection(FilterAdapter.java:2759)
14.         at com.alibaba.druid.filter.FilterChainImpl.dataSource_connect(FilterChainImpl.java:5054)
15.         at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:1469)
16.         at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:1459)
17.         at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:83)
18.         at org.hibernate.engine.jdbc.connections.internal.DatasourceConnectionProviderImpl.getConnection(DatasourceConnectionProviderImpl.java:122)
19.         at org.hibernate.internal.NonContextualJdbcConnectionAccess.obtainConnection(NonContextualJdbcConnectionAccess.java:38)
20.         at org.hibernate.resource.jdbc.internal.LogicalConnectionManagedImpl.acquireConnectionIfNeeded(LogicalConnectionManagedImpl.java:104)
21.         at org.hibernate.resource.jdbc.internal.LogicalConnectionManagedImpl.getPhysicalConnection(LogicalConnectionManagedImpl.java:134)
22.         at org.hibernate.resource.jdbc.internal.LogicalConnectionManagedImpl.getConnectionForTransactionManagement(LogicalConnectionManagedImpl.java:250)
23.         at org.hibernate.resource.jdbc.internal.LogicalConnectionManagedImpl.begin(LogicalConnectionManagedImpl.java:258)
24.         at org.hibernate.resource.transaction.backend.jdbc.internal.JdbcResourceLocalTransactionCoordinatorImpl$TransactionDriverControlImpl.begin(JdbcResourceLocalTransactionCoordinatorImpl.java:246)
25.         at org.hibernate.engine.transaction.internal.TransactionImpl.begin(TransactionImpl.java:83)
26.         at org.springframework.orm.jpa.vendor.HibernateJpaDialect.beginTransaction(HibernateJpaDialect.java:184)
27.         at org.springframework.orm.jpa.JpaTransactionManager.doBegin(JpaTransactionManager.java:402)
28.         at org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java:376)
29.         at org.springframework.transaction.interceptor.TransactionAspectSupport.createTransactionIfNecessary(TransactionAspectSupport.java:572)
30.         at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:360)
31.         at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:99)
32.         at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
33.         at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:747)
34.         at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:95)
35.         at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
36.         at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:747)
37.         at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689)
38.         at com.treach.platform.modules.service.impl.SysLogService$$EnhancerBySpringCGLIB$$36a85251.insert(<generated>)
39.         at com.treach.platform.log.factory.LogTaskFactory$2.run(LogTaskFactory.java:56)
40.         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
41.         at java.util.concurrent.FutureTask.run(FutureTask.java:266)
42.         at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
43.         at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
44.         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
45.         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
46.         at java.lang.Thread.run(Thread.java:750)
48.    Locked ownable synchronizers:
49.         - <0x00000007741f0d68> (a java.util.concurrent.ThreadPoolExecutor$Worker)

复制代码

是的，连接池连接一直被占用锁住了，为什么会被锁住呢？，也设置了连接等待超时时间啊，然后我怀疑是配置没有生效，写了个代码看看

1. public static void main(String[] args) throws SQLException {
2.         ConfigurableApplicationContext run = SpringApplication.run(NdCyApplication.class, args);
3.         DruidDataSource bean = run.getBean(DruidDataSource.class);
5.         int maxActive = bean.getMaxActive();
6.         long maxWait = bean.getMaxWait();
7.         log.info("数据库线程池与数据库最大链接数" + String.valueOf(maxActive));
8.         log.info("数据库线程池等待链接数超时时间"+String.valueOf(maxWait));
9.     }

复制代码

结果：

1. 数据库线程池与数据库最大链接数8
2. 数据库线程池等待链接数超时时间-1

复制代码

这个和配置的不一样啊，真的没有生效，然后我又去查为什么没有生效，原来配置类里面有个DataSoure

1. @Bean     //声明其为Bean实例
2. @Primary  //在同样的DataSource中，首先使用被标注的DataSource
3. @ConfigurationProperties(prefix = "spring.datasource")
4. public DruidDataSource dataSource(){
5.         DruidDataSource datasource = new DruidDataSource();
6.         List<Filter> filters = new ArrayList<>();
7.         filters.add(wallFilter);
8.         filters.add(new StatFilter());
9.         datasource.setProxyFilters(filters);
10.         return datasource;
11. }

复制代码

我们applcation.yaml的配置被覆盖了，druid默认等待链接数超时时间-1，难怪长时间占用连接没有超时。
4 解决

把等待连接超时时间等设置上

1. @Bean     //声明其为Bean实例
2. @Primary  //在同样的DataSource中，首先使用被标注的DataSource
3. @ConfigurationProperties(prefix = "spring.datasource")
4. public DruidDataSource dataSource(){
5.         DruidDataSource datasource = new DruidDataSource();
6.         datasource.setInitialSize(20);
7.         datasource.setMaxActive(80);
8.         datasource.setMaxWait(5000);
9.         List<Filter> filters = new ArrayList<>();
10.         filters.add(wallFilter);
11.         filters.add(new StatFilter());
12.         datasource.setProxyFilters(filters);
13.         return datasource;
14. }

复制代码

成功
5 不懂的点

为什么会出现不回收线程的情况 按理来说现在没有SQL在执行，连接数不是会被回收吗 回到线程池 等待的线程就有连接了 就能不卡死了 为什么呢？

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！