springboot druid數(shù)據(jù)庫連接池連接失敗后一直重連的解決方法
在使用個人阿里云測試機，在查詢實時輸出日志時，看到數(shù)據(jù)庫連接失敗后，服務器一直在重連服務器。開始以為是遭受重復攻擊，后面把服務重啟后，就沒有出現(xiàn)一直重連的情況?？匆韵螺敵鋈罩荆?/p>
2022-02-09 11:04:58.896 ERROR 16876 --- [eate-1550991149] com.alibaba.druid.pool.DruidDataSource : create connection SQLException, url: jdbc:mysql://47.98.67,98:1234/test?useSSL=false&characterEncoding=UTF-8&serverTimezone=UTC, errorCode 1045, state 28000
java.sql.SQLException: Access denied for user 'root'@'113.90.123.76' (using password: YES)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129) ~[mysql-connector-java-8.0.16.jar:8.0.16]
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) ~[mysql-connector-java-8.0.16.jar:8.0.16]
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[mysql-connector-java-8.0.16.jar:8.0.16]
at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:835) ~[mysql-connector-java-8.0.16.jar:8.0.16]
at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:455) ~[mysql-connector-java-8.0.16.jar:8.0.16]
at com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:240) ~[mysql-connector-java-8.0.16.jar:8.0.16]
at com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:199) ~[mysql-connector-java-8.0.16.jar:8.0.16]
at com.alibaba.druid.filter.FilterChainImpl.connection_connect(FilterChainImpl.java:156) ~[druid-1.1.10.jar:1.1.10]
at com.alibaba.druid.filter.stat.StatFilter.connection_connect(StatFilter.java:218) ~[druid-1.1.10.jar:1.1.10]
at com.alibaba.druid.filter.FilterChainImpl.connection_connect(FilterChainImpl.java:150) ~[druid-1.1.10.jar:1.1.10]
at com.alibaba.druid.pool.DruidAbstractDataSource.createPhysicalConnection(DruidAbstractDataSource.java:1560) ~[druid-1.1.10.jar:1.1.10]
at com.alibaba.druid.pool.DruidAbstractDataSource.createPhysicalConnection(DruidAbstractDataSource.java:1623) ~[druid-1.1.10.jar:1.1.10]
at com.alibaba.druid.pool.DruidDataSource$CreateConnectionThread.run(DruidDataSource.java:2468) ~[druid-1.1.10.jar:1.1.10]
注意上面一直有 druid 數(shù)據(jù)庫連接池的提示，這里就想到可能是 druid 連接池的問題，然后去掉 druid maven 依賴后在請求接口就不會出現(xiàn)重連的問題。
druid 重連原因
在上圖源碼找到最后一行 DruidDataSource.java:2468 定位到源碼上，CreateConnectionThread 創(chuàng)建連接線程，看一下 CreateConnectionThread 源碼：
public class CreateConnectionThread extends Thread {
? ? ? ? public CreateConnectionThread(String name){
? ? ? ? ? ? super(name);
? ? ? ? ? ? this.setDaemon(true);
? ? ? ? }
? ? ? ? public void run() {
? ? ? ? ? ? initedLatch.countDown();
? ? ? ? ? ? long lastDiscardCount = 0;
? ? ? ? ? ? int errorCount = 0;
? ? ? ? ? ? for (;;) {
? ? ? ? ? ? ? ? // addLast
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? lock.lockInterruptibly();
? ? ? ? ? ? ? ? } catch (InterruptedException e2) {
? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? long discardCount = DruidDataSource.this.discardCount;
? ? ? ? ? ? ? ? boolean discardChanged = discardCount - lastDiscardCount > 0;
? ? ? ? ? ? ? ? lastDiscardCount = discardCount;
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? boolean emptyWait = true;
? ? ? ? ? ? ? ? ? ? if (createError != null
? ? ? ? ? ? ? ? ? ? ? ? ? ? && poolingCount == 0
? ? ? ? ? ? ? ? ? ? ? ? ? ? && !discardChanged) {
? ? ? ? ? ? ? ? ? ? ? ? emptyWait = false;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? if (emptyWait
? ? ? ? ? ? ? ? ? ? ? ? ? ? && asyncInit && createCount < initialSize) {
? ? ? ? ? ? ? ? ? ? ? ? emptyWait = false;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? if (emptyWait) {
? ? ? ? ? ? ? ? ? ? ? ? // 必須存在線程等待，才創(chuàng)建連接
? ? ? ? ? ? ? ? ? ? ? ? if (poolingCount >= notEmptyWaitThreadCount //
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? && !(keepAlive && activeCount + poolingCount < minIdle)) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? empty.await();
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? // 防止創(chuàng)建超過maxActive數(shù)量的連接
? ? ? ? ? ? ? ? ? ? ? ? if (activeCount + poolingCount >= maxActive) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? empty.await();
? ? ? ? ? ? ? ? ? ? ? ? ? ? continue;
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? ? ? lastCreateError = e;
? ? ? ? ? ? ? ? ? ? lastErrorTimeMillis = System.currentTimeMillis();
? ? ? ? ? ? ? ? ? ? if (!closing) {
? ? ? ? ? ? ? ? ? ? ? ? LOG.error("create connection Thread Interrupted, url: " + jdbcUrl, e);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? } finally {
? ? ? ? ? ? ? ? ? ? lock.unlock();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? PhysicalConnectionInfo connection = null;
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? connection = createPhysicalConnection();
? ? ? ? ? ? ? ? ? ? setFailContinuous(false);
? ? ? ? ? ? ? ? } catch (SQLException e) {
? ? ? ? ? ? ? ? ? ? LOG.error("create connection SQLException, url: " + jdbcUrl + ", errorCode " + e.getErrorCode()
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? + ", state " + e.getSQLState(), e);
? ? ? ? ? ? ? ? ? ? errorCount++;
? ? ? ? ? ? ? ? ? ? if (errorCount > connectionErrorRetryAttempts && timeBetweenConnectErrorMillis > 0) {
? ? ? ? ? ? ? ? ? ? ? ? // fail over retry attempts
? ? ? ? ? ? ? ? ? ? ? ? setFailContinuous(true);
? ? ? ? ? ? ? ? ? ? ? ? if (failFast) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? lock.lock();
? ? ? ? ? ? ? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? notEmpty.signalAll();
? ? ? ? ? ? ? ? ? ? ? ? ? ? } finally {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? lock.unlock();
? ? ? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? if (breakAfterAcquireFailure) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ? ? ? ? Thread.sleep(timeBetweenConnectErrorMillis);
? ? ? ? ? ? ? ? ? ? ? ? } catch (InterruptedException interruptEx) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? } catch (RuntimeException e) {
? ? ? ? ? ? ? ? ? ? LOG.error("create connection RuntimeException", e);
? ? ? ? ? ? ? ? ? ? setFailContinuous(true);
? ? ? ? ? ? ? ? ? ? continue;
? ? ? ? ? ? ? ? } catch (Error e) {
? ? ? ? ? ? ? ? ? ? LOG.error("create connection Error", e);
? ? ? ? ? ? ? ? ? ? setFailContinuous(true);
? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? if (connection == null) {
? ? ? ? ? ? ? ? ? ? continue;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? boolean result = put(connection);
? ? ? ? ? ? ? ? if (!result) {
? ? ? ? ? ? ? ? ? ? JdbcUtils.close(connection.getPhysicalConnection());
? ? ? ? ? ? ? ? ? ? LOG.info("put physical connection to pool failed.");
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? errorCount = 0; // reset errorCount
? ? ? ? ? ? }
? ? ? ? }
? ? }這是一個多線程的類，而 run 方法里面設置了沒有限制的 for 循環(huán) for (;;) {}, 而日志報錯定位的信息:
connection = createPhysicalConnection();
如果符合條件 errorCount > connectionErrorRetryAttempts && timeBetweenConnectErrorMillis > 0 會再次嘗試重連，先看一下這幾個參數(shù)的含義：
errorCount 錯誤次數(shù)
在 run 方法初始化時為零，每次連接失敗，會自動加1
connectionErrorRetryAttempts
連接錯誤重試次數(shù)，默認值為 1。
protected int connectionErrorRetryAttempts = 1;
timeBetweenConnectErrorMillis
連接間隔時間，單位毫秒。默認值為 500。
protected volatile long timeBetweenConnectErrorMillis = DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS; public static final long DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS = 500;
我們在連接數(shù)據(jù)庫失敗后，要不在里面 break 中斷，其中有
if (breakAfterAcquireFailure) {
break;
}
將改 break-after-acquire-failure 設置成 true,在 application.properties 文件如下配置：
spring.datasource.druid.break-after-acquire-failure=true
如果想多嘗試連接幾次，需要設置 connection-error-retry-attempts ,當 errorCount 大于 connectionErrorRetryAttempts 才會進入到 條件內，才會中斷循環(huán)。在 application.properties 文件如下配置：
spring.datasource.druid.connection-error-retry-attempts=3
總結
druid 數(shù)據(jù)庫連接失敗，是因為在使用多線程連接數(shù)據(jù)時使用了無限制循環(huán)連接，需要在連接失敗中斷連接，需要設置 break-after-acquire-failure 為 true。設置之后數(shù)據(jù)庫連接不成功也不會不斷的重試。如果要設置重連次數(shù)要設置 connection-error-retry-attempts。
到此這篇關于springboot druid數(shù)據(jù)庫連接池連接失敗后一直重連的解決方法的文章就介紹到這了,更多相關springboot druid連接池連接失敗內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要介紹了Java中反射reflect的基礎知識講解,Java中的反射,它算是Java當中非常底層的一個技術,平時我們我們用得不多,實際上它也的確非常復雜同時也難以理解,但是涉及到底層的東西Java都給我們封裝好了,我們直接拿來調用即可,需要的朋友可以參考下2023-10-10
這篇文章主要介紹了Java中線程休眠編程實例,本文直接給出代碼實例,并對休眠方法做了一番講解,需要的朋友可以參考下2015-06-06
這篇文章主要介紹了Spring的編程式事務和聲明式事務的相關內容，涉及Spring事務屬性、Spring事務的基本類等知識，需要的朋友可以了解下。2017-09-09
SpringBoot+jpa配置如何根據(jù)實體類自動創(chuàng)建表
這篇文章主要介紹了SpringBoot+jpa配置如何根據(jù)實體類自動創(chuàng)建表，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
SpringBoot中使用JdbcTemplate訪問Oracle數(shù)據(jù)庫的案例詳解
JdbcTemplate是Spring框架中的一個核心類,用于簡化Java應用程序與關系型數(shù)據(jù)庫的交互操作,本文給大家介紹SpringBoot中使用JdbcTemplate訪問Oracle數(shù)據(jù)庫的方法,感興趣的朋友跟隨小編一起看看吧2023-10-10
這篇文章主要介紹了關于Java中的繼承和組合的一個錯誤使用的例子,需要的朋友可以參考下2016-08-08
這篇文章主要介紹了java線程池工作隊列飽和策略代碼示例，涉及線程池的簡單介紹，工作隊列飽和策略的分析及代碼示例，具有一定參考價值，需要的朋友可以了解下。2017-11-11
MAVEN_HOME、M2_HOME,maven環(huán)境變量設置方式
這篇文章主要介紹了MAVEN_HOME、M2_HOME,maven環(huán)境變量設置方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-07-07
本篇文章給大家詳細講述了Java構造函數(shù)與普通函數(shù)用法以及相關知識點，對此有興趣的朋友可以參考學習下。2018-03-03
java使用JDBC動態(tài)創(chuàng)建數(shù)據(jù)表及SQL預處理的方法
這篇文章主要介紹了java使用JDBC動態(tài)創(chuàng)建數(shù)據(jù)表及SQL預處理的方法,涉及JDBC操作數(shù)據(jù)庫的連接、創(chuàng)建表、添加數(shù)據(jù)、查詢等相關實現(xiàn)技巧,需要的朋友可以參考下2017-08-08