golang结合mysql怎么设置最大连接数和最大空闲连接数

来源:这里教程网 时间:2026-02-28 16:46:43 作者:

关于最大连接数和最大空闲连接数,是定义在golang标准库中database/sql的。

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

设置最大连接数的接口是

func (db *DB) SetMaxOpenConns(n int)

设置连接MySQL可以打开的最大连接数。

如果n

立即学习“go语言免费学习笔记(深入)”;

默认为0,也就是不限制连接数。

另一个与连接数相关的参数是MaxIdleConns,表示最大空闲连接数。

如果MaxIdleConns 大于0,且大于MaxOpenConns,那么将调整MaxIdleConns等于MaxOpenConns,有多余的连接时会关闭多余的连接。

设置最大空闲连接数的接口是:

func (db *DB) SetMaxIdleConns(n int)

当n

默认的最大空闲连接数为2:
const defaultMaxIdleConns = 2

关于打开的连接和空闲的连接之间的关系,补充一下:

下面对最大连接数和最大空闲连接数做下测试和验证。

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

使用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:

从结果中可以看出,每次执行SQL使用的连接connection id都不同。

设置最大空闲连接数为0,每次执行SQL后,连接不会放入空闲连接池,而是会被关闭,下次执行SQL时,会重新建立新的连接。

相关推荐