Golang HTTP客户端 - Connectex：通常允许每个套接字地址（协议/网络地址/端口）的一个用法

Question

我正在尝试创建基于Golang Net/HTTP的Web服务，该服务从用户那里获取JSON输入，然后查询第三方Web API ITSELVES，以获取数据，然后返回对客户端的答案。我使用http.client {} client.do（）方法来查询第三方Web API。当我执行性能测试（JMeter）时，通常会出现错误： Connectex：通常允许每个套接字地址（协议/网络地址/端口）使用一个用法。我怀疑种族状态，但种族检测没有任何种族状态。在我看来，发布http请求的频率很高，可能会随着时间的流逝而导致端口耗尽。因此，我试图在两个或三个实例（主机）之间平衡查询。但是，我仍然经常出现错误。有没有办法避免此错误？有没有建筑技巧，可以使我的服务高负载准备好？您可以在下面看到简化的代码示例：

var upstream = []string{"1.1.1.1", "2.2.2.2", "3.3.3.3"}
var scheme = "http"
var timeout = 5

    func main() {
        fmt.Println("Listening on *: 8080")
        http.HandleFunc("/", handler)
        log.Fatal(http.ListenAndServe(":8080", nil))
    }
    
    func handler(w http.ResponseWriter, r *http.Request) {
    
        if r.Method != "POST" {
            http.Error(w, http.StatusText(405), 405)
            return
        }
    
        body, err := ioutil.ReadAll(r.Body)
        if err != nil {
            fmt.Println("Error:", err)
            http.Error(w, http.StatusText(400), 400)
            return
        }
    
        var jsonEntity = make(map[string]string)
    
        json.Unmarshal(body, &jsonEntity)
    
        payload := bytes.NewReader(body)
    
        url := r.URL
        url.Host = upstream[0]
        if len(upstream) > 1 {
            url.Host = upstream[random(0, len(upstream))]
        }
        url.Scheme = scheme
    
    
        proxyReq, err := http.NewRequest(http.MethodPost, url.String(), payload)
        if err != nil {
            fmt.Println("Error:", err)
            http.Error(w, http.StatusText(400), 400)
            return
        }
    
        client := http.Client{Timeout: time.Duration(timeout) * time.Second}
    
        response, err := client.Do(proxyReq) // <- IT FAILS HERE!!!
        if err != nil {                 
            fmt.Println("Error:", err)
            http.Error(w, http.StatusText(500), 500)
            sendWithCheck(w, "%s", []byte(`{"answerParam":"error"}`))
            return
        }
        defer func() {
            if err := response.Body.Close(); err != nil {
                log.Println("Error:", err)
            }
        }()
    
        res, err := ioutil.ReadAll(response.Body)
        if err != nil {
            fmt.Println("Error:", err)
            http.Error(w, http.StatusText(500), 500)
            sendWithCheck(w, "%s", []byte(`{"answerParam":"error"}`))
            return
        }
    
        if response.StatusCode == 200 {
            sendWithCheck(w, "%s", res)
            return
        }
    
        w.WriteHeader(response.StatusCode)
        return
    }