Heim  >  Artikel  >  Backend-Entwicklung  >  Golang http asynchrone Anfrage

Golang http asynchrone Anfrage

WBOY
WBOYOriginal
2023-05-10 15:01:391342Durchsuche

Asynchrone Verarbeitung ist eine der wichtigsten Funktionen in vielen modernen Webanwendungen. In der Go-Sprache bietet es eine einfache, aber leistungsstarke Möglichkeit, asynchrone Anforderungen abzuschließen – mithilfe des http-Pakets. In diesem Artikel wird erläutert, wie Sie mit dem http-Paket von Golang asynchrone Anforderungen stellen.

1. Einführung

Das http-Paket in der Go-Sprache ist ein sehr leistungsfähiges Paket, das zum Senden von GET-, POST- und anderen verschiedenen HTTP-Anfragen verwendet werden kann. Es stellt außerdem einen Client für die Interaktion mit dem HTTP-Server bereit. Im Grundfall bietet das http-Paket eine sehr einfache Möglichkeit, synchrone Anfragen zu senden, wir benötigen jedoch normalerweise eine asynchrone Lösung. Glücklicherweise bietet das http-Paket einige einfache, aber leistungsstarke Funktionen zur Verarbeitung asynchroner Anforderungen. „In Go implementieren wir asynchrone Anforderungen über Goroutine, wodurch Go problemlos eine große Anzahl hochgradig gleichzeitiger asynchroner Anforderungen verarbeiten kann.

2. Verwendungsmethode

1. Erstellen Sie einen Client

In Go im http-Paket Der Client Objekt kann verwendet werden, um asynchrone HTTP-Anfragen auszuführen:

package main

import (
    "net/http"
)

func main() {
    client := &http.Client{}
}

Im obigen Beispiel haben wir ein Standard-HTTP-Clientobjekt erstellt und es der Variablen „client“ zugewiesen.

2. Senden Sie eine Anfrage

Nachdem die Erstellung des HTTP-Clients abgeschlossen ist, können wir mit der Funktion http.NewRequest ein HTTP-Anfrageobjekt erstellen und die Antwort durch Aufrufen von „Do“ empfangen von Goroutine. Hier ist der Beispielcode:

package main

import (
    "fmt"
    "net/http"
)

func main() {
    client := &http.Client{}

    req, err := http.NewRequest("GET", "https://www.google.com", nil)
    if err != nil {
        fmt.Println(err)
        return
    }

    go func() {
        resp, err := client.Do(req)
        if err != nil {
            fmt.Println(err)
            return
        }
        defer resp.Body.Close()
        fmt.Println("Async response status:", resp.Status)
    }()

    fmt.Println("Request sent asynchronously.")
    //等待goroutine结束
    //time.Sleep(5 * time.Second)
}

Im obigen Code erstellen wir zuerst einen HTTP-Client und dann ein GET-Anfrageobjekt mit der Funktion http.NewRequest(). Anschließend verwenden wir Goroutine, um die asynchrone Anfrage zu erstellen. . Der Code, der die Anfrage sendet, liegt außerhalb der Goroutine und gibt „Anfrage asynchron gesendet“ aus. Beachten Sie, dass wir resp.Body.Close() in der defer-Anweisung aufrufen Antworttext.

3. Fehlerbehandlung: Wenn wir eine asynchrone HTTP-Anfrage senden, können verschiedene Fehlertypen auftreten:

1 Bei Problemen kann es zu einer Zeitüberschreitung des Clients kommen, indem er auf eine Antwort wartet. Um dieses Problem zu lösen, können wir die Zeitüberschreitung und den Abbruch der Anfrage über die Funktionen „SetTimeout“ und „CancelRequest“ steuern Stellen Sie zunächst das Timeout des Clients auf 5 Sekunden ein. Anschließend werden mithilfe der WithTimeout-Funktion im Kontextpaket eine Abbruchfunktion zurückgegeben, die wir mithilfe einer Defer-Anweisung sicherstellen wird abgebrochen, bevor die Funktion abgeschlossen ist.

2. Der Fehler, der häufig auftritt, hängt mit der langsamen Netzwerkgeschwindigkeit des Geräts zusammen Bei einem Netzwerkverbindungsproblem können wir http.Transport verwenden. Hier ist der Beispielcode:

package main

import (
    "context"
    "fmt"
    "net/http"
    "time"
)

func main() {
    client := &http.Client{
        Timeout: 5 * time.Second,
    }

    req, err := http.NewRequest("GET", "https://www.google.com", nil)
    if err != nil {
        fmt.Println(err)
        return
    }

    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancel()

    req = req.WithContext(ctx)

    go func() {
        resp, err := client.Do(req)
        if err != nil {
            fmt.Println(err)
            return
        }
        defer resp.Body.Close()
        fmt.Println("Async response status:", resp.Status)
    }()

    fmt.Println("Request sent asynchronously.")
}

Mit der oben genannten Methode setzen wir den Dialer-Timeout auf 5 Sekunden Funktion, die in http.Transport bereitgestellt wird, um die Anfrage zu stellen. Diese Funktion verwendet den Dialer, den wir für die Netzwerkverbindung festgelegt haben, und schließt die Verbindung nach einer Zeitüberschreitung. Beachten Sie, dass wir sicherstellen müssen, dass wir den Antworttext schließen, nachdem wir die Antwort erhalten haben.

4. Fazit

In diesem Artikel haben wir die Methode zur Verwendung des http-Pakets zum Erstellen asynchroner HTTP-Anfragen in der Go-Sprache vorgestellt. Wir haben Goroutine erstellt, um Anfragen asynchron zu senden, und gängige Methoden zur Fehlerbehandlung eingeführt. Dieser Ansatz ist sehr einfach, aber leistungsstark und kann Situationen mit hoher Parallelität bewältigen, die in Webanwendungen auftreten können, wodurch er flexibler ist als die meisten herkömmlichen Netzwerkbibliotheken. Jetzt können Sie diese Technik auf Ihren Code anwenden und so wertvolle Zeit und Ressourcen sparen.

Das obige ist der detaillierte Inhalt vonGolang http asynchrone Anfrage. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn