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

Video Face Swap

Video Face Swap

Échangez les visages dans n'importe quelle vidéo sans effort grâce à notre outil d'échange de visage AI entièrement gratuit !

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)

Place de MySQL: bases de données et programmation Place de MySQL: bases de données et programmation Apr 13, 2025 am 12:18 AM

La position de MySQL dans les bases de données et la programmation est très importante. Il s'agit d'un système de gestion de base de données relationnel open source qui est largement utilisé dans divers scénarios d'application. 1) MySQL fournit des fonctions efficaces de stockage de données, d'organisation et de récupération, en prenant en charge les systèmes Web, mobiles et de niveau d'entreprise. 2) Il utilise une architecture client-serveur, prend en charge plusieurs moteurs de stockage et optimisation d'index. 3) Les usages de base incluent la création de tables et l'insertion de données, et les usages avancés impliquent des jointures multiples et des requêtes complexes. 4) Des questions fréquemment posées telles que les erreurs de syntaxe SQL et les problèmes de performances peuvent être déboguées via la commande Explication et le journal de requête lente. 5) Les méthodes d'optimisation des performances comprennent l'utilisation rationnelle des indices, la requête optimisée et l'utilisation des caches. Les meilleures pratiques incluent l'utilisation des transactions et des acteurs préparés

Comment se connecter à la base de données d'Apache Comment se connecter à la base de données d'Apache Apr 13, 2025 pm 01:03 PM

Apache se connecte à une base de données nécessite les étapes suivantes: Installez le pilote de base de données. Configurez le fichier web.xml pour créer un pool de connexion. Créez une source de données JDBC et spécifiez les paramètres de connexion. Utilisez l'API JDBC pour accéder à la base de données à partir du code Java, y compris l'obtention de connexions, la création d'instructions, les paramètres de liaison, l'exécution de requêtes ou de mises à jour et de traitement des résultats.

Comment démarrer MySQL par Docker Comment démarrer MySQL par Docker Apr 15, 2025 pm 12:09 PM

Le processus de démarrage de MySQL dans Docker se compose des étapes suivantes: Tirez l'image MySQL pour créer et démarrer le conteneur, définir le mot de passe de l'utilisateur racine et mapper la connexion de vérification du port Créez la base de données et l'utilisateur accorde toutes les autorisations sur la base de données

Rôle de MySQL: Bases de données dans les applications Web Rôle de MySQL: Bases de données dans les applications Web Apr 17, 2025 am 12:23 AM

Le rôle principal de MySQL dans les applications Web est de stocker et de gérer les données. 1.MySQL traite efficacement les informations utilisateur, les catalogues de produits, les enregistrements de transaction et autres données. 2. Grâce à SQL Query, les développeurs peuvent extraire des informations de la base de données pour générer du contenu dynamique. 3.MySQL fonctionne basé sur le modèle client-serveur pour assurer une vitesse de requête acceptable.

Exemple d'introduction de Laravel Exemple d'introduction de Laravel Apr 18, 2025 pm 12:45 PM

Laravel est un cadre PHP pour la création facile des applications Web. Il fournit une gamme de fonctionnalités puissantes, notamment: Installation: Installez le Laravel CLI globalement avec Composer et créez des applications dans le répertoire du projet. Routage: définissez la relation entre l'URL et le gestionnaire dans Routes / web.php. Voir: Créez une vue dans les ressources / vues pour rendre l'interface de l'application. Intégration de la base de données: fournit une intégration prête à l'emploi avec des bases de données telles que MySQL et utilise la migration pour créer et modifier des tables. Modèle et contrôleur: le modèle représente l'entité de la base de données et le contrôleur traite les demandes HTTP.

Comment installer MySQL dans CentOS7 Comment installer MySQL dans CentOS7 Apr 14, 2025 pm 08:30 PM

La clé de l'installation de MySQL est d'élégance pour ajouter le référentiel MySQL officiel. Les étapes spécifiques sont les suivantes: Téléchargez la clé GPG officielle MySQL pour empêcher les attaques de phishing. Ajouter un fichier de référentiel MySQL: RPM -UVH https://dev.mysql.com/get/mysql80-community-release-el7-3.noarch.rpm Mise à jour du référentiel Cache: Yum Update Installation Mysql: Yum install install install starting starting mysql Service: SystemCTL start start mysqld starger bugo boartup Service mysql Service: SystemCTL start start mysqld starger bugo bo onthing staring Service mysql Service: SystemCTL Start Start MySQLD Set Out Up Boaching Staring Service MySQL Service: SystemCTL Start Start MysQL

CentOS installe MySQL CentOS installe MySQL Apr 14, 2025 pm 08:09 PM

L'installation de MySQL sur CENTOS implique les étapes suivantes: Ajout de la source MySQL YUM appropriée. Exécutez la commande YUM Install MySQL-Server pour installer le serveur MySQL. Utilisez la commande mysql_secure_installation pour créer des paramètres de sécurité, tels que la définition du mot de passe de l'utilisateur racine. Personnalisez le fichier de configuration MySQL selon les besoins. Écoutez les paramètres MySQL et optimisez les bases de données pour les performances.

Résolvez le problème de la connexion de la base de données: un cas pratique d'utilisation de la bibliothèque Minii / DB Résolvez le problème de la connexion de la base de données: un cas pratique d'utilisation de la bibliothèque Minii / DB Apr 18, 2025 am 07:09 AM

J'ai rencontré un problème délicat lors du développement d'une petite application: la nécessité d'intégrer rapidement une bibliothèque d'opération de base de données légère. Après avoir essayé plusieurs bibliothèques, j'ai constaté qu'ils avaient trop de fonctionnalités ou ne sont pas très compatibles. Finalement, j'ai trouvé Minii / DB, une version simplifiée basée sur YII2 qui a parfaitement résolu mon problème.

See all articles