HikariCP源码分析之初始化分析一
欢迎访问我的博客,同步更新: 枫山别院
源代码版本2.4.5-SNAPSHOTHikariDataSource的初始化
文章图片
HikariDataSource_init.png
HikariDataSource
是 HikariCP 开放给用户使用连接池的主要操作类。所以,我们创建一个 HikariCP 的连接池,其实就是构造一个HikariDataSource
。两个构造函数 它有两个构造函数:
第一个无参构造:
public HikariDataSource() {
super();
fastPathPool = null;
}
第二个有参构造:
public HikariDataSource(HikariConfig configuration) {
configuration.validate();
configuration.copyState(this);
LOGGER.info("{} - Started.", configuration.getPoolName());
pool = fastPathPool = new HikariPool(this);
}
两种初始化方式 既然有两个构造函数,那么就应该有两种初始化方式,对吧。
- 使用无参构造初始化
HikariDataSource dataSource = new HikariDataSource();
dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test");
dataSource.setUsername("root");
dataSource.setPassword("123");
//设置数据库独有的属性
dataSource.addDataSourceProperty("cachePrepStmts", "true");
//从连接池获取连接
Connection connection = dataSource.getConnection();
- 使用有参构造初始化
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/test");
config.setUsername("root");
config.setPassword("123");
//设置数据库独有的属性
config.addDataSourceProperty("cachePrepStmts", "true");
//使用HikariConfig构造HikariDataSource
HikariDataSource dataSource = new HikariDataSource(config);
//从连接池获取连接
Connection connection = dataSource.getConnection();
这两种方式的区别就是,有参构造使用的是
HikariConfig
来设置参数的,有同学会问:既然HikariDataSource
能直接设置参数,为什么还要用HikariConfig
?这不是更麻烦吗?其实 HikariCP 官方更推荐使用
HikariConfig
的方式,为什么呢?我们来具体分析下。无参构造代码分析 我们先来分析第一种无参构造初始化的方式,代码只有两行:
super();
fastPathPool = null;
super();
方法是调用了HikariDataSource
父类的无参构造,它的父类是哪个?是HikariConfig
,这就是为什么HikariDataSource
也能直接设置参数的原因,它继承了HikariConfig
。那么这个super();
肯定就是HikariConfig
的无参构造了,我们看看:public HikariConfig() {
//①
dataSourceProperties = new Properties();
healthCheckProperties = new Properties();
minIdle = -1;
maxPoolSize = -1;
//MAX_LIFETIME=30分钟
maxLifetime = MAX_LIFETIME;
//CONNECTION_TIMEOUT=30 秒
connectionTimeout = CONNECTION_TIMEOUT;
//VALIDATION_TIMEOUT=5 秒
validationTimeout = VALIDATION_TIMEOUT;
//IDLE_TIMEOUT=10分钟
idleTimeout = IDLE_TIMEOUT;
isAutoCommit = true;
isInitializationFailFast = true;
//②
String systemProp = System.getProperty("hikaricp.configurationFile");
if (systemProp != null) {
loadProperties(systemProp);
}
}
- ①
- ②
System.getProperty
是一个获取系统属性的方法,从字面看,它要获取一个叫做hikaricp.configurationFile
的属性值,然后加载它。那么hikaricp.configurationFile
配置的是什么东西呢?其实,这个是一个Properties配置文件的路径,它这是要从这个路径加载配置文件对吧。那么,我们又知道了一种 HikariCP 的配置方式:写一个Properties配置文件,然后将文件路径配置到hikaricp.configurationFile
系统属性,就可以了。又如何配置系统属性呢?很简单的,在应用启动的时候,使用
-Dhikaricp.configurationFile=xxxxx.properties
就可以了吧。至于
loadProperties
如何加载配置文件并set 到对应的配置中,这个没有什么特殊的设计,在这里不展开了,后面给大家分析下HikariConfig
的几种初始化方式,大家也可以看下我的代码注释,非常详细。构造函数的最后一句
fastPathPool = null;
,如果大家看了《HikariCP源码分析之获取连接流程一》那么你一定明白的。有参构造代码分析 我们继续看一下有参构造的代码:
configuration.validate();
configuration.copyState(this);
LOGGER.info("{} - Started.", configuration.getPoolName());
pool = fastPathPool = new HikariPool(this);
第一句
configuration.validate();
,是验证配置的参数。为了避免文章过长,我们另起章节介绍,毕竟文章不像是人体的某部位,越长越好,技术文章太长没人看,现在是流行碎片化阅读。第二句
configuration.copyState(this);
我们要详细介绍下,这个跟本节关系密切。【HikariCP源码分析之初始化分析一】从字面来看,是复制状态之类的操作。不知道
configuration.copyState(this);
方法中的参数的this
大家注意了没有,它代表的是HikariDataSource
对吧,而configuration
代表的是HikariConfig
。我们大胆猜测一下:应该是把HikariConfig
中的配置复制到HikariDataSource
中。对不对呢?进去看下
copyState
代码:public void copyState(HikariConfig other) {
for (Field field : HikariConfig.class.getDeclaredFields()) {
if (!Modifier.isFinal(field.getModifiers())) {
field.setAccessible(true);
try {
field.set(other, field.get(this));
} catch (Exception e) {
throw new RuntimeException("Failed to copy HikariConfig state: " + e.getMessage(), e);
}
}
}
}
果然不出所料,这是一段反射代码,目的就是把
HikariConfig
中的值复制到this
代表的HikariDataSource
实例中。为什么可以直接反射复制?因为HikariDataSource
继承了HikariConfig
啊,这个大家没有忘记吧!具体复制逻辑我就不说了,如果有同学看不懂这段反射,请补习Java反射的内容,这是 Java 基础,不是框架的内容。略过第三句记录日志,我们直接看第四句
pool = fastPathPool = new HikariPool(this);
。为什么要
pool = fastPathPool
, 请大家看《HikariCP源码分析之获取连接流程一》,你会明白的。我们直接看new HikariPool(this)
,这是创建HikariPool
,HikariPool
是连接池的抽象,它提供了操作连接池的方法。感觉已经够长了,换阵地,请看下一篇。
推荐阅读
- 如何寻找情感问答App的分析切入点
- D13|D13 张贇 Banner分析
- 自媒体形势分析
- 2020-12(完成事项)
- Android事件传递源码分析
- Python数据分析(一)(Matplotlib使用)
- Quartz|Quartz 源码解析(四) —— QuartzScheduler和Listener事件监听
- 泽宇读书会——如何阅读一本书笔记
- Java内存泄漏分析系列之二(jstack生成的Thread|Java内存泄漏分析系列之二:jstack生成的Thread Dump日志结构解析)
- [源码解析]|[源码解析] NVIDIA HugeCTR,GPU版本参数服务器---(3)