本文介紹golang 中連接MySQL時，如何設置最大連接數和最大空閑連接數。
關於最大連接數和最大空閑連接數，是定義在golang標准庫中database/sql的。
文中例子連接MySQL用的SQL driver package是github.com/go-sql-driver/mysql.
設置最大連接數的接口是
func (db *DB) SetMaxOpenConns(n int)
設置連接MySQL可以打開的最大連接數。
如果n <= 0，表示打開的連接數沒有限制。
默認為0，也就是不限制連接數。
另一個與連接數相關的參數是MaxIdleConns,表示最大空閑連接數。
如果MaxIdleConns 大於0，且大於MaxOpenConns，那么將調整MaxIdleConns等於MaxOpenConns，有多余的連接時會關閉多余的連接。
設置最大空閑連接數的接口是：
func (db *DB) SetMaxIdleConns(n int)
如果n<=0，表示不使用空閑連接池，即一個連接如果不使用，不會放入空閑連接池。因此，這種方式不會復用連接，每次執行SQL語句，都會重新建立新的連接。
默認的最大空閑連接數為2：
const defaultMaxIdleConns = 2
關於打開的連接和空閑的連接之間的關系，補充一下：
打開的連接 = 正在使用的連接(inuse) + 處於空閑狀態的連接(idle)
下面對最大連接數和最大空閑連接數做下測試和驗證。
1.最大連接數測試
首先設置最大打開的連接數為1，接着開啟20個goroutine，每個goroutine執行sql語句，打印執行sql使用的連接的connection id。並執行耗時的sql語句占用連接，觀察其他需要執行SQL的goroutine的執行情況。
例子代碼如下：
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: 13 , connection id: 55
2019/10/02 18:15:45 worker: 19 , connection id: 55
2019/10/02 18:15:45 worker: 10 , connection id: 55
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:16: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 id: 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時，會重新建立新的連接。