前言:
眼前看官们对“单个ip并发连接mysql”大概比较关切,朋友们都想要学习一些“单个ip并发连接mysql”的相关内容。那么小编在网摘上汇集了一些关于“单个ip并发连接mysql””的相关文章,希望看官们能喜欢,我们一起来学习一下吧!下载安装驱动
go get github.com/go-sql-driver/mysql
导入包:
import "database/sql"
import _ "github.com/go-sql-driver/mysql"
使用sql.Open函数创建一个连接池对象,不是单个连接。在open的时候并没有去连接数据库,只有在执行query、exce方法的时候才会去实际连接数据库。在一个应用中同样的库连接只需要保存一个sql.Open之后的db对象就可以了,不需要多次open。代码入:
var db *sql.DB
func init() {
db, _ = sql.Open("mysql", "root:@tcp(127.0.0.1:3306)/test?charset=utf8")
db.SetMaxOpenConns(2000)
db.SetMaxIdleConns(1000)
db.Ping()
}
连接池的实现关键在于SetMaxOpenConns和SetMaxIdleConns,其中:
SetMaxOpenConns用于设置最大打开的连接数,默认值为0表示不限制。
SetMaxIdleConns用于设置闲置的连接数。设置最大的连接数,可以避免并发太高导致连接mysql出现too many connections的错误。设置闲置的连接数则当开启的一个连接使用完成后可以放在池里等候下一次使用。
在使用query和exce操作数据库时,query需要管理连接,也就是把连接释放,归还连接池,通常采用defer db.Close();而exce在执行完对数据库的操作后会自动释放。比如:
rows, err := db.MysqlDB.Query(querystring)
defer rows.Close()
有些地方说rows在遍历完之后会释放连接,但我自己写的有些地方并没有释放掉,比如在实现用户登录的时候,我没有使用defer rows.Close(),结果在做压力测试的时候,数据库一下子就报“Too many connections”,单次登录不断刷新登录页面登录,使用show processlist;命令查询数据库的进程,发现是不断增大的,说明登录的时候使用的连接没有被释放,加了defer rows.Close()才得以解决问题
标签: #单个ip并发连接mysql #go语言数据库连接池 #go 数据库链接池 #go语言mysql连接池