Comment fermer correctement les connexions de la base de données pour plusieurs goroutine partagée dans le langage go?

Clôture élégante de la connexion de base de données partagée GO multi-goroutine

Dans la programmation simultanée GO, plusieurs connexions de base de données partagées Goroutine sont des scénarios courants. Un mauvais arrêt de connexion peut entraîner une perte de données ou un crash du programme. Cet article explore comment fermer en toute sécurité les connexions de la base de données pour plusieurs goroutine partagée.

Analyse des problèmes:

L'utilisation defer db.Close() directement dans le goroutine principal ne peut garantir que tous les enfants Goroutines ont effectué des opérations de base de données, ce qui peut entraîner la fermeture de la connexion à l'avance et augmenter une erreur. L'utilisation defer db.Close() chez chaque enfant, la goroutine entraînera la fermeture de la connexion plusieurs fois, et la même erreur sera augmentée.

Solution:

Il est recommandé d'utiliser des compteurs et sync.WaitGroup pour coordonner l'exécution de Goroutine et la fermeture des connexions de la base de données.

Exemple de code:

 package principal

importer (
    "FMT"
    "sync"
    "temps"

    "base de données / SQL"
    _ "github.com/go-sql-driver/mysql" // Remplacez par votre pilote de base de données)

Tapez DBConn Struct {
    Conn * sql.db
    wg * sync.waitgroup
}

func opendb () (* dbConn, error) {
    db, err: = sql.open ("mysql", "utilisateur: mot de passe @ tcp (127.0.0.1:3306) / base de données") // Remplacez par votre chaîne de connexion de base de données si err! = nil {
        Renvoie nil, euh
    }
    return & dbConn {Conn: db, wg: & sync.waitgroup {}}, nil
}

func (dc * dbConn) close () error {
    dc.wg.wait () // attendez que tous les Goroutines terminent le retour dc.conn.close ()
}

func querydb (dc * dbConn, i int) {
    différer dc.wg.done ()
    dc.wg.add (1) // compteur est ajouté 1
    // ... Fonctionnement de la base de données ...
    Time.Sleep (time.second) // Simuler les opérations de la base de données FMT.printf ("Goroutine% D Finish \ n", i)
}

func main () {
    dc, err: = opendendb ()
    Si err! = Nil {
        fmt.println ("Base de données d'ouverture d'erreur:", err)
        Retour
    }
    différer dc.close () // assurez-vous de fermer la connexion en dernier pour i: = 0; I <p> <strong>Explication du code:</strong></p><ol>
<li> La structure <code>dbConn</code> contient la connexion de la base de données et <code>sync.WaitGroup</code> pour gérer l'exécution de Goroutines.</li>
<li> La fonction <code>openDb</code> ouvre la connexion de la base de données et renvoie <code>dbConn</code> .</li>
<li> La méthode <code>close</code> utilise <code>dc.wg.Wait()</code> pour attendre que tous les Goroutines se terminent avant de fermer la connexion de la base de données.</li>
<li> <code>querydb</code> utilise <code>dc.wg.Add(1)</code> pour augmenter le compteur avant d'exécuter l'opération de base de données, et utilise <code>defer dc.wg.Done()</code> pour diminuer le compteur une fois l'opération terminée.</li>
<li> <code>main</code> démarre plusieurs Goroutines pour exécuter les fonctions <code>querydb</code> et ferme finalement la connexion de la base de données à l'aide <code>defer dc.close()</code> .</li>
</ol><p> Cette méthode garantit que tous les Goroutines complètent les opérations de base de données, puis ferment la connexion de la base de données, en évitant la perte de données et les erreurs. N'oubliez pas de remplacer la chaîne et le pilote de connexion de la base de données dans l'exemple de code. Si le temps de fonctionnement de la base de données est imprévisible, des mécanismes plus complexes peuvent être nécessaires pour attendre que tous les Goroutines se terminent, comme la signalisation à l'aide d'un canal.</p>

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!