Heim >Backend-Entwicklung >Golang >Warum gibt „json.NewDecoder().Decode()' keinen Kontext-Deadline-Fehler zurück, wenn „ioutil.ReadAll()' dies innerhalb einer Kontext-Deadline in Go tut?

Warum gibt „json.NewDecoder().Decode()' keinen Kontext-Deadline-Fehler zurück, wenn „ioutil.ReadAll()' dies innerhalb einer Kontext-Deadline in Go tut?

Barbara Streisand
Barbara StreisandOriginal
2024-10-31 12:34:31524Durchsuche

Why does `json.NewDecoder().Decode()` not return a context deadline error when `ioutil.ReadAll()` does within a context deadline in Go?

Unerwartetes Verhalten von json.NewDecoder().Decode() innerhalb der Kontextfrist

In Go-Programmen mit festgelegter Kontextfrist die Antwort Es wird erwartet, dass der von ioutil.ReadAll() gelesene Text einen Fehler zurückgibt (context.DeadlineExceeded). Dieses Verhalten wird jedoch nicht beobachtet, wenn der Antworttext mit json.NewDecoder(resp.Body).Decode() gelesen wird, was Null zurückgibt.

Lassen Sie uns tiefer in das Problem eintauchen:

Den Antworten zufolge verwendet das Paket net/http möglicherweise Puffer, um Anfragen zu verarbeiten. Dies bedeutet, dass der eingehende Antworttext teilweise oder vollständig gelesen und gepuffert werden kann, bevor Sie dies tun. Daher hindert Sie ein ablaufender Kontext möglicherweise nicht daran, den Lesevorgang abzuschließen.

Um dies deutlicher zu veranschaulichen, haben wir ein Beispiel angepasst, um einen Test-HTTP-Server zu starten, der die Antwort absichtlich teilweise verzögert:

<code class="go">ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    s := []byte(`{&quot;ip&quot;:&quot;12.34.56.78&quot;}`)
    w.Write(s[:10])
    if f, ok := w.(http.Flusher); ok {
        f.Flush()
    }
    time.Sleep(time.Second * 6)
    w.Write(s[10:])
}))
defer ts.Close()
url = ts.URL

readDoesntFail()
readFails()</code>

Dieser Testserver gibt ein JSON-Objekt aus, das der Antwort von ip.jsontest.com ähnelt. Im Gegensatz dazu liefert es zunächst nur 10 Body-Bytes, löscht sie dann und schläft absichtlich 6 Sekunden lang, bevor der Rest übertragen wird, sodass der Client Zeit zum Ablaufen hat.

Wenn wir readDoesntFail() mit diesem Server ausführen erhalten wir:

before reading response body, context error is: context deadline exceeded
panic: Get &quot;http://127.0.0.1:38230&quot;: context deadline exceeded

goroutine 1 [running]:
main.readDoesntFail()
    /tmp/sandbox721114198/prog.go:46 +0x2b4
main.main()
    /tmp/sandbox721114198/prog.go:28 +0x93

Mit unserem aktualisierten Beispiel bemüht sich json.Decoder.Decode() nun, aus der Verbindung zu lesen, da die Informationen noch nicht gepuffert sind, sodass der Kontextablauf eine veranlassen kann Fehler aufgrund abgelaufenen Kontexts.

Das obige ist der detaillierte Inhalt vonWarum gibt „json.NewDecoder().Decode()' keinen Kontext-Deadline-Fehler zurück, wenn „ioutil.ReadAll()' dies innerhalb einer Kontext-Deadline in Go tut?. 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