关于Druid连接池遇到数据库挂了，重启遇到的问题解决方法 |
您所在的位置：网站首页 › 数据库连接失败怎么办恢复不了 › 关于Druid连接池遇到数据库挂了，重启遇到的问题解决方法 |
|
项目在线上环境测试时发现一个问题，就是如果数据库关闭了，然后重启，获取数据库连接一直是超时状态。网上查了很多资料，才知道了原因，Druid数据库连接池配置中的BreakAfterAcquireFailure属性设置为true就可能会出现数据库关闭重启，一直获取不到连接。 BreakAfterAcquireFailure是设置是否失败重连,默认为false。 false表示新的请求都会尝试去数据库请求connection，但是当获取不到连接的时候，Druid将会无限的打印获取不到连接的异常信息。 true表示向数据库请求连接失败后,就算数据库恢复正常也不进行重连,客户端对pool的请求都拒绝掉。当该参数为true的时候，当多次重试之后无法获取连接，DruidDataSource中的CreateConnectionThread线程就会因为 代码中的break 而跳出自己的for循环获取连接的机制而导致生命终结，通过jstack可以看到里面是没有该线程的信息的，所以该线程是已经死掉了，通过日志排查CreateConnectionThread确实是有终结前的日志信息。因为创建连接的线程已经死掉了，那后续肯定是无法创建出新的连接的。 但是我们又不能将breakAfterAcquireFailure设置为false，因为这将在无法获取连接的时候产生无限的错误日志。 所以解决方案是每次获取连接时判断检测下该线程的状态，如果该线程已经死掉，则直接close连接池，然后重新创建。 CreateConnectionThread 的存活检测机制： public Connection getJdbcConnection(Integer dsId) throws SQLException { //获取数据库连接池 DruidDataSource dataSource = this.dataSourceMap.get(dsId); if(checkDataSourceFailContinuousStatus(dataSource)){ //连接池创建连接线程已死亡，关闭连接池，重新创建连接池 this.refreshJdbcDataSource(dsId); dataSource = this.dataSourceMap.get(dsId); if (dataSource == null) { throw new DutyRuntimeException("数据库连接为空"); } } return dataSource.getConnection(); } //检测线程是否存活 public static boolean checkDataSourceFailContinuousStatus(DruidDataSource dataSource) { if (!dataSource.isBreakAfterAcquireFailure()) { //log.info("this data source does not open `BreakAfterAcquireFailure`"); return false; } boolean failContinuous = dataSource.isFailContinuous(); // fail over retry attempts boolean createConnectionThreadIsAlive = true; try { DruidDataSource.CreateConnectionThread createConnectionThread = getCreateConnectionThread(dataSource); createConnectionThreadIsAlive = createConnectionThread.isAlive(); } catch (Exception e) { //log.error("Get dataSource: " + dataSource + "'s createConnectionThread fails."); } return failContinuous && !createConnectionThreadIsAlive; } public static DruidDataSource.CreateConnectionThread getCreateConnectionThread(DruidDataSource dataSource) throws NoSuchFieldException, IllegalAccessException { Field createConnectionThread = dataSource.getClass().getDeclaredField("createConnectionThread"); createConnectionThread.setAccessible(true); DruidDataSource.CreateConnectionThread createConnectionThreadInstance = (DruidDataSource.CreateConnectionThread) createConnectionThread .get(dataSource); /*log.info("Get dataSource: {}'s createConnectionThread: {}", dataSource, createConnectionThreadInstance);*/ return createConnectionThreadInstance; }参考地址：https://www.jianshu.com/p/db46e8b3fd41 |
今日新闻 |
点击排行 |
|
推荐新闻 |
图片新闻 |
|
专题文章 |
| CopyRight 2018-2019 实验室设备网 版权所有 win10的实时保护怎么永久关闭 |