Table des matières
Le code est le suivant :
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

Jun 03, 2023 pm 02:15 PM
mysql golang

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)
Copier après la connexion

Définissez le nombre maximum de connexions pouvant être ouvertes pour se connecter à MySQL.

Si n <= 0, cela signifie qu'il n'y a pas de limite sur le nombre de connexions ouvertes.

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)
Copier après la connexion

Quand n<=0, le pool de connexions inactives ne sera pas utilisé, c'est-à-dire lorsque l'inactive Le pool de connexions n'est pas utilisé, le pool de connexions inactif ne sera pas utilisé. Les connexions utilisées n'y seront pas stockées. Par conséquent, cette méthode ne réutilise pas la connexion et une nouvelle connexion doit être rétablie à chaque fois qu'une instruction SQL est exécutée. <=0时,空闲连接池不会被使用,即不使用空闲连接池时,未使用的连接将不会被存入其中。因此,这种方法不会重复利用连接,每次执行SQL语句都需要重新建立新的连接。

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 connexions

Dé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
        }

}
Copier après la connexion

output

2019/10/02 18:14:25 travailleur : 2 , identifiant de connexion : 55

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 connexion

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)
Copier après la connexion
#🎜🎜 #Utilisez netstat pour afficher la connexion

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
Copier après la connexion
Comme 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 inactives

Dans l'exemple suivant, définissez le nombre maximum de connexions inactives sur 1 et le nombre maximum de connexions inactives sur 0.#🎜🎜 #

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)
}
Copier après la connexion

output:

2019/10/13 23:06:00 identifiant de connexion : 26#🎜 🎜#2019/10/13 23:06:03 identifiant de connexion : 27

2019/10/13 23:06:06 identifiant de connexion : 28

2019/10/13 23:06 : 09 identifiant de connexion : 29

2019/10/13 23:06:12 identifiant de connexion : 30

2019/10/13 23:06:15 identifiant de connexion : 31
2019/10/13 23:06 :18 identifiant de connexion : 32

2019/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!

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Outils d'IA chauds

Undresser.AI Undress

Undresser.AI Undress

Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover

AI Clothes Remover

Outil d'IA en ligne pour supprimer les vêtements des photos.

Undress AI Tool

Undress AI Tool

Images de déshabillage gratuites

Clothoff.io

Clothoff.io

Dissolvant de vêtements AI

AI Hentai Generator

AI Hentai Generator

Générez AI Hentai gratuitement.

Article chaud

R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
2 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Repo: Comment relancer ses coéquipiers
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: Comment obtenir des graines géantes
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Combien de temps faut-il pour battre Split Fiction?
3 Il y a quelques semaines By DDD

Outils chauds

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Comment lire et écrire des fichiers en toute sécurité avec Golang ? Comment lire et écrire des fichiers en toute sécurité avec Golang ? Jun 06, 2024 pm 05:14 PM

Lire et écrire des fichiers en toute sécurité dans Go est crucial. Les directives incluent : Vérification des autorisations de fichiers Fermeture de fichiers à l'aide de reports Validation des chemins de fichiers Utilisation de délais d'attente contextuels Le respect de ces directives garantit la sécurité de vos données et la robustesse de vos applications.

Comment corriger les erreurs mysql_native_password non chargé sur MySQL 8.4 Comment corriger les erreurs mysql_native_password non chargé sur MySQL 8.4 Dec 09, 2024 am 11:42 AM

L'un des changements majeurs introduits dans MySQL 8.4 (la dernière version LTS en 2024) est que le plugin « MySQL Native Password » n'est plus activé par défaut. De plus, MySQL 9.0 supprime complètement ce plugin. Ce changement affecte PHP et d'autres applications

Golang Framework vs Go Framework : comparaison de l'architecture interne et des fonctionnalités externes Golang Framework vs Go Framework : comparaison de l'architecture interne et des fonctionnalités externes Jun 06, 2024 pm 12:37 PM

La différence entre le framework GoLang et le framework Go se reflète dans l'architecture interne et les fonctionnalités externes. Le framework GoLang est basé sur la bibliothèque standard Go et étend ses fonctionnalités, tandis que le framework Go se compose de bibliothèques indépendantes pour atteindre des objectifs spécifiques. Le framework GoLang est plus flexible et le framework Go est plus facile à utiliser. Le framework GoLang présente un léger avantage en termes de performances et le framework Go est plus évolutif. Cas : gin-gonic (framework Go) est utilisé pour créer l'API REST, tandis qu'Echo (framework GoLang) est utilisé pour créer des applications Web.

Le rôle et les avantages du framework Golang dans le développement cloud natif Le rôle et les avantages du framework Golang dans le développement cloud natif Jun 06, 2024 am 11:32 AM

Le framework Go joue un rôle important dans le développement natif du cloud, notamment la création de microservices, le déploiement de fonctions cloud, l'orchestration de conteneurs et le traitement des flux de données. Ses avantages sont : hautes performances, évolutivité, robustesse et écosystème riche. De plus, les cas pratiques du framework Go démontrent son application dans les fonctions cloud. En utilisant le framework Gin, vous pouvez facilement créer et déployer des fonctions cloud avec le message « Hello, CloudFunctions ! ».

Surveillance des gouttelettes Redis à l'aide du service d'exportation Redis Surveillance des gouttelettes Redis à l'aide du service d'exportation Redis Jan 06, 2025 am 10:19 AM

Une surveillance efficace des bases de données Redis est essentielle pour maintenir des performances optimales, identifier les goulots d'étranglement potentiels et garantir la fiabilité globale du système. Redis Exporter Service est un utilitaire robuste conçu pour surveiller les bases de données Redis à l'aide de Prometheus. Ce didacticiel vous guidera tout au long de l'installation et de la configuration complètes de Redis Exporter Service, vous garantissant ainsi d'établir une solution de surveillance de manière transparente. En suivant ce didacticiel, vous obtiendrez une configuration de surveillance entièrement opérationnelle pour surveiller efficacement les mesures de performances de votre base de données Redis.

Quels sont les éléments courants auxquels il faut prêter attention lors de l'utilisation du framework Golang ? Quels sont les éléments courants auxquels il faut prêter attention lors de l'utilisation du framework Golang ? Jun 06, 2024 pm 01:33 PM

Lorsque vous utilisez le framework Golang, vous devez faire attention à : vérifier si la route correspond à la demande pour éviter les erreurs de routage. Utilisez le middleware avec prudence pour éviter une dégradation des performances. Gérez correctement les connexions à la base de données pour éviter les problèmes de performances ou les plantages. Utilisez des wrappers d’erreurs pour gérer les erreurs et garantir que votre code est clair et facile à déboguer. Obtenez des packages tiers auprès de sources réputées et maintenez les packages à jour.

Comment gérer la redirection HTTP dans Golang ? Comment gérer la redirection HTTP dans Golang ? Jun 06, 2024 am 11:46 AM

Lors de la gestion des redirections HTTP dans Go, vous devez comprendre les types de redirection suivants : 301 Move Permanent 302 Found 303 View Others Les redirections peuvent être gérées via le type http.Client et la méthode Do dans le package net/http, ainsi que via la fonction CheckRedirect personnalisée. pour suivre les redirections.

Comment utiliser un fuseau horaire prédéfini avec Golang ? Comment utiliser un fuseau horaire prédéfini avec Golang ? Jun 06, 2024 pm 01:02 PM

L'utilisation de fuseaux horaires prédéfinis dans Go comprend les étapes suivantes : Importez le package « time ». Chargez un fuseau horaire spécifique via la fonction LoadLocation. Utilisez le fuseau horaire chargé dans des opérations telles que la création d'objets Time, l'analyse de chaînes horaires et l'exécution de conversions de date et d'heure. Comparez les dates en utilisant différents fuseaux horaires pour illustrer l'application de la fonctionnalité de fuseau horaire prédéfini.

See all articles