golang結(jié)合mysql設(shè)置最大連接數(shù)和最大空閑連接數(shù)
本文介紹golang 中連接MySQL時(shí)，如何設(shè)置最大連接數(shù)和最大空閑連接數(shù)。
關(guān)于最大連接數(shù)和最大空閑連接數(shù)，是定義在golang標(biāo)準(zhǔn)庫(kù)中database/sql的。
文中例子連接MySQL用的SQL driver package是github.com/go-sql-driver/mysql.
設(shè)置最大連接數(shù)的接口是
func (db *DB) SetMaxOpenConns(n int)
設(shè)置連接MySQL可以打開(kāi)的最大連接數(shù)。
如果n <= 0，表示打開(kāi)的連接數(shù)沒(méi)有限制。
默認(rèn)為0，也就是不限制連接數(shù)。
另一個(gè)與連接數(shù)相關(guān)的參數(shù)是MaxIdleConns,表示最大空閑連接數(shù)。
如果MaxIdleConns 大于0，且大于MaxOpenConns，那么將調(diào)整MaxIdleConns等于MaxOpenConns，有多余的連接時(shí)會(huì)關(guān)閉多余的連接。
設(shè)置最大空閑連接數(shù)的接口是：
func (db *DB) SetMaxIdleConns(n int)
如果n<=0，表示不使用空閑連接池，即一個(gè)連接如果不使用，不會(huì)放入空閑連接池。因此，這種方式不會(huì)復(fù)用連接，每次執(zhí)行SQL語(yǔ)句，都會(huì)重新建立新的連接。
默認(rèn)的最大空閑連接數(shù)為2：
const defaultMaxIdleConns = 2
關(guān)于打開(kāi)的連接和空閑的連接之間的關(guān)系，補(bǔ)充一下：
打開(kāi)的連接 = 正在使用的連接(inuse) + 處于空閑狀態(tài)的連接(idle)
下面對(duì)最大連接數(shù)和最大空閑連接數(shù)做下測(cè)試和驗(yàn)證。
1.最大連接數(shù)測(cè)試
首先設(shè)置最大打開(kāi)的連接數(shù)為1，接著開(kāi)啟20個(gè)goroutine，每個(gè)goroutine執(zhí)行sql語(yǔ)句，打印執(zhí)行sql使用的連接的connection id。并執(zhí)行耗時(shí)的sql語(yǔ)句占用連接，觀察其他需要執(zhí)行SQL的goroutine的執(zhí)行情況。
例子代碼如下：
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()
//開(kāi)啟20個(gè)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
從結(jié)果可以看到，20個(gè)goroutine輪流使用同一個(gè)連接(connection id 為55)執(zhí)行sql語(yǔ)句。
當(dāng)連接被占用時(shí)，其他嘗試使用連接的goroutine會(huì)被阻塞。直到連接使用完后，其他goroutine才可以使用連接。
即使多個(gè)goroutine在執(zhí)行SQL，也沒(méi)有創(chuàng)建多個(gè)連接。
因此，最大連接數(shù)設(shè)置生效。
有些讀者可能會(huì)問(wèn)，沒(méi)有看到設(shè)置最大空閑連接數(shù)，此時(shí)最大空間連接數(shù)是多少？
前面已經(jīng)提到，默認(rèn)的最大空閑連接數(shù)是2.
下面再來(lái)測(cè)試下最大空間連接數(shù)。
2.最大空閑連接數(shù)測(cè)試
下面例子中，設(shè)置最大連接數(shù)為1，最大空閑連接數(shù)為0.
并且每隔3s執(zhí)行一條SQL語(yǔ)句。
代碼如下：
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
從結(jié)果中可以看出，每次執(zhí)行SQL使用的連接connection id都不同。
設(shè)置最大空閑連接數(shù)為0，每次執(zhí)行SQL后，連接不會(huì)放入空閑連接池，而是會(huì)被關(guān)閉，下次執(zhí)行SQL時(shí)，會(huì)重新建立新的連接。
3.參考
到此這篇關(guān)于golang結(jié)合mysql設(shè)置最大連接數(shù)和最大空閑連接數(shù)的文章就介紹到這了,更多相關(guān)golang 最大連接數(shù)和最大空閑連接數(shù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要為大家介紹了go語(yǔ)言的變量定義示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-12-12
使用go實(shí)現(xiàn)一個(gè)超級(jí)mini的消息隊(duì)列的示例代碼
本文主要介紹了使用go實(shí)現(xiàn)一個(gè)超級(jí)mini的消息隊(duì)列的示例代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-12-12
這篇文章主要給大家介紹了關(guān)于Go語(yǔ)言中定時(shí)器cron使用的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧。2018-01-01
在并發(fā)編程中，協(xié)程是?Go?語(yǔ)言的核心特性之一，本文將介紹如何使用?Go?協(xié)程池構(gòu)造一個(gè)協(xié)程池，并解決函數(shù)傳參問(wèn)題、優(yōu)雅關(guān)閉協(xié)程池和保證協(xié)程安全的問(wèn)題，感興趣的可以了解一下2023-06-06
go?singleflight緩存雪崩源碼分析與應(yīng)用
這篇文章主要為大家介紹了go?singleflight緩存雪崩源碼分析與應(yīng)用示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-09-09
Go語(yǔ)言實(shí)現(xiàn)讀取文件的方式總結(jié)
這篇文章主要為大家詳細(xì)介紹了Go語(yǔ)言實(shí)現(xiàn)讀取文件的幾個(gè)方式，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)Go語(yǔ)言有一定的幫助，感興趣的小伙伴可以收藏一下2023-04-04
Golang中時(shí)間戳與時(shí)區(qū)轉(zhuǎn)換的方法詳解
時(shí)間是我們生活的基石,而在計(jì)算機(jī)科學(xué)中,時(shí)間處理顯得尤為重要,尤其是當(dāng)你在處理分布式系統(tǒng)、跨時(shí)區(qū)應(yīng)用和全球服務(wù)時(shí),時(shí)間和時(shí)區(qū)的管理變得不可或缺,在這篇文章中,我們將深入探討Golang中的時(shí)間戳與時(shí)區(qū)轉(zhuǎn)換,需要的朋友可以參考下2024-06-06
這篇文章主要為大家詳細(xì)介紹了Golang官方中的一致性哈希組件的相關(guān)知識(shí)，文中的示例代碼講解詳細(xì)，感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-04-04
Go開(kāi)發(fā)go-optioner工具實(shí)現(xiàn)輕松生成函數(shù)選項(xiàng)模式代碼
go-optioner?是一個(gè)在?Go?代碼中生成函數(shù)選項(xiàng)模式代碼的工具，可以根據(jù)給定的結(jié)構(gòu)定義自動(dòng)生成相應(yīng)的選項(xiàng)代碼，下面就來(lái)聊聊go-optioner是如何使用的吧2023-07-07
我們知道iota是go語(yǔ)言的常量計(jì)數(shù)器，本文嘗試全面總結(jié)其使用用法以及其實(shí)現(xiàn)原理，需要的朋友可以參考以下內(nèi)容，希望對(duì)大家有所幫助2022-08-08