Spring Boot 青睐的数据库连接池 HikariCP 为什么是史上最快的？

this.isUseJdbc4Validation = config.getConnectionTestQuery() == null;

jdbc:mysql://127.0.0.1:3306/xxx?socketTimeout=250

//这个接口的实现主要负责收集一些动作的耗时public interface IMetricsTracker extends AutoCloseable{    //这个方法触发点在创建实际的物理连接时（主流程3），用于记录一个实际的物理连接创建所耗费的时间    default void recordConnectionCreatedMillis(long connectionCreatedMillis) {}
    //这个方法触发点在getConnection时（主流程1），用于记录获取一个连接时实际的耗时    default void recordConnectionAcquiredNanos(final long elapsedAcquiredNanos) {}
    //这个方法触发点在回收连接时（主流程6），用于记录一个连接从被获取到被回收时所消耗的时间    default void recordConnectionUsageMillis(final long elapsedBorrowedMillis) {}
    //这个方法触发点也在getConnection时（主流程1），用于记录获取连接超时的次数，每发生一次获取连接超时，就会触发一次该方法的调用    default void recordConnectionTimeout() {}
    @Override    default void close() {}}

//用于创建IMetricsTracker实例，并且按需记录PoolStats对象里的属性（这个对象里的属性就是类似连接池当前闲置连接数之类的线程池状态类指标）public interface MetricsTrackerFactory{    //返回一个IMetricsTracker对象，并且把PoolStats传了过去    IMetricsTracker create(String poolName, PoolStats poolStats);}

public abstract class PoolStats {    private final AtomicLong reloadAt; //触发下次刷新的时间（时间戳）    private final long timeoutMs; //刷新下面的各项属性值的频率，默认1s，无法改变
    // 总连接数    protected volatile int totalConnections;    // 闲置连接数    protected volatile int idleConnections;    // 活动连接数    protected volatile int activeConnections;    // 由于无法获取到可用连接而阻塞的业务线程数    protected volatile int pendingThreads;    // 最大连接数    protected volatile int maxConnections;    // 最小连接数    protected volatile int minConnections;
    public PoolStats(final long timeoutMs) {        this.timeoutMs = timeoutMs;        this.reloadAt = new AtomicLong();    }
    //这里以获取最大连接数为例，其他的跟这个差不多    public int getMaxConnections() {        if (shouldLoad()) { //是否应该刷新            update(); //刷新属性值，注意这个update的实现在HikariPool里，因为这些属性值的直接或间接来源都是HikariPool        }
        return maxConnections;    }        protected abstract void update(); //实现在↑上面已经说了
    private boolean shouldLoad() { //按照更新频率来决定是否刷新属性值        for (; ; ) {            final long now = currentTime();            final long reloadTime = reloadAt.get();            if (reloadTime > now) {                return false;            } else if (reloadAt.compareAndSet(reloadTime, plusMillis(now, timeoutMs))) {                return true;            }        }    }}

@Overridepublic IMetricsTracker create(String poolName, PoolStats poolStats) {    getCollector().add(poolName, poolStats); //将接收到的PoolStats对象直接交给Collector，这样普罗米修斯服务端每触发一次采集接口的调用，PoolStats都会跟着执行一遍内部属性获取流程    return new PrometheusMetricsTracker(poolName, this.collectorRegistry); //返回IMetricsTracker接口的实现类}
//自定义的Collectorprivate HikariCPCollector getCollector() {    if (collector == null) {        //注册到普罗米修斯收集中心        collector = new HikariCPCollector().register(this.collectorRegistry);    }    return collector;

final class PoolEntry implements IConcurrentBagEntry {    private static final Logger LOGGER = LoggerFactory.getLogger(PoolEntry.class);    //通过cas来修改state属性    private static final AtomicIntegerFieldUpdater stateUpdater;
    Connection connection; //实际的物理连接对象    long lastAccessed; //触发回收时刷新该时间，表示“最近一次使用时间”    long lastBorrowed; //getConnection里borrow成功后刷新该时间，表示“最近一次借出的时间”
    @SuppressWarnings("FieldCanBeLocal")    private volatile int state = 0; //连接状态，枚举值：IN_USE（使用中）、NOT_IN_USE（闲置中）、REMOVED（已移除）、RESERVED（标记为保留中）    private volatile boolean evict; //是否被标记为废弃，很多地方用到（比如流程1.1靠这个判断连接是否已被废弃，再比如主流程4里时钟回拨时触发的直接废弃逻辑）
    private volatile ScheduledFuture<?> endOfLife; //用于在超过连接生命周期（maxLifeTime）时废弃连接的延时任务，这里poolEntry要持有该对象，主要是因为在对象主动被关闭时（意味着不需要在超过maxLifeTime时主动失效了），需要cancel掉该任务
    private final FastList openStatements; //当前该连接对象上生成的所有的statement对象，用于在回收连接时主动关闭这些对象，防止存在漏关的statement    private final HikariPool hikariPool; //持有pool对象
    private final boolean isReadOnly; //是否为只读    private final boolean isAutoCommit; //是否存在事务}

private PoolEntry createPoolEntry() {
        final PoolEntry poolEntry = newPoolEntry(); //生成实际的连接对象
        final long maxLifetime = config.getMaxLifetime(); //拿到配置好的maxLifetime        if (maxLifetime > 0) { //<=0的时候不启用主动过期策略            // 计算需要减去的随机数            // 源注释：variance up to 2.5% of the maxlifetime            final long variance = maxLifetime > 10_000 ? ThreadLocalRandom.current().nextLong(maxLifetime / 40) : 0;            final long lifetime = maxLifetime - variance; //生成实际的延时时间            poolEntry.setFutureEol(houseKeepingExecutorService.schedule(                    () -> { //实际的延时任务，这里直接触发softEvictConnection，而softEvictConnection内则会标记该连接对象为废弃状态，然后尝试修改其状态为STATE_RESERVED，若成功，则触发closeConnection（对应流程1.1.2）                        if (softEvictConnection(poolEntry, "(connection has passed maxLifetime)", false /* not owner */)) {                            addBagItem(connectionBag.getWaitingThreadCount()); //回收完毕后，连接池内少了一个连接，就会尝试新增一个连接对象                        }                    },                    lifetime, MILLISECONDS)); //给endOfLife赋值，并且提交延时任务，lifetime后触发        }
        return poolEntry;    }
    //触发新增连接任务    public void addBagItem(final int waiting) {        //前排提示：addConnectionQueue和addConnectionExecutor的关系和初始化参考主流程2
        //当添加连接的队列里已提交的任务超过那些因为获取不到连接而发生阻塞的线程个数时，就进行提交连接新增连接的任务        final boolean shouldAdd = waiting - addConnectionQueue.size() >= 0; // Yes, >= is intentional.        if (shouldAdd) {            //提交任务给addConnectionExecutor这个线程池，PoolEntryCreator是一个实现了Callable接口的类，下面将通过流程图的方式介绍该类的call方法            addConnectionExecutor.submit(poolEntryCreator);        }    }

//housekeepingPeriodMs的默认值是30s，所以定时任务的间隔为30sthis.houseKeeperTask = houseKeepingExecutorService.scheduleWithFixedDelay(new HouseKeeper(), 100L, housekeepingPeriodMs, MILLISECONDS);

//now就是当前系统时间，previous就是上次触发该任务时的时间，housekeepingPeriodMs就是隔多久触发该任务一次//也就是说plusMillis(previous, housekeepingPeriodMs)表示当前时间//如果系统时间没被回拨，那么plusMillis(now, 128)一定是大于当前时间的，如果被系统时间被回拨//回拨的时间超过128ms，那么下面的判断就成立，否则永远不会成立if (plusMillis(now, 128) < plusMillis(previous, housekeepingPeriodMs))

//拿到所有处于闲置状态的连接final List notInUse = connectionBag.values(STATE_NOT_IN_USE);//计算出需要被检查闲置时间的数量，简单来说，池内需要保证最小minIdle个连接活着，所以需要计算出超出这个范围的闲置对象进行检查int toRemove = notInUse.size() - config.getMinIdle();for (PoolEntry entry : notInUse) {  //在检查范围内，且闲置时间超出idleTimeout，然后尝试将连接对象状态由STATE_NOT_IN_USE变为STATE_RESERVED成功  if (toRemove > 0 && elapsedMillis(entry.lastAccessed, now) > idleTimeout && connectionBag.reserve(entry)) {    closeConnection(entry, "(connection has passed idleTimeout)"); //满足上述条件，进行连接关闭    toRemove--;  }}fillPool(); //因为可能回收了一些连接，所以要再次触发连接池扩充流程检查下是否需要新增连接。

Math.min(最大连接数 - 池内当前连接总数, 最小连接数 - 池内闲置的连接数)

public final void close() throws SQLException {  // 原注释：Closing statements can cause connection eviction, so this must run before the conditional below  closeStatements(); //此连接对象在业务方使用过程中产生的所有statement对象，进行统一close，防止漏close的情况  if (delegate != ClosedConnection.CLOSED_CONNECTION) {    leakTask.cancel(); //取消连接泄漏检查任务，参考流程2.2    try {      if (isCommitStateDirty && !isAutoCommit) { //在存在执行语句后并且还打开了事务，调用close时需要主动回滚事务        delegate.rollback(); //回滚        lastAccess = currentTime(); //刷新"最后一次使用时间"      }    } finally {      delegate = ClosedConnection.CLOSED_CONNECTION;      poolEntry.recycle(lastAccess); //触发回收    }  }}

void recycle(final long lastAccessed) {  if (connection != null) {    this.lastAccessed = lastAccessed; //刷新最后使用时间    hikariPool.recycle(this); //触发HikariPool的回收方法，把自己传过去  }}

void recycle(final PoolEntry poolEntry) {  metricsTracker.recordConnectionUsage(poolEntry); //监控指标相关，忽略  connectionBag.requite(poolEntry); //最终触发connectionBag的requite方法归还连接，该流程参考ConnectionBag主流程里的requite方法部分}

public class ConcurrentBag<T extends IConcurrentBagEntry> implements AutoCloseable {
    private final CopyOnWriteArrayList<T> sharedList; //最终存放PoolEntry对象的地方，它是一个CopyOnWriteArrayList    private final boolean weakThreadLocals; //默认false，为true时可以让一个连接对象在下方threadList里的list内处于弱引用状态，防止内存泄漏（参见备注1）
    private final ThreadLocal<List<Object>> threadList; //线程级的缓存，从sharedList拿到的连接对象，会被缓存进当前线程内，borrow时会先从缓存中拿，从而达到池内无锁实现    private final IBagStateListener listener; //内部接口，HikariPool实现了该接口，主要用于ConcurrentBag主动通知HikariPool触发添加连接对象的异步操作（也就是主流程3里的addConnectionExecutor所触发的流程）    private final AtomicInteger waiters; //当前因为获取不到连接而发生阻塞的业务线程数，这个在之前的流程里也出现过，比如主流程3里addBagItem就会根据该指标进行判断是否需要新增连接    private volatile boolean closed; //标记当前ConcurrentBag是否已被关闭
    private final SynchronousQueue<T> handoffQueue; //这是个即产即销的队列，用于在连接不够用时，及时获取到add方法里新创建的连接对象，详情可以参考下面borrow和add的代码
    //内部接口，PoolEntry类实现了该接口    public interface IConcurrentBagEntry {
        //连接对象的状态，前面的流程很多地方都已经涉及到了，比如主流程4的缩容        int STATE_NOT_IN_USE = 0; //闲置        int STATE_IN_USE = 1; //使用中        int STATE_REMOVED = -1; //已废弃        int STATE_RESERVED = -2; //标记保留，介于闲置和废弃之间的中间状态，主要由缩容那里触发修改
        boolean compareAndSet(int expectState, int newState); //尝试利用cas修改连接对象的状态值
        void setState(int newState); //设置状态值
        int getState(); //获取状态值    }
    //参考上面listener属性的解释    public interface IBagStateListener {        void addBagItem(int waiting);    }
    //获取连接方法    public T borrow(long timeout, final TimeUnit timeUnit) {        // 省略...    }
    //回收连接方法    public void requite(final T bagEntry) {        //省略...    }
    //添加连接方法    public void add(final T bagEntry) {        //省略...    }
    //移除连接方法    public boolean remove(final T bagEntry) {        //省略...    }
    //根据连接状态值获取当前池子内所有符合条件的连接集合    public List values(final int state) {        //省略...    }
    //获取当前池子内所有的连接    public List values() {        //省略...    }
    //利用cas把传入的连接对象的state从 STATE_NOT_IN_USE 变为 STATE_RESERVED    public boolean reserve(final T bagEntry) {        //省略...    }
    //获取当前池子内符合传入状态值的连接数量    public int getCount(final int state) {        //省略...    }}

public T borrow(long timeout, final TimeUnit timeUnit) throws InterruptedException {    // 源注释：Try the thread-local list first    final List<Object> list = threadList.get(); //首先从当前线程的缓存里拿到之前被缓存进来的连接对象集合    for (int i = list.size() - 1; i >= 0; i--) {        final Object entry = list.remove(i); //先移除，回收方法那里会再次add进来        final T bagEntry = weakThreadLocals ? ((WeakReference<T>) entry).get() : (T) entry; //默认不启用弱引用        // 获取到对象后，通过cas尝试把其状态从STATE_NOT_IN_USE 变为 STATE_IN_USE，注意，这里如果其他线程也在使用这个连接对象，        // 并且成功修改属性，那么当前线程的cas会失败，那么就会继续循环尝试获取下一个连接对象        if (bagEntry != null && bagEntry.compareAndSet(STATE_NOT_IN_USE, STATE_IN_USE)) {            return bagEntry; //cas设置成功后，表示当前线程绕过其他线程干扰，成功获取到该连接对象，直接返回        }    }
    // 源注释：Otherwise, scan the shared list ... then poll the handoff queue    final int waiting = waiters.incrementAndGet(); //如果缓存内找不到一个可用的连接对象，则认为需要“回源”，waiters+1    try {        for (T bagEntry : sharedList) {            //循环sharedList，尝试把连接状态值从STATE_NOT_IN_USE 变为 STATE_IN_USE            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) { //阻塞线程数大于1时，需要触发HikariPool的addBagItem方法来进行添加连接入池，这个方法的实现参考主流程3                    listener.addBagItem(waiting - 1);                }                return bagEntry; //cas设置成功，跟上面的逻辑一样，表示当前线程绕过其他线程干扰，成功获取到该连接对象，直接返回            }        }
        //走到这里说明不光线程缓存里的列表竞争不到连接对象，连sharedList里也找不到可用的连接，这时则认为需要通知HikariPool，该触发添加连接操作了        listener.addBagItem(waiting);
        timeout = timeUnit.toNanos(timeout); //这时候开始利用timeout控制获取时间        do {            final long start = currentTime();            //尝试从handoffQueue队列里获取最新被加进来的连接对象（一般新入的连接对象除了加进sharedList之外，还会被offer进该队列）            final T bagEntry = handoffQueue.poll(timeout, NANOSECONDS);            //如果超出指定时间后仍然没有获取到可用的连接对象，或者获取到对象后通过cas设置成功，这两种情况都不需要重试，直接返回对象            if (bagEntry == null || bagEntry.compareAndSet(STATE_NOT_IN_USE, STATE_IN_USE)) {                return bagEntry;            }            //走到这里说明从队列内获取到了连接对象，但是cas设置失败，说明又该对象又被其他线程率先拿去用了，若时间还够，则再次尝试获取            timeout -= elapsedNanos(start); //timeout减去消耗的时间，表示下次循环可用时间        } while (timeout > 10_000); //剩余时间大于10s时才继续进行，一般情况下，这个循环只会走一次，因为timeout很少会配的比10s还大
        return null; //超时，仍然返回null    } finally {        waiters.decrementAndGet(); //这一步出去后，HikariPool收到borrow的结果，算是走出阻塞，所以waiters-1    }}

public void add(final T bagEntry) {
    sharedList.add(bagEntry); //直接加到sharedList里去
    // 源注释：spin until a thread takes it or none are waiting    // 参考borrow流程，当存在线程等待获取可用连接，并且当前新入的这个连接状态仍然是闲置状态，且队列里无消费者等待获取时，发起一次线程调度    while (waiters.get() > 0 && bagEntry.getState() == STATE_NOT_IN_USE && !handoffQueue.offer(bagEntry)) { //注意这里会offer一个连接对象入队列        yield();    }}

public void requite(final T bagEntry) {    bagEntry.setState(STATE_NOT_IN_USE); //回收意味着使用完毕，更改state为STATE_NOT_IN_USE状态
    for (int i = 0; waiters.get() > 0; i++) { //如果存在等待线程的话，尝试传给队列，让borrow获取        if (bagEntry.getState() != STATE_NOT_IN_USE || handoffQueue.offer(bagEntry)) {            return;        }        else if ((i & 0xff) == 0xff) {            parkNanos(MICROSECONDS.toNanos(10));        }        else {            yield();        }    }
    final List<Object> threadLocalList = threadList.get();    if (threadLocalList.size() < 50) { //线程内连接集合的缓存最多50个，这里回收连接时会再次加进当前线程的缓存里，方便下次borrow获取        threadLocalList.add(weakThreadLocals ? new WeakReference<>(bagEntry) : bagEntry); //默认不启用弱引用，若启用的话，则缓存集合里的连接对象没有内存泄露的风险    }}

public boolean remove(final T bagEntry) {    // 下面两个cas操作，都是从其他状态变为移除状态，任意一个成功，都不会走到下面的warn log    if (!bagEntry.compareAndSet(STATE_IN_USE, STATE_REMOVED) && !bagEntry.compareAndSet(STATE_RESERVED, STATE_REMOVED) && !closed) {        LOGGER.warn("Attempt to remove an object from the bag that was not borrowed or reserved: {}", bagEntry);        return false;    }
    // 直接从sharedList移除掉    final boolean removed = sharedList.remove(bagEntry);    if (!removed && !closed) {        LOGGER.warn("Attempt to remove an object from the bag that does not exist: {}", bagEntry);    }
    return removed;}

public List values(final int state) {    //过滤出来符合状态值的对象集合逆序后返回出去    final List list = sharedList.stream().filter(e -> e.getState() == state).collect(Collectors.toList());    Collections.reverse(list);    return list;}
public List values() {    //返回全部连接对象（注意下方clone为浅拷贝）    return (List) sharedList.clone();}

public boolean reserve(final T bagEntry){   return bagEntry.compareAndSet(STATE_NOT_IN_USE, STATE_RESERVED);}

public int getCount(final int state){   int count = 0;   for (IConcurrentBagEntry e : sharedList) {      if (e.getState() == state) {         count++;      }   }   return count;}