快捷導(dǎo)航

jdbc中自帶MySQL?連接池實(shí)踐示例

更新時(shí)間：2022年07月21日 12:01:38 作者：FunTester

這篇文章主要為大家介紹了jdbc中自帶MySQL連接池實(shí)踐示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

引言

在上期文章自定義 MySQL 連接池中，我提到了沒(méi)找到一個(gè)特別合適的 MySQL 連接池實(shí)現(xiàn)，所以自己寫(xiě)了一個(gè)基于通用池化框架commons-pool2的 MySQL 連接池，并且模仿了 Go 語(yǔ)言的gorm框架設(shè)計(jì)思路，把借和還的操作不暴露給用戶，只處理用戶發(fā)來(lái)的 SQL 語(yǔ)句的思路，封裝了一個(gè)com.funtester.db.mysql.MysqlPool。

可惜打臉的事情來(lái)的太快了，在錄制視頻的時(shí)候偶然發(fā)現(xiàn)了 Intellij 代碼提示有個(gè)com.mysql.cj.jdbc.MysqlConnectionPoolDataSource的類。這還了得，看名字就知道是我想要的那款。

經(jīng)過(guò)查閱資料，好像也沒(méi)搜到太多詳細(xì)的資料?？垂俜降奈臋n，也是遮遮掩掩，仿佛并不很推薦這個(gè)實(shí)現(xiàn)。關(guān)于 MySQL 連接池的管理，在 spring 語(yǔ)境下，應(yīng)該有相當(dāng)多更好的實(shí)踐。但是對(duì)于測(cè)試來(lái)講，那些太重，不太適合腳本化使用。不管怎樣，我還是注意到了這個(gè) MySQL 連接池的實(shí)現(xiàn)類。

關(guān)于它的名字，我在 stackoverflow 看到有人討論，表示說(shuō)叫它 MySQL 連接池并不恰當(dāng)，因?yàn)樗皇歉咝Ч芾砹诉B接的資源使用，并沒(méi)有池化。這一點(diǎn)在我實(shí)測(cè)中也發(fā)現(xiàn)了，使用獲取連接的時(shí)候，一直都是在創(chuàng)建新的連接。然后再連接空閑時(shí)間超過(guò)了設(shè)置之后，回收掉這個(gè)連接，回收的方法就是調(diào)用close()方法。

對(duì)于一般池化技術(shù)來(lái)講，就是為了解決重用問(wèn)題。如果連接并不重用，而是進(jìn)行高效資源回收管理，其實(shí)并不算一個(gè)非常優(yōu)秀的解決方案。

下面是com.mysql.cj.jdbc.MysqlConnectionPoolDataSource使用實(shí)踐，比較簡(jiǎn)單，API 倒是挺多的，但是大多數(shù)都用不到。

package com.funtest.groovytest
import com.funtester.frame.SourceCode
import com.mysql.cj.jdbc.MysqlConnectionPoolDataSource
class MysqlPoolTe extends SourceCode {
    public static void main(String[] args) {
        def query = "select * from testers limit 2;"
        def source = new MysqlConnectionPoolDataSource()
        source.setServerName("localhost")
        source.setPort(3306)
        source.setUser("root")
        source.setPassword("root123456")
        source.setDatabaseName("funtester")
        source.setAllowMultiQueries(true)
        def connection = source.getPooledConnection()
        def statement = connection.getConnection().createStatement()
        while (true) {
            sleep(1)
            def query = statement.executeQuery(query)
            while (query.next()) {
                output query.getString("name")
            }
        }
    }
}

這里有個(gè)很容易的坑，就是有個(gè)setURL()還有一個(gè)setUrl()，其實(shí)這兩個(gè)沒(méi)有任何區(qū)別，我只能說(shuō)可能為了兼容舊版本把。還有就是設(shè)置了 URL 之后，好像 database 設(shè)置不起作用了，也是妙明感覺(jué)設(shè)計(jì)真糟心，所以在上面的案例中我也沒(méi)有用到這倆方法。

下面是我的測(cè)試結(jié)果，如圖所示創(chuàng)建了超級(jí)多的線程，但是一直連接的只有很少。大概是經(jīng)過(guò)幾秒鐘就會(huì)被回收一次，但是總創(chuàng)建數(shù)依舊非常高。