产生源头
数据库连接池中的连接长时间空闲着(出现在数据库连接闲置一夜或者小网站长时间无人访问)超过了 8 小时,MySQL 会自动将其断开,连接失效,但这时数据库连接池并不知道,依旧使用,就出现了异常,总的来说有:
CommunicationsException: Communications link failure 连接失效
Broken pipe (Write failed) 连接损坏
MySQLNonTransientConnectionException: No operations allowed after connection closed 在连接关闭后依旧操作
◉ 查看连接状态
使用 show processlist
查看连接状态时:
注意到表中的 Time 这一栏,是数据库存在的时间
其单位是 秒(s),默认最长时间为 8 小时,也就是 28800 秒,超过这个时间连接将失效
◉ 解决过程:
查了很多网上的做法,就是将失效时间修改得长一点
默认的 wait_timeout
值为 28800
,改动它可以让连接活得久一点
但个人感觉这并不是好办法,如果能在连接失效时检查出来,再替换成新的连接,不就解决问题了吗
失败方法:
过程中我使用了数据库连接 Connection
的 isClosed()
方法,却发现这并不能检查出是否失效,这是因为该连接并没有被关闭,只是失效了而已,之后又使用了 isValid()
,很遗憾同样不生效
解决方法:
既然连接的关闭依赖的是时间,那就将连接创建时的时间记录下来
而后在每次使用前检查该连接到现在的时间差,是否超过 8 个小时
如果大于 8 小时,则将数据库连接池中的连接清空,重新换一批新的
下面以 4 小时为例子:
private final List<Connection> connPool = new LinkedList<>();
private int maxFreeConnections = 10;
private long lastTime;
private static final int OVER_TIME = 4 * 60 * 60;
@Override
public Connection getConnection() throws SQLException {
// 比较时间,若超时则替换连接池连接
if (Instant.now().getEpochSecond() - lastTime > OVER_TIME) {
poolLogger.info("连接超时了,重新获取 10 个连接");
clearPool();
initPool();
}
// 如果连接池为空,新建连接
if (connPool.isEmpty()) {
poolLogger.info("连接池空了,再新建 10 个连接");
initPool();
}
// 给出一个有效数据库连接
poolLogger.info("给出了一个连接,目前剩余连接数:" + (connPool.size()-1) +
" (该批连接持续服务时间:"+ (Instant.now().getEpochSecond() - lastTime) +" / "+ OVER_TIME +" s)");
return connPool.remove(0);
}
@Override
public void initPool() throws SQLException {
// 获取数据库连接并放入数据库连接池中
for (int i = 0; i < maxFreeConnections; i++) {
connPool.add(DriverManager.getConnection(URL, USER, PASSWORD));
}
// 更新此次的连接时间
lastTime = Instant.now().getEpochSecond();
poolLogger.info("新开了 10 个数据库连接");
}
@Override
public void clearPool() throws SQLException {
// 关闭连接池中的数据库连接
for (Connection conn : connPool) {
conn.close();
}
// 最后清空连接池
connPool.clear();
}
该数据库连接池为手写简陋版,其它数据库连接池不知道怎样,仅供参考
一次性更新整个连接池还是有点亏,再考虑优化吧 op
风雨兼程,奔赴我的远方(IceClean)