首页 > Golang > Go教程

Golang实现HTTP并发压测工具性能分析

时间：2026-03-29 17:27:41 412浏览收藏

本文深入剖析了使用 Golang 的 `http.DefaultClient` 进行 HTTP 并发压测时极易踩坑的关键细节——看似简单的 `go client.Do(req)` 并发调用，实则因连接池耗尽、DNS 频繁解析、goroutine 泛滥、响应体未关闭、FD 泄漏及 GC 干扰等问题，导致服务未压垮而客户端先崩盘；文章直击本质，给出可落地的高性能压测配置方案：自定义 `http.Transport` 调优连接池与超时、禁用低效 DNS 解析、用信号量或 worker 池硬限并发、强制关闭 `resp.Body`、固定 `GOMAXPROCS` 并临时禁用 GC，真正实现“发得稳、收得准、测得真”。

如何在Golang中编写一个HTTP压测工具 Go语言并发请求性能测试

怎么用 `http.DefaultClient` 发起并发请求不崩

Go 的 http.DefaultClient 默认复用连接，但压测时若不调优，很快会卡在 DNS 解析、连接池耗尽或 TCP TIME_WAIT 堆积上。关键不是“能不能发”，而是“发完能不能收、收得稳不稳”。

http.DefaultClient.Transport 必须自定义：默认 MaxIdleConns 和 MaxIdleConnsPerHost 都是 100，压测 500 并发时直接排队等连接
DNS 缓存要关或设长：默认 net.Resolver 不缓存，高频域名解析会阻塞 goroutine；可配 Transport.DialContext + net.Dialer.Timeout 控制建连超时
别用 time.Sleep 控制 QPS：goroutine 启太多又睡不齐，实际并发毛刺大；改用 time.Ticker 或带限速的 worker 池

示例关键配置：

tr := &http.Transport{
    MaxIdleConns:        2000,
    MaxIdleConnsPerHost: 2000,
    IdleConnTimeout:     30 * time.Second,
    TLSHandshakeTimeout: 10 * time.Second,
}
client := &http.Client{Transport: tr}

为什么 `goroutine + http.Do` 写法容易 OOM

常见写法是 for 循环里直接 go func() { client.Do(req) }()，看着简洁，实则危险——没做并发控制，瞬间几千 goroutine 启动，内存暴涨，调度器反成瓶颈。

每个 goroutine 至少占 2KB 栈空间，10k 并发 ≈ 20MB 内存起步，还没算响应体缓冲
http.Do 是同步阻塞的，goroutine 等响应期间仍驻留，无法被 GC 回收
错误不收集：HTTP 错误码、timeout、connection refused 全被吞掉，压测结果失真

正确做法是加 channel 控制并发数，比如用带缓冲的 sem channel：

sem := make(chan struct{}, 100) // 限制 100 并发
for i := 0; i < total; i++ {
    sem <- struct{}{}
    go func() {
        defer func() { <-sem }()
        resp, err := client.Do(req)
        // 处理 resp/err
    }()
}

`http.Response.Body` 不 `Close()` 会导致什么

压测中常忽略 resp.Body.Close()，后果不是立刻报错，而是连接无法复用、文件描述符泄漏、后续请求变慢甚至失败。

HTTP/1.1 默认 keep-alive，Body 不关 → 连接卡在 “idle” 状态，进不了连接池复用队列
Linux 默认单进程 1024 fd 限制，压测几分钟就 hit too many open files
即使用了 io.Copy(ioutil.Discard, resp.Body)，也必须跟 resp.Body.Close()，否则底层 TCP 连接不释放

安全写法（带错误检查）：

resp, err := client.Do(req)
if err != nil {
    // 记录 err
    return
}
defer resp.Body.Close() // 注意：这里 defer 在 goroutine 里才有效
body, _ := io.ReadAll(resp.Body)
// 后续处理 body