全部產品
Search
文件中心

:Druid串連池

更新時間:Sep 05, 2024

Druid是一個高效能的資料庫連接池,旨在提高資料庫連接效能和管理效率。本文將介紹在Spring架構下使用Druid串連池串連AnalyticDB for MySQL(以下簡稱AnalyticDB for MySQL)的配置參數與程式碼範例。

注意事項

  • 僅支援Druid 1.1.16以上的版本。

  • 使用Druid串連池串連AnalyticDB for MySQL時,建議配置<property name="keepAlive" value="true" />,可以複用串連和避免短串連。

  • AnalyticDB for MySQL前端接入節點使用SLB做負載平衡,用戶端串連前端節點。為了將用戶端請求較為均勻地發送到各個前端節點,建議串連池裡有稍多一些串連,且串連保持的時間不宜太長。

  • 根據業務情況合理調整串連池配置,並確保配置生效。您可以在程式中通過DruidDataSource#getStatData()DruidDataSource#dump()方法定期擷取生效的配置與串連池的資訊,並在日誌中查看、核對相關配置資訊。

  • 執行查詢前從串連池擷取串連,執行完查詢後要及時調用conn.close()將串連返回到串連池中。再次使用時,請從串連池中擷取新串連,避免長時間使用一個串連導致Druid無法及時檢查到串連失效。

  • 複雜網路情況下,當遇到網關效能達到瓶頸、網路鏈路長、網路抖動、重傳率或丟包率高等情形,可能會導致串連中斷。在確保串連池合理配置都生效的情況下,如果仍然有串連中斷的情況,建議業務代碼側通過重試進行最佳化。

配置Druid串連池

 <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> 
     <!--jdbc_url是AnalyticDB MySQL叢集的串連地址URL,可以在控制台的叢集資訊頁面擷取串連URL。-->
     <property name="url" value="${jdbc_url}" />

     <!--jdbc_user是AnalyticDB MySQL叢集中的使用者帳號:高許可權帳號或者普通帳號。-->
     <property name="username" value="${jdbc_user}" />

     <!--jdbc_password是AnalyticDB MySQL叢集中使用者帳號對應的密碼。-->
     <property name="password" value="${jdbc_password}" />

     <!--配置初始化串連池大小、最小串連數、最大串連數。-->
     <property name="initialSize" value="5" />
     <property name="minIdle" value="10" /> 
     <property name="maxActive" value="20" />

     <!--配置擷取串連等待逾時的時間。-->
     <property name="maxWait" value="60000" />

     <!--配置一個串連在串連池中的最小存留時間、最大存留時間,超過最大存留時間會被移除,單位毫秒。-->
     <property name="minEvictableIdleTimeMillis" value="600000" />
     <property name="maxEvictableIdleTimeMillis" value="900000" />

     <!--配置間隔多久進行一次檢測,檢測需要關閉的空閑串連,單位毫秒。 預設是60s,太長可能會導致無法及時檢測到串連中斷。-->
     <property name="timeBetweenEvictionRunsMillis" value="2000" />

     <!--配置從串連池擷取串連時,當串連空閑時間大於timeBetweenEvictionRunsMillis時是否檢查串連有效性,true每次都檢查;false不檢查。-->
     <property name="testWhileIdle" value="true" />

     <!--配置從串連池擷取串連時和向串連池歸還串連時,是否檢查串連有效性。-->
     <!--每次擷取或歸還串連都檢測太頻繁,除非特別重要或網路特別不可靠等情況,建議用testWhileIdle + timeBetweenEvictionRunsMillis代替。-->
     <property name="testOnBorrow" value="false" />
     <property name="testOnReturn" value="false" />

     <!--配置是否定期探活、探活間隔。-->
     <property name="keepAlive" value="true" />
     <property name="keepAliveBetweenTimeMillis" value="30000" />  <!--預設120s。-->

     <!--配置一個串連最大使用次數,避免長時間使用相同串連造成伺服器端負載不均衡。-->
     <property name="phyMaxUseCount" value="1000" />

     <!--探活、驗證鏈結接有效性的查詢,新版本預設使用mysqlPing代替-->
     <property name="validationQuery"  value="select 1" />
     
     <!--配置監控統計攔截的filters。-->
     <property name="filters" value="stat" /> 
 </bean>     

生效ValidationQuery

Druid新版本預設使用mysqlPing代替執行ValidationQuery進行探活,如果需要執行ValidationQuery可以進行如下設定:

...
druidDataSource.init();

Properties properties = new Properties();
properties.setProperty("druid.mysql.usePingMethod", "false");
druidDataSource.setConnectProperties(properties);

擷取串連池資訊

使用dataSource.dump()可以擷取串連池和串連的基本資料。

{
    CreateTime:"2022-06-01 15:28:10",   # 串連池建立時間
    ActiveCount:0,      # 從串連池取出來在用的串連數
    PoolingCount:2,     # 在串連池中,未取出去使用的串連數
    CreateCount:2,      # 建立過的串連數,串連銷毀後重新建立會增加該數量
    DestroyCount:0,     # 銷毀過的串連數,串連異常或到期銷毀會增加該數量
    CloseCount:4,       # 調用conn.close()將串連還到串連池的次數
    ConnectCount:4,     # 調用dataSource.getConnection()擷取串連的次數
    Connections:[
        {
            ID:525571,     # 串連ID
            ConnectTime:"2022-06-01 15:28:11",        # 串連建立時間
            UseCount:0,                     # 串連被擷取使用的次數,所有UseCount加起來等於上面的ConnectCount
            LastActiveTime:"2022-06-01 15:28:11"    # 串連最後被取出來使用的時間,未使用等於ConnectTime
        },
        {ID:1263877414, ConnectTime:"2022-06-01 15:28:11", UseCount:4, LastActiveTime:"2022-06-01 15:28:11"}
    ]
}

擷取串連池生效配置

使用dataSource.getStatData()可以擷取串連池生效的配置。

{
    Identity=85777802,
    Name=DataSource-85777802,
    DbType=mysql,
    DriverClassName=com.mysql.jdbc.Driver,
    URL=jdbc:mysql://host:port/db_name,
    UserName=haicen,
    FilterClassNames=[],
    WaitThreadCount=0,
    NotEmptyWaitCount=0,
    NotEmptyWaitMillis=0,
    PoolingCount=2,
    PoolingPeak=2,
    PoolingPeakTime=Wed Jun 01 16:08:15 CST 2022,
    ActiveCount=0,
    ActivePeak=1,
    ActivePeakTime=Wed Jun 01 16:08:15 CST 2022,
    InitialSize=1,
    MinIdle=2,
    MaxActive=3,
    QueryTimeout=0,
    TransactionQueryTimeout=0,
    LoginTimeout=0,
    ValidConnectionCheckerClassName=com.alibaba.druid.pool.vendor.MySqlValidConnectionChecker,
    ExceptionSorterClassName=com.alibaba.druid.pool.vendor.MySqlExceptionSorter,
    TestOnBorrow=true,
    TestOnReturn=true,
    TestWhileIdle=true,
    DefaultAutoCommit=true,
    DefaultReadOnly=null,
    DefaultTransactionIsolation=null,
    LogicConnectCount=14,
    LogicCloseCount=14,
    LogicConnectErrorCount=0,
    PhysicalConnectCount=6,
    PhysicalCloseCount=4,
    PhysicalConnectErrorCount=0,
    DiscardCount=0,
    ExecuteCount=14,
    ExecuteUpdateCount=0,
    ExecuteQueryCount=14,
    ExecuteBatchCount=0,
    ErrorCount=0,
    CommitCount=0,
    RollbackCount=0,
    PSCacheAccessCount=0,
    PSCacheHitCount=0,
    PSCacheMissCount=0,
    StartTransactionCount=0,
    TransactionHistogram=[
        J@6a472554,
        ConnectionHoldTimeHistogram=[
            J@7ff2a664,
            RemoveAbandoned=true,
            ClobOpenCount=0,
            BlobOpenCount=0,
            KeepAliveCheckCount=332,
            KeepAlive=true,
            FailFast=false,
            MaxWait=6000,
            MaxWaitThreadCount=-1,
            PoolPreparedStatements=false,
            MaxPoolPreparedStatementPerConnectionSize=10,
            MinEvictableIdleTimeMillis=600000,
            MaxEvictableIdleTimeMillis=900000,
            LogDifferentThread=true,
            RecycleErrorCount=0,
            PreparedStatementOpenCount=0,
            PreparedStatementClosedCount=0,
            UseUnfairLock=false,
            InitGlobalVariants=false,
            InitVariants=false
}