Sử dụng lại các kết nối http trong Golang

Question

Tôi hiện đang vật lộn để tìm cách tái sử dụng các kết nối khi tạo các bài đăng HTTP trong Golang.

tôi đã tạo ra một phương tiện giao thông và khách hàng như sau:

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

tôi sau đó đi qua con trỏ client này vào một goroutine mà là làm cho nhiều bài viết để các thiết bị đầu cuối tương tự như vậy:

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

Nhìn vào netstat điều này dường như dẫn đến kết nối mới cho mỗi bài viết dẫn đến một số lượng lớn các kết nối đồng thời đang được mở.

Cách chính xác để sử dụng lại kết nối trong trường hợp này là gì?

Answer 1

IIRC, máy khách mặc định hiện kết nối tái sử dụng. Bạn có đang đóng response không?

Người gọi phải đóng lại. Khi đọc xong. Nếu resp.Body không được đóng, RoundTripper bên dưới của Client (thường là Transport) có thể không thể sử dụng lại kết nối TCP liên tục đến máy chủ để yêu cầu tiếp tục "tiếp tục".

Answer 2

Bạn phải đảm bảo rằng bạn đọc cho đến khi phản hồi hoàn tất trước khi gọi Close().

ví dụ:

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

Để đảm bảo http.Client tái sử dụng kết nối hãy chắc chắn để làm hai việc:

• đọc cho đến khi đáp ứng được hoàn tất (tức ioutil.ReadAll(resp.Body))
• Gọi Body.Close()

Answer 3

Edit: Đây là chi tiết của một lưu ý cho những người xây dựng một Transport và Client cho mọi yêu cầu.

Transport là struct chứa các kết nối để tái sử dụng:

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

Vì vậy, nếu bạn tạo một Giao thông vận tải mới cho mỗi yêu cầu, nó sẽ tạo ra các kết nối mới mỗi lần. Trong trường hợp này, giải pháp là chia sẻ một cá thể Transport giữa các máy khách.

Answer 4

Nếu có ai vẫn đang tìm câu trả lời về cách thực hiện, đây là cách tôi đang thực hiện.

package main 

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

var (
    httpClient *http.Client 
) 

const (
    MaxIdleConnections int = 20 
    RequestTimeout  int = 5 
) 

// init HTTPClient 
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() { 
    var endPoint string = "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") 

    // use httpClient to send request 
    response, err := httpClient.Do(req) 
    if err != nil && response == nil { 
     log.Fatalf("Error sending request to API endpoint. %+v", err) 
    } else { 
     // 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)) 
    } 

} 

Go Playground: http://play.golang.org/p/oliqHLmzSX

Nói tóm lại, tôi đang tạo ra một phương pháp khác nhau để tạo ra một khách hàng HTTP và gán nó vào biến toàn cầu và sau đó sử dụng nó để thực hiện yêu cầu. Lưu ý rằng

defer response.Body.Close() 

Thao tác này sẽ đóng kết nối và đặt sẵn sàng để sử dụng lại lần nữa.

Hy vọng điều này sẽ giúp ai đó.