如何优化Golang网络请求并发性能_Golang net/http高并发优化示例

日期：2026-01-11 00:00 / 作者：P粉602998670

默认 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 main

import ( "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 是否关闭——这两点漏掉一个，压测结果就完全失真。