默认 http.Client 高并发时卡住,因其 Transport 默认 MaxIdleConns=100、MaxIdleConnsPerHost=2、IdleConnTimeout=30s,导致连接争用;需自定义 Client 并调优参数,同时控制并发、关闭 resp.Body、设置超时与重试。

为什么默认 http.Client 一并发就卡住?
Go 的 http.DefaultClient 底层复用 http.Transport,但它的默认配置极度保守:最大空闲连接数只有 100,每个 host 最多 2 个空闲连接,且连接复用超时仅 30s。高并发下大量请求排队等待空闲连接,表现为延迟陡增、net/http: request canceled (Client.Timeout exceeded) 或直接卡死。
实操建议:
立即学习“go语言免费学习笔记(深入)”;
- 必须显式构造自定义
http.Client,禁用http.DefaultClient -
http.Transport.MaxIdleConns设为500~2000(视机器内存和目标服务承受力) -
http.Transport.MaxIdleConnsPerHost至少设为100,避免单 host 成瓶颈 -
http.Transport.IdleConnTimeout建议90s,太短导致频繁重建连接;太长可能堆积无效连接 - 务必设置
http.Client.Timeout,否则失败请求会无限阻塞 goroutine
如何避免 goroutine 泄漏和连接耗尽?
并发发起 HTTP 请求时,若不控制并发量或未正确关闭响应体,会导致 goroutine 积压、文件描述符耗尽(too many open files),甚至触发系统级限制。
实操建议:
立即学习“go语言免费学习笔记(深入)”;
- 用带缓冲的 channel 或
semaphore控制并发数,例如固定50个 goroutine 同时发请求 - 每次调用
resp, err := client.Do(req)后,必须调用resp.Body.Close()—— 即使err != nil也要判空再关 - 对失败请求做指数退避重试(如
time.Sleep(time.Second ),避免雪崩 - 使用
context.WithTimeout包裹请求,防止单个慢请求拖垮整批
要不要用 http/2?什么时候反而更慢?
Go 1.6+ 默认启用 HTTP/2(对 HTTPS 自动协商),但对 HTTP 明文不生效;且某些老旧代理或服务端不兼容 HTTP/2,会降级失败或增加握手开销。
实操建议:
立即学习“go语言免费学习笔记(深入)”;
- HTTPS 场景下无需额外操作,Go 会自动协商 HTTP/2
- HTTP 明文无法启用 HTTP/2,强行配置
Transport.TLSClientConfig.NextProtos = []string{"h2"}会导致连接失败 - 若目标服务明确不支持 HTTP/2(如 Nginx 未开启
http2指令),或压测发现 TLS 握手占比过高,可临时禁用:Transport.TLSClientConfig.NextProtos = []string{"http/1.1"} - HTTP/2 的多路复用优势在「同一 host 大量小请求」时明显;若请求分散在几十个不同域名,HTTP/1.1 + 连接池优化反而更稳
package mainimport ( "context" "fmt" "io" "net/http" "time" )
func main() { client := &http.Client{ Timeout: 5 time.Second, Transport: &http.Transport{ MaxIdleConns: 1000, MaxIdleConnsPerHost: 200, IdleConnTimeout: 90 time.Second, TLSHandshakeTimeout: 5 * time.Second, }, }
sem := make(chan struct{}, 50) // 控制并发数 results := make(chan string, 100) for i := 0; i < 200; i++ { go func(id int) { sem <- struct{}{} defer func() { <-sem }() ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second) defer cancel() req, _ := http.NewRequestWithContext(ctx, "GET", "https://httpbin.org/delay/1", nil) resp, err := client.Do(req) if err != nil { results <- fmt.Sprintf("req %d failed: %v", id, err) return } defer resp.Body.Close() // 关键:必须关闭 io.Copy(io.Discard, resp.Body) results <- fmt.Sprintf("req %d ok", id) }(i) } for i := 0; i < 200; i++ { fmt.Println(zuojiankuohaophpcn-results) }}
真正卡住你的往往不是 Goroutine 数量,而是 Transport 连接池参数和 Body 是否关闭——这两点漏掉一个,压测结果就完全失真。











