介绍
官网地址: https://github.com/brettwooldridge/HikariCP
快速,简单,可靠的数据源,spring boot2.0已经将HikariCP做为了默认的数据源链接池,在官网测试中秒杀一切其他数据源,比如commons-dbcp,tomcat,c3po,druid。
基本设计
Hikari链接池采用了很多优化来提高并发数,可参考这里
所有数据库链接池都遵守基本的设计规则,实现 javax.sql.DataSource 接口,里面最重要的方法就是 Connection getConnection() throws SQLException; 用于获取一个Connection, 一个Connection就是一个数据库链接,就是一个TCP链接,建立TCP链接是需要进行3次握手的,这降低来链接的使用效率,也是各种数据库链接池存在的原因。
数据库链接池通过事先建立好Connection并缓存起来,这样应用需要做数据查询的时候,直接从缓存中拿到Connection就可以使用来。数据库链接池还能够检测异常的链接,释放闲置的链接。
HikariDataSource
Hikari中提供的DataSource是HikariDataSource ,HikariDataSource 实现了 HikariConfig,和数据库的各种参数超时时间配置就正HikariaConfig中。
其中提供两种初始化方式,一种是默认的构造函数,单new一个HikariDataSource时,数据源的链接不会建立,需要等到第一次调用HikariDataSource的getConnection方法。数据源建立后的相关信息保存在 HikariDataSource 中变量HikariPool pool。
另一种建立方式是调用带有HikariConfig的构造函数,这种方式适合多个数据源的建立,共享同一份配置。 这种方式在调用构造函数的时候就建立了数据源的链接。
HikariDataSource的所有数据源获取都委托给了HikariPool,一个数据源会有一个HikariPool,一个HikariPool中有一个ConcurrentBag,一个ConcurrentBag中多个PoolEntry,一个PoolEntry对应一个Connection。
HikariPool
HikariPool中的基本field介绍。
PoolEntryCreator POOL_ENTRY_CREATOR:用于创建PoolEntry,也就是用于创建Connection了,创建Connection是委托给驱动程序的。
Collection
ThreadPoolExecutor addConnectionExecutor:创建Connection链接的执行是有这个线程池调度的。使用新的链接池不会而不使用当前的工作线程,为了不影响工作线程的执行(比如会导致工作线程超时)。
ThreadPoolExecutor closeConnectionExecutor:关闭Connection的链接是有这个线程池调度的。
ConcurrentBag
ProxyLeakTaskFactory leakTaskFactory;参考ProxyLeakTask用于检测Connection泄漏。
ScheduledFuture<?> houseKeeperTask:用于管理链接池里面的链接,比如链接不够用了要创建链接,链接最大生存时间到了要关闭链接。线程池中的Connection就是有它初始化的。
ConcurrentBag
ConcurrentBag设计主要为了解决并发对资源的争用,其中主要有CopyOnWriteArrayList
public T borrow(long timeout, final TimeUnit timeUnit) throws InterruptedException
{
// 从threadList获取链接
final List<Object> list = threadList.get();
for (int i = list.size() - 1; i >= 0; i--) {
final Object entry = list.remove(i);
final T bagEntry = weakThreadLocals ? ((WeakReference<T>) entry).get() : (T) entry;
if (bagEntry != null && bagEntry.compareAndSet(STATE_NOT_IN_USE, STATE_IN_USE)) {
return bagEntry;
}
}
// 从sharedList获取链接
final int waiting = waiters.incrementAndGet();
try {
for (T bagEntry : sharedList) {
if (bagEntry.compareAndSet(STATE_NOT_IN_USE, STATE_IN_USE)) {
// If we may have stolen another waiter\'s connection, request another bag add.
if (waiting > 1) {
listener.addBagItem(waiting - 1);
}
return bagEntry;
}
}
listener.addBagItem(waiting);
timeout = timeUnit.toNanos(timeout);
do {
final long start = currentTime();
//等待其他线程释放链接,超过timeout就获取失败了
final T bagEntry = handoffQueue.poll(timeout, NANOSECONDS);
if (bagEntry == null || bagEntry.compareAndSet(STATE_NOT_IN_USE, STATE_IN_USE)) {
return bagEntry;
}
timeout -= elapsedNanos(start);
} while (timeout > 10_000);
return null;
}
finally {
waiters.decrementAndGet();
}
}