Un exemple présente la méthode de Golang pour réaliser des millions de requêtes simultanées

Avec le développement rapide d'Internet, la demande de simultanéité élevée devient de plus en plus élevée. Comment améliorer la simultanéité du système est devenu une question importante explorée par les programmeurs. Dans le domaine des langages de programmation, Golang est devenu un langage de programmation à haute concurrence populaire en raison de ses caractéristiques de concurrence inhérentes et de ses excellentes performances. Ensuite, nous présenterons comment utiliser Golang pour réaliser des millions de requêtes simultanées basées sur des cas réels.

Tout d'abord, pour les débutants qui viennent d'entrer en contact avec Golang, goroutine et canal sont les deux concepts les plus importants, et ils sont également au cœur de la haute concurrence de Golang. Goroutine est un thread léger qui n'occupe pas trop de ressources et peut exécuter plusieurs goroutines en même temps pour réaliser des opérations simultanées efficaces. Channel est un pipeline utilisé pour la communication entre les goroutines, qui peut réaliser des opérations de transmission de données et de synchronisation.

Ensuite, découvrons la mise en œuvre de la goroutine et du canal de Golang à travers un exemple simple. Tout d'abord, nous écrivons un simple serveur HTTP qui peut écouter les requêtes et renvoyer des réponses. Le code est le suivant :

package main

import (
    "fmt"
    "io"
    "log"
    "net/http"
)

func main() {
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        io.WriteString(w, "Hello, World!\n")
    })
    log.Fatal(http.ListenAndServe(":8080", nil))
}

Ensuite, nous utilisons la goroutine et le canal de Golang pour réaliser des millions de requêtes simultanées. Tout d'abord, nous devons ouvrir plusieurs goroutines pour envoyer des requêtes. Le code est le suivant :

package main

import (
    "fmt"
    "io"
    "log"
    "net/http"
    "sync"
)

func worker(url string, ch chan<- string, wg *sync.WaitGroup) {
    defer wg.Done()
    resp, err := http.Get(url)
    if err != nil {
        log.Fatal(err)
    }
    defer resp.Body.Close()
    body, err := io.ReadAll(resp.Body)
    if err != nil {
        log.Fatal(err)
    }
    ch <- string(body)
}

func main() {
    var wg sync.WaitGroup
    ch := make(chan string)
    for i := 0; i < 1000000; i++ {
        wg.Add(1)
        go worker("https://www.example.com", ch, &wg)
    }
    go func() {
        wg.Wait()
        close(ch)
    }()
    for resp := range ch {
        fmt.Println(resp)
    }
}

Dans le code ci-dessus, nous définissons la fonction de travail pour envoyer des requêtes HTTP. Dans la fonction principale, nous ouvrons 1 million de goroutines. Chaque goroutine appellera la fonction de travail pour demander l'interface https://www.example.com et mettra le résultat de retour dans le canal ch. Dans la goroutine principale, nous utilisons une boucle for pour parcourir les valeurs de réponse dans le canal ch et les afficher sur la console.

Il est à noter que puisque 1 million de goroutines sont ouvertes, cela peut provoquer un crash du système si aucune restriction n'est imposée. Par conséquent, dans un environnement de production réel, nous devons contrôler de manière appropriée le nombre de goroutines pour éviter une pression excessive sur les ressources système.

Pour résumer, les mécanismes goroutine et canal fournis par golang peuvent facilement mettre en œuvre des opérations à haute concurrence et améliorer considérablement les performances du système. Grâce à l'exemple simple ci-dessus, nous pouvons avoir une compréhension préliminaire de la méthode utilisée par Golang pour réaliser des millions de requêtes simultanées. Cependant, dans l'environnement de production réel, il est nécessaire de combiner les scénarios commerciaux et les ressources système pour contrôler de manière appropriée le nombre de goroutines et le nombre de goroutines. échelle des requêtes simultanées, afin d'obtenir des résultats de performances optimaux.

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!