Golang高并发优化技巧分享

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《Golang高并发优化技巧与实践》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

默认 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) 或直接卡死。

实操建议：

• 必须显式构造自定义 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），甚至触发系统级限制。

实操建议：

• 用带缓冲的 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，会降级失败或增加握手开销。

实操建议：

• 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
<p>import (
"context"
"fmt"
"io"
"net/http"
"time"
)</p><p>func main() {
client := &http.Client{
Timeout: 5 <em> time.Second,
Transport: &http.Transport{
MaxIdleConns:        1000,
MaxIdleConnsPerHost: 200,
IdleConnTimeout:     90 </em> time.Second,
TLSHandshakeTimeout: 5 * time.Second,
},
}</p><pre class="brush:php;toolbar:false;">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(&lt;-results)
}

}

真正卡住你的往往不是 Goroutine 数量，而是 Transport 连接池参数和 Body 是否关闭——这两点漏掉一个，压测结果就完全失真。

终于介绍完啦！小伙伴们，这篇关于《Golang高并发优化技巧分享》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！