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

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 的 Goroutine 的执行情况，当执行耗时的 SQL 语句占用连接时。

例子代码如下：

package mainimport ( "database/sql" "log" _ "github.com/go-sql-driver/mysql")var DB *sql.DBvar 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: 552019/10/02 18:14:25 worker: 17 , connection id: 552019/10/02 18:14:25 worker: 11 , connection id: 552019/10/02 18:14:35 worker: 3 , connection id: 552019/10/02 18:14:45 worker: 0 , connection id: 552019/10/02 18:14:45 worker: 4 , connection id: 552019/10/02 18:14:45 worker: 5 , connection id: 552019/10/02 18:15:05 worker: 7 , connection id: 552019/10/02 18:15:25 worker: 15 , connection id: 552019/10/02 18:15:25 worker: 6 , connection id: 552019/10/02 18:15:35 worker: 13 , connection id: 552019/10/02 18:15:45 worker: 19 , connection id: 552019/10/02 18:15:45 worker: 10 , connection id: 552019/10/02 18:15:45 worker: 12 , connection id: 552019/10/02 18:15:55 worker: 14 , connection id: 552019/10/02 18:16:15 worker: 8 , connection id: 552019/10/02 18:16:35 worker: 18 , connection id: 552019/10/02 18:16:35 worker: 1 , connection id: 552019/10/02 18:17:05 worker: 16 , connection id: 552019/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 3306tcp4 0 0 127.0.0.1.3306 127.0.0.1.59518 ESTABLISHEDtcp4 0 0 127.0.0.1.59518 127.0.0.1.3306 ESTABLISHEDtcp46 0 0 *.3306 *.* LISTEN登录后复制

从结果可以看到，20个goroutine轮流使用同一个连接(connection id 为55)执行sql语句。

其他goroutine在连接被占用时会进入阻塞状态。直到连接使用完后，其他goroutine才可以使用连接。

即使多个goroutine在执行SQL，也没有创建多个连接。

因此，最大连接数设置生效。

有些读者可能会问，没有看到设置最大空闲连接数，此时最大空间连接数是多少？

前面已经提到，默认的最大空闲连接数是2.

下面再来测试下最大空间连接数。

2.最大空闲连接数测试

下面例子中，设置最大连接数为1，最大空闲连接数为0.

并且每隔3s执行一条SQL语句。

代码如下：

package mainimport ( "database/sql" "log" "time" _ "github.com/go-sql-driver/mysql")var DB *sql.DBvar 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: 262019/10/13 23:06:03 connection id: 272019/10/13 23:06:06 connection id: 282019/10/13 23:06:09 connection id: 292019/10/13 23:06:12 connection id: 302019/10/13 23:06:15 connection id: 312019/10/13 23:06:18 connection id: 322019/10/13 23:06:21 connection id: 332019/10/13 23:06:24 connection id: 342019/10/13 23:06:27 connection id: 352019/10/13 23:06:30 connection id: 362019/10/13 23:06:33 connection id: 372019/10/13 23:06:36 connection id: 38

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

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。