多个 http.Requests 给出“无法分配请求的地址”，除非加速

Question

使用下面的客户端代码（以及此框上端口 8088 上的侦听 Web 服务器），在从以下位置弹出此错误之前，我很少能够获得超过 23000 次点击client.Get()：

panic: Get http://localhost:8088/: dial tcp 127.0.0.1:8088: can't assign requested address

奇怪的是，如果我增加计时器延迟（即从一毫秒到一微秒），需要更多的点击才能获得错误，170,000 甚至更多。

查看网络流量，每个客户端连接在断开连接之前只使用了几次（即客户端发送一个 FIN）。很明显，它正在建立许多 TCP 连接并溢出套接字表。鉴于 Golang HTTP 文档说默认情况下启用了 keepalive，我不希望出现这种情况。内核跟踪显示在关闭之前底层套接字没有发出任何错误（EAGAIN 除外，这是预期的并且并不总是在套接字关闭之前）。

这是 OSX (14.4.0) 上的 Go 1.4.2。为什么客户端连接没有一直被重用？

package main

import (

    "io/ioutil"

    "net/http"

    "runtime"

    "sync"

    "time"

)

var reqnum = 0

func hit(client *http.Client) {

    resp, err := client.Get("http://localhost:8088/")

    if err != nil {

        println(reqnum)

        panic(err)

    }

    defer resp.Body.Close()

    _, err = ioutil.ReadAll(resp.Body)

    if err != nil {

        panic(err)

    }

    reqnum++ // not thread safe, but shouldn't cause errors.

}

func main() {

    var wg sync.WaitGroup

    runtime.GOMAXPROCS(runtime.NumCPU())

    client := &http.Client{}

    for i := 0; i < 10; i++ {

        wg.Add(1)

        go func() {

            defer wg.Done()

            ticker := time.NewTicker(time.Microsecond * 1000)

            for j := 0; j < 120000; j++ {

                <-ticker.C

                hit(client)

            }

            ticker.Stop()

        }()

    }

    wg.Wait()

}

Answer 1

can't assign requested address拨号期间的错误是由于用于客户端连接的本地临时端口用完了。端口用完的原因仅仅是因为您建立的连接太多，速度太快。当您加快连接速率时会发生什么，您开始捕捉空闲连接在它们关闭之前返回到池中。有一个代码路径可以在拨号期间捕获这些新的空闲连接以更快地返回连接，但是没有办法每次都确定性地捕获这些连接。由于您仅连接到一台主机（如评论中所述），因此您需要做的是将其设置得Transport.MaxIdleConnsPerHost更高。您需要查看它在太多开放连接之间以及何时开始过快回收它们之间的平衡。在客户端上使用信号量甚至可能是有利的，以防止过多的同时连接，这将开始导致连接再次过快回收。