Wiederverwenden von http-Verbindungen in Golang

Ich bin derzeit kämpfen, um einen Weg finden, um die Wiederverwendung von verbindungen, wenn das HTTP-posts in Golang.

Habe ich einen transport-und client-wie so:

//Create a new transport and HTTP client
tr := &http.Transport{}
client := &http.Client{Transport: tr}

Bin ich dann mit der Verabschiedung dieser client-Zeiger in eine goroutine, die macht, mehrere Beiträge zum gleichen Endpunkt wie folgt:

r, err := client.Post(url, "application/json", post)

Blick auf netstat dies scheint zu sein, was eine neue Verbindung für jeden post, resultierend in einer großen Anzahl von gleichzeitigen verbindungen öffnen.

Was ist der richtige Weg, um die Wiederverwendung von verbindungen in diesem Fall?

InformationsquelleAutor der Frage sicr | 2013-07-30

  1. 64

    Sollten Sie sicherstellen, dass Sie zu Lesen, bis die Reaktion abgeschlossen ist vor dem Aufruf Close().

    z.B. 

    res, _ := client.Do(req)
io.Copy(ioutil.Discard, res.Body)
res.Body.Close()

    Sicherzustellen http.Client Verbindung wiederverwenden, werden Sie sicher zwei Dinge zu tun:

    • Zu Lesen, bis die Reaktion abgeschlossen ist (d.h. ioutil.ReadAll(resp.Body))
    • Nennen Body.Close()

    InformationsquelleAutor der Antwort Matt Self

  2. 24

    Wenn jemand noch Antworten zu finden, wie es zu tun, das ist, wie ich bin, es zu tun.

    package main

import (
    "bytes"
    "io/ioutil"
    "log"
    "net/http"
    "time"
)

var httpClient *http.Client

const (
    MaxIdleConnections int = 20
    RequestTimeout     int = 5
)

func init() {
    httpClient = createHTTPClient()
}

//createHTTPClient for connection re-use
func createHTTPClient() *http.Client {
    client := &http.Client{
        Transport: &http.Transport{
            MaxIdleConnsPerHost: MaxIdleConnections,
        },
        Timeout: time.Duration(RequestTimeout) * time.Second,
    }

    return client
}

func main() {
    endPoint := "https://localhost:8080/doSomething"

    req, err := http.NewRequest("POST", endPoint, bytes.NewBuffer([]byte("Post this data")))
    if err != nil {
        log.Fatalf("Error Occured. %+v", err)
    }
    req.Header.Set("Content-Type", "application/x-www-form-urlencoded")

    response, err := httpClient.Do(req)
    if err != nil && response == nil {
        log.Fatalf("Error sending request to API endpoint. %+v", err)
    }

    //Close the connection to reuse it
    defer response.Body.Close()

    //Let's check if the work actually is done
    //We have seen inconsistencies even when we get 200 OK response
    body, err := ioutil.ReadAll(response.Body)
    if err != nil {
        log.Fatalf("Couldn't parse response body. %+v", err)
    }

    log.Println("Response Body:", string(body))    
}

    Gehen Spielplatz: http://play.golang.org/p/oliqHLmzSX

    Zusammenfassend, ich bin darin eine andere Methode zum erstellen einer HTTP-client und Zuordnung zu globalen Variablen und dann mit es Anfragen zu stellen.
    Hinweis: die 

    defer response.Body.Close()

    Dadurch wird das schließen der Verbindung, und stellen Sie es bereit für die Wiederverwendung wieder.

    Hoffe, dies hilft jemand.

    InformationsquelleAutor der Antwort bn00d

  3. 23

    Edit: Das ist eher ein Hinweis für Leute, die konstruieren einer Transport-und Client für jede Anfrage.

    Transport ist die Struktur, die Sie hält verbindungen für re-use:

    http://golang.org/src/pkg/net/http/transport.go#L46

    Also, wenn Sie einen neuen Transport für jede Anfrage, es werden neue verbindungen erstellen jedes mal. In diesem Fall die Lösung ist es, die Transport-Instanz zwischen den clients.

    InformationsquelleAutor der Antwort DrJosh9000

  4. 8

    IIRC der Standard-client hat verbindungen wiederverwenden. Schließen Sie die Antwort?

    Anrufer sollte in der Nähe bzw.Körper, wenn Sie fertig Lesen. Wenn bzw.Körper ist nicht geschlossen, die Kunden zugrunde liegenden RoundTripper (in der Regel Transport) möglicherweise nicht in der Lage zu re-verwenden Sie eine persistente TCP-Verbindung zum server für eine anschließende "keep-alive" - Anfrage.

    InformationsquelleAutor der Antwort zzzz

Schreibe einen Kommentar