项目在线上环境测试时发现一个问题,就是如果数据库关闭了,然后重启,获取数据库连接一直是超时状态。网上查了很多资料,才知道了原因,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 = (dsId);
if(checkDataSourceFailContinuousStatus(dataSource)){
//连接池创建连接线程已死亡,关闭连接池,重新创建连接池
(dsId);
dataSource = (dsId);
if (dataSource == null) {
throw new DutyRuntimeException("数据库连接为空");
}
}
return ();
}
//检测线程是否存活
public static boolean checkDataSourceFailContinuousStatus(DruidDataSource dataSource) {
if (!()) {
//("this data source does not open `BreakAfterAcquireFailure`");
return false;
}
boolean failContinuous = (); // fail over retry attempts
boolean createConnectionThreadIsAlive = true;
try {
createConnectionThread = getCreateConnectionThread(dataSource);
createConnectionThreadIsAlive = ();
} catch (Exception e) {
//("Get dataSource: " + dataSource + "'s createConnectionThread fails.");
}
return failContinuous && !createConnectionThreadIsAlive;
}
public static getCreateConnectionThread(DruidDataSource dataSource)
throws NoSuchFieldException, IllegalAccessException {
Field createConnectionThread = ().getDeclaredField("createConnectionThread");
(true);
createConnectionThreadInstance = () createConnectionThread
.get(dataSource);
/*("Get dataSource: {}'s createConnectionThread: {}", dataSource,
createConnectionThreadInstance);*/
return createConnectionThreadInstance;
}
参考地址:/p/db46e8b3fd41