Maison développement back-end Golang Comment optimiser les performances des applications Websocket en langage Go

Comment optimiser les performances des applications Websocket en langage Go

Dec 18, 2023 pm 05:42 PM
go语言 websocket 优化性能

Comment optimiser les performances des applications Websocket en langage Go

WebSocket est devenu un protocole très populaire dans le développement d'applications Web modernes en temps réel. Lors de l'écriture d'applications à l'aide de WebSocket, nous devons prendre en compte l'optimisation de ses performances pour garantir que notre application peut répondre aux demandes des clients rapidement et avec précision. Dans cet article, nous expliquons comment optimiser les performances des applications Go WebSocket et fournissons des exemples de code concrets.

  1. Utilisez la bonne bibliothèque WebSocket

Le langage Go propose plusieurs bibliothèques WebSocket populaires, telles que Gorilla WebSocket, Gobwas WebSocket et Fasthttp WebSocket. Parmi elles, la bibliothèque Gorilla WebSocket est l'une des bibliothèques les plus utilisées et offre plus de fonctionnalités que les autres bibliothèques. Lorsque vous choisissez une bibliothèque WebSocket, vous devez tenir compte de ses performances, de ses fonctionnalités et de sa facilité d'utilisation.

Dans cet article, nous utiliserons la bibliothèque Gorilla WebSocket pour faire une démonstration.

  1. Utilisez les connexions WebSocket de manière appropriée

Lors de la conception d'applications WebSocket, nous devons éviter autant que possible les connexions inutiles. Chaque connexion WebSocket consomme des ressources du serveur, donc si une opération qui aurait pu être effectuée via une seule connexion entraîne plusieurs connexions car la connexion n'est pas planifiée, le serveur sera surchargé. Il est recommandé de créer des connexions lorsque cela est nécessaire et d'utiliser des connexions de longue durée aussi souvent que possible pour éviter d'avoir à établir de nouvelles connexions.

Regardons un exemple de code pour créer une connexion WebSocket à l'aide de la bibliothèque Gorilla WebSocket :

package main

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}

func main() {
    http.HandleFunc("/ws", handleWebSocket)
    log.Fatal(http.ListenAndServe(":8080", nil))
}

func handleWebSocket(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }
    defer conn.Close()

    // use the websocket connection here
}
Copier après la connexion

Dans l'exemple de code ci-dessus, nous avons créé une fonction handleWebSocket pour gérer la connexion WebSocket. Dans cette fonction, nous utilisons la fonction upgrader.Upgrade() pour mettre à niveau la connexion HTTP vers une connexion WebSocket. Notez que la fonction defer conn.Close() est utilisée ici pour garantir que la connexion WebSocket est fermée à la fin de la fonction.

  1. Configurer correctement WebSocket

Lorsque le nombre de connexions atteint un certain niveau, l'équilibrage de charge de la configuration de WebSocket est très important. Pour les serveurs, WebSocket dispose de deux paramètres de configuration particulièrement importants : ReadBufferSize et WriteBufferSize. Ces deux paramètres contrôlent la taille du tampon de lecture et du tampon d'écriture de la connexion WebSocket. Un tampon trop grand peut affecter les performances de connexion, tandis qu'un tampon trop petit peut augmenter le nombre de transferts de données supplémentaires.

Lors de l'utilisation de la bibliothèque Gorilla WebSocket, nous pouvons modifier la taille du tampon en :

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}
Copier après la connexion

Dans l'exemple de code ci-dessus, nous définissons la taille de ReadBufferSize et WriteBufferSize à 1024 octets. Veuillez définir la taille appropriée en fonction des besoins réels.

  1. Utilisation du traitement simultané

Les applications WebSocket doivent prendre en charge un grand nombre de connexions simultanées, elles doivent donc utiliser des goroutines pour gérer chaque connexion. Vous pouvez utiliser le mécanisme goroutine fourni par la bibliothèque standard du langage Go pour gérer plusieurs connexions WebSocket. Transmettez simplement les connexions WebSocket créées aux goroutines et elles géreront facilement chaque connexion.

Voici un exemple de code qui utilise le traitement simultané des connexions WebSocket :

func main() {
    http.HandleFunc("/ws", handleWebSocket)
    log.Fatal(http.ListenAndServe(":8080", nil))
}

func handleWebSocket(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }

    go func(conn *websocket.Conn) {
        for {
            _, message, err := conn.ReadMessage()
            if err != nil {
                log.Println(err)
                return
            }

            log.Printf("received message: %s", message)
            // handle the message here
        }
    }(conn)
}
Copier après la connexion

Dans l'exemple de code ci-dessus, nous utilisons goroutine pour gérer chaque connexion WebSocket. Dans chaque goroutine, nous recevons des messages WebSocket à l'aide de la fonction conn.ReadMessage(). Nous pouvons ensuite traiter les messages dans chaque goroutine.

  1. Utilisation efficace de la mémoire

Dans chaque connexion WebSocket, le tampon créé consomme beaucoup de mémoire. Nous devons donc garantir une utilisation maximale de la mémoire. Voici quelques suggestions :

  • Cache les messages à envoyer et évite les allocations de mémoire fréquentes lors de l'écriture.
  • Utilisez un mécanisme de récupération de place régulier pour éviter les fuites de mémoire causées par des pointeurs non référencés.
  • Évitez de créer des objets volumineux ou d'appeler des bibliothèques ou des fonctions peu performantes dans le traitement des messages WebSocket.

Par exemple, l'exemple suivant montre comment mettre en cache les messages et nettoyer le cache périodiquement :

type Connection struct {
    conn    *websocket.Conn
    send    chan []byte
}

func (c *Connection) read() {
    for {
        _, _, err := c.conn.ReadMessage()
        if err != nil {
            break
        }
    }
    c.conn.Close()
}

func (c *Connection) write() {
    ticker := time.NewTicker(10 * time.Second)
    defer func() {
        ticker.Stop()
        c.conn.Close()
    }()

    var messages [][]byte
    for {
        select {
        case message, ok := <-c.send:
            if !ok {
                c.conn.WriteMessage(websocket.CloseMessage, []byte{})
                return
            }
            messages = append(messages, message)

        case <-ticker.C:
            if err := c.conn.WriteMessage(websocket.TextMessage, bytes.Join(messages, []byte{})); err != nil {
                return
            }
            messages = nil
        }
    }
}

func main() {
    http.HandleFunc("/ws", handleWebSocket)
    log.Fatal(http.ListenAndServe(":8080", nil))
}

func handleWebSocket(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }
    connection := &Connection{conn: conn, send: make(chan []byte, 256)}
    go connection.write()
    go connection.read()

    // use the connection here
}
Copier après la connexion

Dans l'exemple de code ci-dessus, nous avons créé une structure de connexion avec deux champs : conn et send. Le champ d'envoi est un canal avec un tampon dans lequel tous les messages sont mis en mémoire tampon. Nous utilisons ensuite le téléscripteur pour effacer et envoyer périodiquement des messages.

Résumé :

Pour optimiser les performances des applications WebSocket en langage Go, vous devez prendre en compte les aspects suivants :

  • Utilisez la bonne bibliothèque WebSocket
  • Utilisez la connexion WebSocket de manière raisonnable
  • Configurez WebSocket de manière raisonnable
  • Utilisez le traitement simultané
  • Utilisez efficacement la mémoire

Ceux-ci ci-dessus sont quelques-uns des moyens les plus efficaces pour optimiser les performances des applications WebSocket en langage Go. Bien que l'exemple de code présenté dans cet article ne soit pas exhaustif, vous devez suivre les recommandations ci-dessus pour améliorer les performances des applications lorsque vous développez des applications WebSocket.

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)
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Meilleurs paramètres graphiques
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Comment réparer l'audio si vous n'entendez personne
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
WWE 2K25: Comment déverrouiller tout dans Myrise
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌

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)

Quelles bibliothèques sont utilisées pour les opérations du numéro de point flottantes en Go? Quelles bibliothèques sont utilisées pour les opérations du numéro de point flottantes en Go? Apr 02, 2025 pm 02:06 PM

La bibliothèque utilisée pour le fonctionnement du numéro de point flottante dans le langage go présente comment s'assurer que la précision est ...

Quel est le problème avec le fil de file d'attente dans GO's Crawler Colly? Quel est le problème avec le fil de file d'attente dans GO's Crawler Colly? Apr 02, 2025 pm 02:09 PM

Problème de threading de file d'attente dans Go Crawler Colly explore le problème de l'utilisation de la bibliothèque Crawler Crawler dans le langage Go, les développeurs rencontrent souvent des problèmes avec les threads et les files d'attente de demande. � ...

Quelle est la différence entre la structure de définition des mots clés `var` et« type »dans le langage Go? Quelle est la différence entre la structure de définition des mots clés `var` et« type »dans le langage Go? Apr 02, 2025 pm 12:57 PM

Deux façons de définir les structures dans le langage GO: la différence entre les mots clés VAR et le type. Lorsque vous définissez des structures, GO Language voit souvent deux façons d'écrire différentes: d'abord ...

Dans Go, pourquoi les chaînes d'impression avec println et string () ont-elles des effets différents? Dans Go, pourquoi les chaînes d'impression avec println et string () ont-elles des effets différents? Apr 02, 2025 pm 02:03 PM

La différence entre l'impression de chaîne dans le langage go: la différence dans l'effet de l'utilisation de fonctions println et string () est en Go ...

Quelles bibliothèques de GO sont développées par de grandes entreprises ou fournies par des projets open source bien connus? Quelles bibliothèques de GO sont développées par de grandes entreprises ou fournies par des projets open source bien connus? Apr 02, 2025 pm 04:12 PM

Quelles bibliothèques de GO sont développées par de grandes entreprises ou des projets open source bien connus? Lors de la programmation en Go, les développeurs rencontrent souvent des besoins communs, ...

Comment résoudre le problème de conversion de type user_id lors de l'utilisation du flux redis pour implémenter les files d'attente de messages dans le langage Go? Comment résoudre le problème de conversion de type user_id lors de l'utilisation du flux redis pour implémenter les files d'attente de messages dans le langage Go? Apr 02, 2025 pm 04:54 PM

Le problème de l'utilisation de Redessstream pour implémenter les files d'attente de messages dans le langage GO consiste à utiliser le langage GO et redis ...

Que dois-je faire si les étiquettes de structure personnalisées à Goland ne sont pas affichées? Que dois-je faire si les étiquettes de structure personnalisées à Goland ne sont pas affichées? Apr 02, 2025 pm 05:09 PM

Que dois-je faire si les étiquettes de structure personnalisées à Goland ne sont pas affichées? Lorsque vous utilisez Goland pour le développement du langage GO, de nombreux développeurs rencontreront des balises de structure personnalisées ...

Pourquoi est-il nécessaire de passer des pointeurs lors de l'utilisation de bibliothèques Go et Viper? Pourquoi est-il nécessaire de passer des pointeurs lors de l'utilisation de bibliothèques Go et Viper? Apr 02, 2025 pm 04:00 PM

GO POINTER SYNTAXE ET ATTENDRE DES PROBLÈMES DANS LA BIBLIOTHÈQUE VIPER Lors de la programmation en langage Go, il est crucial de comprendre la syntaxe et l'utilisation des pointeurs, en particulier dans ...

See all articles