Maison >base de données >tutoriel mysql >Comment définir le nombre maximum de connexions et le nombre maximum de connexions inactives dans Golang combiné avec MySQL
Comment définir le nombre maximum de connexions et le nombre maximum de connexions inactives dans Golang combiné avec MySQL
- 王林avant
- 2023-06-03 14:15:531439parcourir
Concernant le nombre maximum de connexions et le nombre maximum de connexions inactives, ils sont définis en database/sql dans la bibliothèque standard golang.
Le package de pilotes SQL utilisé pour se connecter à MySQL dans l'exemple de cet article est github.com/go-sql-driver/mysql.
L'interface pour définir le maximum le nombre de connexions est
func (db *DB) SetMaxOpenConns(n int)
Définissez le nombre maximum de connexions pouvant être ouvertes pour se connecter à MySQL.
Si n
La valeur par défaut est 0, ce qui signifie qu'il n'y a pas de limite sur le nombre de connexions.
Un autre paramètre lié au nombre de connexions est MaxIdleConns, qui représente le nombre maximum de connexions inactives.
Si MaxIdleConns est supérieur à 0 et supérieur à MaxOpenConns, alors MaxIdleConns sera ajusté pour être égal à MaxOpenConns, et les connexions en excès seront fermées lorsqu'il y a des connexions en excès.
L'interface permettant de définir le nombre maximum de connexions inactives est :
func (db *DB) SetMaxIdleConns(n int)
Quand n
Le nombre maximum par défaut de connexions inactives est de 2 :
const defaultMaxIdleConns = 2
Concernant la relation entre les connexions ouvertes et les connexions inactives, veuillez ajouter : # 🎜🎜 #
Connexion ouverte = connexion en cours d'utilisation (inuse) + connexion en état d'inactivité (idle)Ce qui suit est le nombre maximum de connexions et tester et vérifier le nombre maximum de connexions inactives. 1. Test du nombre maximum de connexionsDéfinissez d'abord le nombre maximum de connexions ouvertes sur 1, puis ouvrez 20 goroutines, chaque goroutine exécute l'instruction SQL et imprime le nombre utilisé pour exécuter le sql L'identifiant de connexion de la connexion. Observez l'exécution d'autres Goroutines qui doivent exécuter SQL lors de l'exécution d'instructions SQL fastidieuses occupant des connexions. L'exemple de code est le suivant :
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 travailleur : 2 , identifiant de connexion : 55Comme vous pouvez le voir sur les résultats, 20 goroutines utilisent à tour de rôle la même connexion (l'identifiant de connexion est 55) pour exécuter des instructions SQL. D'autres goroutines entreront dans l'état de blocage lorsque la connexion sera occupée. Aucune autre goroutine ne peut utiliser la connexion jusqu'à ce que la connexion soit épuisée. Même si plusieurs goroutines exécutent SQL, plusieurs connexions ne sont pas créées. Par conséquent, le paramètre du nombre maximum de connexions prend effet. Certains lecteurs peuvent demander : si vous ne voyez pas le nombre maximum de connexions inactives défini, quel est le nombre maximum de connexions spatiales à ce moment ? Comme mentionné précédemment, le nombre maximum de connexions inactives par défaut est de 2. Testons le nombre maximum de connexions spatiales. 2. Test du nombre maximum de connexions inactivesDans l'exemple suivant, définissez le nombre maximum de connexions inactives sur 1 et le nombre maximum de connexions inactives sur 0.#🎜🎜 #2019/10/02 18:14:25 travailleur : 17 , identifiant de connexion : 55
2019/10/02 18:14:25 travailleur : 11 , identifiant de connexion : 55# 🎜🎜# 2019/10/02 18:14:35 travailleur : 3 , identifiant de connexion : 55
2019/10/02 18:14:45 travailleur : 0 , identifiant de connexion : 55
2019/10 /02 18 :14:45 travailleur : 4 , identifiant de connexion : 55
2019/10/02 18:14:45 travailleur : 5 , identifiant de connexion : 55
2019/10/02 18:15 : 05 travailleur : 7, identifiant de connexion : 55
2019/10/02 18:15:25 travailleur : 15, identifiant de connexion : 55
2019/10/02 18:15:25 travailleur : 6, connexion identifiant : 55
2019/10/02 18:15:35 travailleur : 13 , identifiant de connexion : 55
2019/10/02 18:15:45 travailleur : 19 , identifiant de connexion : 55#🎜🎜 #2019/ 10/02 18:15:45 travailleur : 10 , identifiant de connexion : 55
2019/10/02 18:15:45 travailleur : 12 , identifiant de connexion : 55
2019/10/02 18:15 :55 travailleur : 14 , identifiant de connexion : 55
2019/10/02 18:16:15 travailleur : 8 , identifiant de connexion : 55
2019/10/02 18:16:35 travailleur : 18 , identifiant de connexion : 55
2019/10/02 18:16:35 travailleur : 1 , identifiant de connexion : 55
2019/10/02 18:17:05 travailleur : 16 , identifiant de connexion : 55#🎜 🎜#2019/10/02 18:17:35 travailleur : 9, identifiant de connexion : 55
Utilisez show processlist pour afficher la connexionmysql> 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)#🎜🎜 #Utilisez netstat pour afficher la connexionnetstat -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
Et exécutez une instruction SQL toutes les 3 secondes.
Le code est le suivant :
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 identifiant de connexion : 26#🎜 🎜#2019/10/13 23:06:03 identifiant de connexion : 272019/10/13 23:06:06 identifiant de connexion : 28
2019/10/13 23:06 : 09 identifiant de connexion : 292019/10/13 23:06:12 identifiant de connexion : 30
2019/10/13 23:06:15 identifiant de connexion : 312019/10/13 23:06 :18 identifiant de connexion : 322019/10/13 23:06:21 identifiant de connexion : 33
2019/10/13 23:06:24 identifiant de connexion : 34
2019 /10/ 13 23:06:27 identifiant de connexion : 35
2019/10/13 23:06:30 identifiant de connexion : 36
2019/10/13 23:06:33 identifiant de connexion : 37# 🎜🎜# 2019/10/13 23:06:36 identifiant de connexion : 38
Comme le montrent les résultats, l'identifiant de connexion utilisé à chaque fois que SQL est exécuté est différent.
Définissez le nombre maximum de connexions inactives à 0. Après chaque exécution de SQL, la connexion ne sera pas mise dans le pool de connexions inactives, mais sera fermée lors de la prochaine exécution de SQL, une nouvelle. la connexion sera rétablie.
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!