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语句占用连接,观察其他需要执行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时,会重新建立新的连接。
3.参考
Connection pool and timeouts
Golang MySQL 连接和连接池
到此这篇关于golang结合mysql设置最大连接数和最大空闲连接数的文章就介绍到这了,更多相关golang 最大连接数和最大空闲连接数内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
原文出处:https://blog.csdn.net/lanyang123456/article/details/10194742
相关文章
- 这篇文章主要介绍了golang 调用 php7详解及实例的相关资料,需要的朋友可以参考下...2017-01-15
- 这篇文章主要介绍了用golang实现替换某个文件中的字符串操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-04-25
- 这篇文章主要介绍了golang在GRPC中设置client的超时时间,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-04-27
- 这篇文章主要介绍了解决Golang json序列化字符串时多了\的情况,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-12-24
Golang中的自定义类型之间的转换的实现(type conversion)
这篇文章主要介绍了Golang中的自定义类型之间的转换的实现(type conversion),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-21- 这篇文章主要介绍了golang与php实现计算两个经纬度之间距离的方法,结合实例形式对比分析了Go语言与php进行经纬度计算的相关数学运算技巧,需要的朋友可以参考下...2016-07-29
解决golang处理http response碰到的问题和需要注意的点
这篇文章主要介绍了解决golang处理http response碰到的问题和需要注意的点,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-12-16- 这篇文章主要介绍了golang http使用踩过的坑与填坑指南,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-04-27
- 这篇文章主要介绍了golang文件读取-按指定BUFF大小读取方式,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-12-22
- Go(又称Golang)是Google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的编程语言。这篇文章给大家介绍golang 正则表达式的相关知识,感兴趣的朋友跟随小编一起看看吧...2021-05-07
- 这次文章为大家带来的是一个比较实用的示例:利用Golang生成整数随机数,对此感兴趣的可以一起来看看。 php随机数生成一个给定范围的随机数,用 PHP 就太简单不过了,而...2017-07-06
- 这篇文章主要介绍了golang DNS服务器的简单实现操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-05-01
- 这篇文章主要介绍了golang中json和struct的使用说明,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-05-01
Fedora14 Linux系统安装Golang开发环境笔记
这篇文章主要介绍了Fedora14 Linux系统安装Golang开发环境笔记,本文讲解了2种安装方法,需要的朋友可以参考下...2020-05-01- 这篇文章主要介绍了golang去除多余空白字符(含制表符)的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-04-25
golang elasticsearch Client的使用详解
这篇文章主要介绍了golang elasticsearch Client的使用详解,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-05-04- 这篇文章主要介绍了解决golang json解析出现值为空的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-12-24
- 这篇文章主要介绍了golang中的空接口使用,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-03-30
- 这篇文章主要介绍了Golang Cron 定时任务的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-05-11
- 这篇文章主要为大家介绍了golang开发安装go-torch火焰图操作步骤...2021-11-16