golang結合mysql怎麼設定最大連線數和最大空閒連線數

關於最大連線數和最大空閒連線數，是定義在golang標準函式庫中database/sql的。

文中範例連接MySQL用的SQL driver package是github.com/go-sql-driver/mysql.

設定最大連線數的介面是

func (db *DB) SetMaxOpenConns(n int)

設定連接MySQL可以開啟的最大連線數。

如果n

預設為0，也就是不限制連線數。

另一個與連線數相關的參數是MaxIdleConns,表示最大空閒連線數。

如果MaxIdleConns 大於0，且大於MaxOpenConns，那麼將調整MaxIdleConns等於MaxOpenConns，有多餘的連線時會關閉多餘的連線。

設定最大空閒連線數的介面是：

func (db *DB) SetMaxIdleConns(n int)

當n

預設的最大空閒連接數為2：
const defaultMaxIdleConns = 2

關於開啟的連接和空閒的連接之間的關係，補充一下：

開啟的連線= 正在使用的連線(inuse) 處於空閒狀態的連線(idle)

下面對最大連線數和最大空閒連線數做下測試和驗證。

1.最大連接數測試

先設定最大開啟的連接數為1，接著開啟20個goroutine，每個goroutine執行sql語句，列印執行sql使用的連接的connection id 。觀察其他需執行 SQL 的 Goroutine 的執行情況，當執行耗時的 SQL 語句佔用連線時。

範例程式碼如下：

package main

import (
        "database/sql"
        "log"

        _ "github.com/go-sql-driver/mysql"
)

var DB *sql.DB
var dataBase = "root:Aa123456@tcp(127.0.0.1:3306)/?loc=Local&parseTime=true"

func Init() {
        var err error
        DB, err = sql.Open("mysql", dataBase)
        if err != nil {
                log.Fatalln("open db fail:", err)
        }

        DB.SetMaxOpenConns(1)

        err = DB.Ping()
        if err != nil {
                log.Fatalln("ping db fail:", err)
        }
}

func main() {
        Init()
        
        //开启20个goroutine
        for i:=0; i < 20; i++ {
                go one_worker(i)
        }
        
        select {
        }

}

func one_worker(i int) {
        var connection_id int
        err := DB.QueryRow("select CONNECTION_ID()").Scan(&connection_id)
        if err != nil {
                log.Println("query connection id failed:", err)
                return
        }

        log.Println("worker:", i, ", connection id:", connection_id)

        var result int
        err = DB.QueryRow("select sleep(10)").Scan(&result)
        if err != nil {
                log.Println("query sleep connection id faild:", err)
                return
        }

}

output

2019/10/02 18:14:25 worker: 2 , connection id: 55
2019/ 10/02 18:14:25 worker: 17 , connection id: 55
2019/10/02 18:14:25 worker: 11 , connection id: 55
2019/10/02 18:14:35 worker: 3 , connection id: 55
2019/10/02 18:14:45 worker: 0 , connection id: 55
2019/10/02 18:14:45 worker: 4 , connection id: 55
2019/10/02 18:14:45 worker: 5 , connection id: 55
2019/10/02 18:15:05 worker: 7 , connection id: 55
2019/10/02 18:15:25 worker: 15 , connection id: 55
2019/10/02 18:15:25 worker: 6 , connection id: 55
2019/10/02 18:15:35 worker: , connection id: 55
2019/10/02 18:15:45 worker: 19 , connection id: 55
2019/10/02 18:15:45 worker: 10 , connection## 2019/10/02 18:15:45 worker: 12 , connection id: 55
2019/10/02 18:15:55 worker: 14 , connection id: 55
2019/10/02 18:162 :15 worker: 8 , connection id: 55
2019/10/02 18:16:35 worker: 18 , connection id: 55
2019/10/02 18:16:35 worker: 1, connection : 55
2019/10/02 18:17:05 worker: 16 , connection id: 55
2019/10/02 18:17:35 worker: 9 , connection id: 55

##使用show processlist查看連接

mysql> show processlist;
+----+------+-----------------+------+---------+------+------------+------------------+
| Id | User | Host            | db   | Command | Time | State      | Info             |
+----+------+-----------------+------+---------+------+------------+------------------+
| 20 | root | localhost       | NULL | Query   |    0 | starting   | show processlist |
| 55 | root | localhost:59518 | NULL | Query   |    5 | User sleep | select sleep(10) |
+----+------+-----------------+------+---------+------+------------+------------------+
2 rows in set (0.00 sec)

使用netstat 查看連接

netstat -an | grep 3306
tcp4       0      0  127.0.0.1.3306         127.0.0.1.59518        ESTABLISHED
tcp4       0      0  127.0.0.1.59518        127.0.0.1.3306         ESTABLISHED
tcp46      0      0  *.3306                 *.*                    LISTEN

從結果可以看到，20個goroutine輪流使用同一個連接(connection id 為55)執行sql語句。

其他goroutine在連接被佔用時會進入阻塞狀態。直到連接使用完後，其他goroutine才可以使用連接。

即使多個goroutine在執行SQL，也沒有建立多個連線。

因此，最大連線數設定生效。

有些讀者可能會問，沒有看到設定最大空閒連線數，此時最大空間連線數是多少？

前面已經提到，預設的最大空閒連線數是2.

下面再來測試下最大空間連線數。

2.最大空閒連線數測試

下面範例中，設定最大連線數為1，最大空閒連線數為0.

並且每隔3s執行一條SQL語句。

程式碼如下：

package main

import (
        "database/sql"
        "log"
        "time"

        _ "github.com/go-sql-driver/mysql"

)

var DB *sql.DB
var dataBase = "root:Aa123456@tcp(127.0.0.1:3306)/?loc=Local&parseTime=true"

func mysqlInit() {
        var err error
        DB, err = sql.Open("mysql", dataBase)
        if err != nil {
                log.Fatalln("open db fail:", err)
        }

        DB.SetMaxOpenConns(1)
        DB.SetMaxIdleConns(0)

        err = DB.Ping()
        if err != nil {
                log.Fatalln("ping db fail:", err)
        }
}

func main() {
        mysqlInit()

        for {
                execSql()
                time.Sleep(3*time.Second)
        }
}


func execSql() {
        var connection_id int
        err := DB.QueryRow("select CONNECTION_ID()").Scan(&connection_id)
        if err != nil {
                log.Println("query connection id failed:", err)
                return
        }

        log.Println("connection id:", connection_id)
}

output:

2019/10/13 23:06:00 connection id: 26

2019/10/13 23 :06:03 connection id: 27

2019/10/13 23:06:06 connection id: 28
2019/10/13 23:06:09 connection id: 29
2019/10/13 23:06:12 connection id: 30
2019/10/13 23:06:15 connection id: 31
2019/10/13 23:06:18 connection id: 32
#2019/10/ 13 23:06:21 connection id: 33
2019/10/13 23:06:24 connection id: 34
2019/10/13 23:06:27 connection id: 35
2019/10 /13 23:06:30 connection id: 36
2019/10/13 23:06:33 connection id: 37
2019/10/13 23:06:36 connection id: 38

從結果可以看出，每次執行SQL所使用的連線connection id都不同。

設定最大閒置連線數為0，每次執行SQL後，連線不會放入空閒連線池，而是會關閉，下次執行SQL時，會重新建立新的連線。

以上是golang結合mysql怎麼設定最大連線數和最大空閒連線數的詳細內容。更多資訊請關注PHP中文網其他相關文章！