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
}