Heim >Backend-Entwicklung >Golang >Golang asynchrone Anfrage

Golang asynchrone Anfrage

WBOY
WBOYOriginal
2023-05-18 21:55:36680Durchsuche

Mit der rasanten Entwicklung des Internets müssen immer mehr Anwendungen mit externen Diensten interagieren, und die von diesen Diensten bereitgestellten APIs sind häufig asynchron. In Single-Thread-Programmen führen Synchronisationsanforderungen häufig zu einer Programmüberlastung, die sich auf die Programmleistung und Reaktionsgeschwindigkeit auswirkt. In Bezug auf asynchrone Anforderungen ermöglicht uns das einzigartige Design der Golang-Sprache daher, asynchrone Aufrufe einfacher zu implementieren und den Durchsatz und die Antwortgeschwindigkeit der Anwendung zu verbessern.

In diesem Artikel erfahren Sie, wie Golang asynchrone Anforderungen implementiert, Goroutine und Channel in Golang verstehen und wie Sie sie zum Implementieren asynchroner Vorgänge verwenden.

goroutine

goroutine in Golang ist ein leichter Thread, der mehrere Aufgaben gleichzeitig in einem einzigen Thread ausführen kann. Mit dem Schlüsselwort go können wir eine neue Goroutine im Programm starten. Nehmen Sie ein einfaches Beispiel:

go func() {
    fmt.Println("Hello, goroutine!")
}()

Im obigen Beispiel starten wir eine neue Goroutine und geben eine Nachricht in der Goroutine aus. Wenn wir das Programm ausführen, können wir sehen, dass die Nachricht vor der Nachricht des Hauptthreads gedruckt wird. Dies zeigt, dass es in verschiedenen Goroutinen ausgeführt wird.

Die Ausführung der Goroutine beginnt, wenn die go-Anweisung aufgerufen wird, nicht, wenn die Funktion startet. Daher können wir mehrere Goroutinen im selben Thread starten und mehrere Aufgaben gleichzeitig ausführen, ohne uns um die Race-Bedingungen zwischen ihnen kümmern zu müssen.

channel

channel ist ein weiteres wichtiges Konzept in Golang. Es handelt sich um einen Kommunikationsmechanismus, der zur Datenübertragung zwischen verschiedenen Goroutinen verwendet wird. Die Methode zum Erstellen eines Kanals ist sehr einfach:

ch := make(chan <type>)

wobei 7674b22ef33c73b930516fd6bc30b7a3 der im Kanal übertragene Datentyp ist. Bei der Verwendung von Kanälen können wir das Schlüsselwort <- verwenden, um Nachrichten zu senden oder zu empfangen. Zum Beispiel: 7674b22ef33c73b930516fd6bc30b7a3 是 channel 中传输的数据类型。在使用 channel 时,我们可以使用关键字 <- 来发送或接收消息。例如:

ch <- "Hello, channel!"
msg := <- ch

在上面的例子中,我们首先向 channel 中发送了一条消息,然后从该 channel 中接收该消息。同样,我们也可以在一个 goroutine 中发送消息,然后在另一个 goroutine 中接收该消息,从而实现不同 goroutine 间的通信。

异步请求

有了前面介绍的 goroutine 和 channel 的知识,我们现在可以轻松地实现异步请求了。例如,我们可以写一个函数,使用 goroutine 启动异步操作,并在操作完成后将结果发送到 channel 中。例如:

func asyncRequest(url string, ch chan<- []byte) {
    resp, err := http.Get(url)
    if err == nil {
        body, _ := ioutil.ReadAll(resp.Body)
        ch <- body
    }
}

在上面的函数中,我们首先使用 http.Get() 函数获取指定 URL 的响应。然后,如果没有出现错误,我们会将响应的主体发送到 channel 中。注意,我们在函数签名中使用了 ch chan<- []byte,这表示该 channel 只能用于发送数据,而不能用于接收数据。

现在,我们可以使用该函数来启动异步请求,并在请求完成后接收响应。例如:

func main() {
    ch := make(chan []byte)
    go asyncRequest("https://www.example.com", ch)
    data := <- ch
    fmt.Printf("Response: %s
", data)
}

在上面的例子中,我们启动了一个异步请求,并使用 <- chrrreee

Im obigen Beispiel haben wir zuerst eine Nachricht an den Kanal gesendet und dann die Nachricht vom Kanal erhalten. Ebenso können wir eine Nachricht in einer Goroutine senden und die Nachricht dann in einer anderen Goroutine empfangen, um eine Kommunikation zwischen verschiedenen Goroutinen zu erreichen.

Asynchrone Anfragen🎜🎜Mit den zuvor eingeführten Kenntnissen über Goroutine und Kanal können wir jetzt problemlos asynchrone Anfragen implementieren. Beispielsweise können wir eine Funktion schreiben, die mithilfe einer Goroutine eine asynchrone Operation startet und das Ergebnis an einen Kanal sendet, wenn die Operation abgeschlossen ist. Zum Beispiel: 🎜rrreee🎜In der obigen Funktion verwenden wir zunächst die Funktion http.Get(), um die Antwort der angegebenen URL abzurufen. Wenn dann keine Fehler auftreten, senden wir den Antworttext an den Kanal. Beachten Sie, dass wir ch chan<- []byte in der Funktionssignatur verwendet haben, was bedeutet, dass der Kanal nur zum Senden von Daten, nicht zum Empfangen von Daten verwendet werden kann. 🎜🎜Jetzt können wir diese Funktion verwenden, um eine asynchrone Anfrage zu initiieren und die Antwort zu erhalten, sobald die Anfrage abgeschlossen ist. Zum Beispiel: 🎜rrreee🎜Im obigen Beispiel initiieren wir eine asynchrone Anfrage und empfangen die Antwort vom Kanal mithilfe der Syntax <- ch. Wenn der asynchrone Vorgang abgeschlossen ist, erhalten wir eine Antwort und drucken den Text aus. 🎜🎜Mit der oben genannten Methode können wir asynchrone Anforderungen problemlos implementieren, ohne uns Gedanken über Race Conditions oder feststeckende Programme machen zu müssen. Darüber hinaus können Goroutinen und Kanäle in Golang unsere Anwendungen problemlos erweitern, um komplexere asynchrone Vorgänge zu implementieren. 🎜

Das obige ist der detaillierte Inhalt vonGolang 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
Vorheriger Artikel:Java zu GolangNächster Artikel:Java zu Golang