【SpringBoot】服务停止数据源的关闭时机

创作时间:

作者:

@小白创作中心

【SpringBoot】服务停止数据源的关闭时机

引用

来源

https://www.cnblogs.com/kukuxjx/p/18207044

在微服务架构中，数据源的管理至关重要，尤其是在服务停止时如何正确释放数据库连接。本文将深入探讨SpringBoot应用中三种常见数据源（DynamicDataSource、HikariDataSource、DruidDataSource）的连接释放机制，帮助开发者更好地理解服务停止时的数据源管理策略。

1 前言

微服务中我们会用到数据源，数据源中其实就是管理我们的数据库连接，对于数据库而言，连接数是很珍贵的资源，所以释放无用或者长时间空闲的连接显得很重要。
那么对于微服务比如我们的 SpringBoot 当服务启动的时候会初始化数据源，那么停止的时候，是如何关闭数据源，释放连接的呢？这节我们就来看看不同数据源下的连接释放时机。
这节我们主要从三种数据源看起：动态数据源（DynamicDataSource）、SpringBoot现在默认的数据源（HikariDataSource）、阿里的德鲁伊（DruidDataSource），看下三者是什么时候释放连接的。

2 释放方式

我们站在服务的角度，也就是我们的应用角度，释放时机分主动（应用主动关闭数据库连接）和被动（数据库服务关闭连接）。

2.1 被动方式

我理解的每个数据库都有自己的空闲连接或者超时连接的释放，我查了下来自（通过查阅相关资料）：

不同数据库系统的默认空闲连接超时时间设置各不相同，以下是一些常见数据库的默认空闲超时时间概览：

MySQL: 默认的空闲连接超时时间是8小时，通过wait_timeout和interactive_timeout两个变量控制。这两个变量的默认值通常是28800秒（8小时）。
PostgreSQL: PostgreSQL默认没有明确的空闲超时设置。但可以通过设置idle_in_transaction_session_timeout参数来限制处于事务中但空闲的会话时间，其默认值是0，意味着没有限制。
Microsoft SQL Server: SQL Server的默认空闲超时由连接字符串中的Connection Lifetime或Idle Timeout参数决定，或者由数据库服务器的配置设置。如果不显式设置，通常没有默认的空闲超时限制。
Oracle: Oracle数据库的空闲超时时间可以通过配置Profile来设定，特别是通过修改IDLE_TIME参数。默认情况下，如果未特别配置，Oracle可能没有固定的空闲超时时间，需要根据实际的Profile设置来确定。
OceanBase: OceanBase的默认空闲连接超时时间也是8小时，通过wait_timeout和interactive_timeout设置，类似于MySQL。另外，OceanBase还提供了ob_trx_timeout来控制事务超时时间，默认值为100000000微秒（约100秒）。

请注意，这些默认值可能会随数据库版本的不同而有所变化，且通常都可以通过数据库的配置文件或动态修改系统参数的方式来调整。在实际应用中，根据应用需求和资源管理策略，通常会根据具体情况调整这些参数。

被动方式的，我看 PGSQL 默认居然不设置，那我有疑问了，那我服务强制停止，那连接谁来释放呢？下边我会实际来操作，把它归到了主动方式里。

2.2 主动方式（正常）

主动方式我这里分开，一种是服务正常停止也叫优雅停止比如类似 kill -15，一种是非正常的比如强制停止服务类似 kill -9。

2.2.1 SpringBoot + ShutdownHook

在了解正常的服务停止时，我们得先回忆下 Runtime.getRuntime().addShutdownHook(...),这个是 JVM 退出时会执行的回调，这个之前看 SpringBoot 的启动过程或者 Spring 的上下文刷新的时候都有看过，这里我们简单看下：

在 SpringBoot 里的 Bean 实现了 DisposableBean 接口的 Bean都会得到执行，至于 SpringBoot 什么时候放进去这个回调的，是在 Springboot 刷新上下文的时候注册的 shutdownHook:

{@link org.springframework.boot.SpringApplication#refreshContext(ConfigurableApplicationContext)
private void refreshContext(ConfigurableApplicationContext context) {
 refresh(context);
 if (this.registerShutdownHook) {
 try {
 context.registerShutdownHook();
 }
 catch (AccessControlException ex) {
 // Not allowed in some environments.
 }* }
}
@Override
public void registerShutdownHook() {
 if (this.shutdownHook == null) {
 // No shutdown hook registered yet.
 this.shutdownHook = new Thread(SHUTDOWN_HOOK_THREAD_NAME) {
 @Override
 public void run() {
 synchronized (startupShutdownMonitor) {
 doClose();
 }
 } * };
 Runtime.getRuntime().addShutdownHook(this.shutdownHook);
 }
}

doClose() 方法里的 destroyBeans(); 就会调用每个实现了 DisposableBean 接口的 destory 销毁方法。

2.2.2 DynamicDataSource下的关闭

动态数据源就是实现了销毁的接口：

public class DynamicRoutingDataSource extends AbstractRoutingDataSource implements InitializingBean, DisposableBean {
 ...
 // 释放每个数据源的连接
 public void destroy() throws Exception {
 log.info("dynamic-datasource start closing ....");
 Iterator var1 = this.dataSourceMap.entrySet().iterator();
 while(var1.hasNext()) {
 Entry<String, DataSource> item = (Entry)var1.next();
 DataSource dataSource = (DataSource)item.getValue();
 if (this.seata) {
 DataSourceProxy dataSourceProxy = (DataSourceProxy)dataSource;
 dataSource = dataSourceProxy.getTargetDataSource();
 }
 if (this.p6spy) {
 Field realDataSourceField = P6DataSource.class.getDeclaredField("realDataSource");
 realDataSourceField.setAccessible(true);
 dataSource = (DataSource)realDataSourceField.get(dataSource);
 }
 Class clazz = dataSource.getClass();
 try {
 // 调用每个数据源的 close 方法
 Method closeMethod = clazz.getDeclaredMethod("close");
 closeMethod.invoke(dataSource);
 } catch (NoSuchMethodException var6) {
 log.warn("dynamic-datasource close the datasource named [{}] failed,", item.getKey());
 }
 }
 log.info("dynamic-datasource all closed success,bye");
 }
}

效果如下图：