Hikari 默認(rèn)幾個(gè)超時(shí)配置

連接創(chuàng)建超時(shí)時(shí)間 30s 

private static final long CONNECTION_TIMEOUT = SECONDS.toMillis(30);

連接存活驗(yàn)證時(shí)間5s，這個(gè)時(shí)間就是驗(yàn)證時(shí)socketTimeout，驗(yàn)證之后恢復(fù)為0，

但是真正做數(shù)據(jù)查詢時(shí)默認(rèn)為0，表示永不超時(shí)

private static final long VALIDATION_TIMEOUT = SECONDS.toMillis(5);

連接空閑時(shí)間10分鐘

private static final long IDLE_TIMEOUT = MINUTES.toMillis(10);

連接最大存活時(shí)間30分鐘

private static final long MAX_LIFETIME = MINUTES.toMillis(30);

Hikari 連接池中默認(rèn)連接數(shù)量為10

默認(rèn)最小連接數(shù)等于最大相同未為10

private static final int DEFAULT_POOL_SIZE = 10;

Hikari通過CopyOnWriteArrayList保存所有的連接

com.zaxxer.hikari.util.ConcurrentBag#sharedList

線程無法獲取連接時(shí)通過SynchronousQueue實(shí)現(xiàn)公平阻塞等待

當(dāng)池的連接被用盡，Hikari通過SynchronousQueue實(shí)現(xiàn)讓線程阻塞等待，并且采用的是公平鎖。

源碼見com.zaxxer.hikari.util.ConcurrentBag#handoffQueue以及com.zaxxer.hikari.util.ConcurrentBag#ConcurrentBag構(gòu)造方法

Hikari內(nèi)部有三個(gè)單線程的 線程池 對(duì)象

• houseKeepingExecutorService ，addConnectionExecutor，closeConnectionExecutor 分別是都只有一條線程的線程池，源碼見：com.zaxxer.hikari.pool.HikariPool。
• houseKeepingExecutorService是一個(gè)ScheduledExecutorService對(duì)象。池中每創(chuàng)建一個(gè)連接，就會(huì)被封裝成一個(gè)PoolEntry對(duì)象，然后放在定時(shí)任務(wù)中，定時(shí)時(shí)間就是設(shè)置的max-lifetime。只要到達(dá)這個(gè)時(shí)間就會(huì)采取軟驅(qū)逐的方式從池中移除。
• 除此之外，houseKeepingExecutorService還用于每隔30s來檢查一次池中的空閑連接、最大連接情況，并通過調(diào)用異步創(chuàng)建連接、異步銷毀連接的方法來維護(hù)池中連接數(shù)的平衡。

何謂軟驅(qū)逐

• 如果這個(gè)連接正在被使用，則不立即關(guān)閉連接，但是通過PoolEntry對(duì)象中的private volatile boolean evict;字段來標(biāo)記為需要關(guān)閉。下次有線程來獲取到這個(gè)連接時(shí)，發(fā)現(xiàn)evict=true則調(diào)用異步關(guān)閉方法。重新獲取池中其它的連接。
• 如果這個(gè)連接未被使用，則立即調(diào)用異步關(guān)閉連接的方法。

池中連接的創(chuàng)建，關(guān)閉，除了初始化時(shí)只同步創(chuàng)建1條，其它都是異步的。

• 創(chuàng)建連接通過addConnectionExecutor(ThreadPoolExecutor)來完成，關(guān)閉連接通過closeConnectionExecutor(ThreadPoolExecutor)來完成.
• 這兩個(gè)線程池都每個(gè)都只有一個(gè)線程。加上houseKeepingExecutorService，那么一個(gè)Hikari連接池會(huì)創(chuàng)建3條線程?。?！
• 可以通過啟動(dòng)參數(shù)-Dcom.zaxxer.hikari.blockUntilFilled和InitializationFailTimeout單位ms，來讓Hikari啟動(dòng)時(shí)等待創(chuàng)建完成設(shè)置的最小連接數(shù)。默認(rèn)為false

一個(gè)connection本質(zhì)上就是一個(gè)socket連接

一個(gè)連接池中，有多少個(gè)connection連接則對(duì)應(yīng)多少個(gè) socket 對(duì)象與服務(wù)端的連接。

Hikari中會(huì)使用ThreadLocal來將連接綁定到線程

Hikari為了提高從池中獲取連接的性能，通過ThreadLocal來避免資源競(jìng)爭(zhēng)，一個(gè)connection可以對(duì)應(yīng)多個(gè)Thread，一個(gè)Thread可以綁定多個(gè)connection，源碼見ConcurrentBag類中的成員變量private final ThreadLocal<List<Object>> threadList;

為什么ThreadLocal里面的泛型是List< Object >?

因?yàn)橐粋€(gè)connection可以在不同時(shí)期被多個(gè)線程使用，當(dāng)另一個(gè)線程綁定的connection正在被別的線程使用時(shí)，就需要選擇其它沒有被使用的connection，新選擇的connection同樣需要綁定到這條線程，所以使用的是List來保存。

源碼見：com.zaxxer.hikari.util.ConcurrentBag#borrow

什么時(shí)候向ThreadLocal里面保存connection?

當(dāng)調(diào)用連接池中connection釋放資源的時(shí)候回收，這里的connection實(shí)際上是Hikari實(shí)現(xiàn)的一個(gè)代理類（ProxyConnection），封裝了JDBC 連接。

源碼見：com.zaxxer.hikari.pool.ProxyConnection#close

Hikari如何做到連接的回收

通過ProxyConnection代理類來實(shí)現(xiàn)。

源碼見：com.zaxxer.hikari.pool.ProxyConnection#close

Hikari通過CAS樂觀鎖來控制連接當(dāng)前狀態(tài)

Hikari通過PoolEntry來封裝Connection，并通過private volatile int state來記錄Connection當(dāng)前狀態(tài)，主要有如下幾個(gè)枚舉值，并通過CAS樂觀鎖來維護(hù)這些狀態(tài)，提高多線程之間獲取連接的性能.

public interface IConcurrentBagEntry{
  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);
  void setState(int newState);
  int getState();
}

獲取連接，對(duì)驗(yàn)證連接可用性的優(yōu)化

每次從池中獲取連接后，先判斷連接最后訪問時(shí)間和當(dāng)前時(shí)間差，如果小于500ms，則直接認(rèn)為連接是可用的，避免向服務(wù)器發(fā)送驗(yàn)證的sql語句，提高連接池性能。

源碼見：com.zaxxer.hikari.pool.HikariPool#getConnection(long hardTimeout)

 if (poolEntry.isMarkedEvicted() || (elapsedMillis(poolEntry.lastAccessed, now) > aliveBypassWindowMs && !isConnectionAlive(poolEntry.connection))) {
    closeConnection(poolEntry, poolEntry.isMarkedEvicted() ? EVICTED_CONNECTION_MESSAGE : DEAD_CONNECTION_MESSAGE);
    timeout = hardTimeout - elapsedMillis(startTime);
 }

否則需要驗(yàn)證連接可用性：

如果配置了connection-test-query則使用配置sql驗(yàn)證，否則使用數(shù)據(jù)庫驅(qū)動(dòng)程序?qū)崿F(xiàn)的java.sql.Connection#isValid(int timeout)方法驗(yàn)證。

源碼見：com.zaxxer.hikari.pool.PoolBase#isConnectionAlive。

如果連接不可用,會(huì)輸出警告日志

如果驗(yàn)證連接可用性過程，連接因?yàn)閿?shù)據(jù)庫wait_timeout超時(shí)被服務(wù)端關(guān)閉，或者網(wǎng)絡(luò)異常，則會(huì)出現(xiàn)如下警告日志，

Failed to validate connection com.mysql.cj.jdbc.ConnectionImpl@2e2ce118 (No operations allowed after connection closed.). Possibly consider using a shorter maxLifetime value.

解決方案參考我的另一篇博客：Failed to validate connection com.mysql.cj.jdbc.ConnectionImpl問題排查

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

最新評(píng)論