Bagaimana untuk menyelesaikan masalah bahawa kolam sambungan pangkalan data springboot druid terus menyambung semula selepas kegagalan sambungan

Apabila saya menggunakan mesin ujian Alibaba Cloud peribadi saya, apabila melihat log keluaran masa nyata, saya mendapati bahawa selepas sambungan pangkalan data gagal, pelayan terus cuba menyambung semula. Pada mulanya ia dianggap bahawa sistem itu diserang berterusan, tetapi selepas memulakan semula perkhidmatan, penyambungan semula berterusan tidak lagi berlaku. Lihat log keluaran berikut:

2022-02-09 11:04:58.896 ERROR 16876 --- [eate-1550991149] com.alibaba.druid.pool.DruidDataSource, : buat sambungan SQLException url: jdbc:mysql://47.98.67,98:1234/test?useSSL=false&characterEncoding=UTF-8&serverTimezone=UTC, errorCode 1045, state 28000

java.sql.SQLException: Akses definitif pengguna root' @'113.90.123.76' (menggunakan kata laluan: YES)
di com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129) ~[mysql-connector-java-8.0.16. jar: 8.0.16]
di com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) ~[mysql-connector-java-8.0.16.jar:8.0.16]
di com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[mysql-connector-java-8.0.16.jar:8.0.16]
di 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.7e51f00a783d7eb8f68358439dee7daf(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]
di com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:199) ~[mysql-connector-java-8.0.16.jar:8.0 .16 ]
di 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]
di com.alibaba.druid.pool.DruidAbstractDataSource.createPhysicalConnection(DruidAbstractDataSource.java:1560) ~[druid-1.1.10.10] 🎜> di com.alibaba.druid.pool.DruidAbstractDataSource.createPhysicalConnection(DruidAbstractDataSource.java:1623) ~[druid-1.1.10.jar:1.1.10]
di com.alibabah.druidConnection$ .run (DruidDataSource.java:2468) ~[druid-1.1.10.jar:1.1.10]

Perhatikan bahawa sentiasa ada gesaan untuk kumpulan sambungan pangkalan data druid di atas mungkin masalah sambungan druid, dan kemudian selepas mengalih keluar kebergantungan druid maven, tidak akan ada masalah penyambungan semula dalam antara muka permintaan.

Sebab penyambungan semula Druid

Cari baris terakhir DruidDataSource.java:2468 dalam kod sumber di atas Cari kod sumber, CreateConnectionThread mencipta utas sambungan, lihat kod sumber 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) {
                        // 必须存在线程等待，才创建连接
                        if (poolingCount >= notEmptyWaitThreadCount //
                                && !(keepAlive && activeCount + poolingCount < minIdle)) {
                            empty.await();
                        }

                        // 防止创建超过maxActive数量的连接
                        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
            }
        }
    }

Ini ialah kelas berbilang benang dan kaedah larian mempunyai gelung untuk tanpa had untuk (;;) {} dan maklumat lokasi ralat log:

connection = createPhysicalConnection();

Jika syaratnya met errorCount > connectionErrorRetryAttempts && timeBetweenConnectErrorMillis > 0 akan cuba menyambung semula sekali lagi. kaedah dimulakan. Setiap kali sambungan gagal, ia akan ditingkatkan secara automatik 1

connectionErrorRetryAttempts

Bilangan percubaan semula ralat sambungan, nilai lalai ialah 1.

protected int  connectionErrorRetryAttempts  = 1;

timeBetweenConnectErrorMillis

Masa selang sambungan dalam milisaat. Nilai lalai ialah 500.

protected volatile long timeBetweenConnectErrorMillis = DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS;
public static final long DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS = 500;

Selepas kami gagal menyambung ke pangkalan data, kami perlu memecah masuk Antaranya,

if (breakAfterAcquireFailure) {
     break;
}

akan menukar pecah selepas perolehan kepada benar, dan mengkonfigurasinya dalam aplikasi. .properties fail seperti berikut:

spring.datasource.druid.break-after-acquire-failure=true

Jika anda ingin mencuba menyambung beberapa kali lagi, anda perlu menetapkan connection-error-retry-attempts Apabila errorCount lebih besar daripada connectionErrorRetryAttempts, ia akan memasuki keadaan dan gelung akan terganggu. Berikut ialah konfigurasi fail application.properties:

spring.datasource.druid.connection-error-retry-attempts=3

Atas ialah kandungan terperinci Bagaimana untuk menyelesaikan masalah bahawa kolam sambungan pangkalan data springboot druid terus menyambung semula selepas kegagalan sambungan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!