Go语言高并发场景下HTTP连接池实战：参数配置与性能提升指南！

tr := &http.Transport{
    MaxIdleConns:        100,       // 全局最大空闲连接数
    MaxIdleConnsPerHost: 20,        // 每个主机最大空闲连接数
    MaxConnsPerHost:     30,        // 每个主机最大连接数（包括活跃）
}

tr := &http.Transport{
    IdleConnTimeout:    90 * time.Second,  // 空闲连接超时
    DialTimeout:        5 * time.Second,   // 建立连接超时
    TLSHandshakeTimeout: 5 * time.Second,   // TLS握手超时
    ResponseHeaderTimeout: 10 * time.Second, // 读取响应头超时
}

client := &http.Client{
    Transport: tr,
    Timeout: 30 * time.Second,  // 整个请求的超时时间
}

func CreateProductionHTTPClient() *http.Client {
    tr := &http.Transport{
        // 连接池配置
        MaxIdleConns:        100,
        MaxIdleConnsPerHost: 25,
        MaxConnsPerHost:     50,
        
        // 超时配置
        IdleConnTimeout:       90 * time.Second,
        DialTimeout:           5 * time.Second,
        TLSHandshakeTimeout:   5 * time.Second,
        ResponseHeaderTimeout: 10 * time.Second,
        
        // 协议配置
        ForceAttemptHTTP2: true,
        DisableKeepAlives: false,
        
        // 连接建立配置
        DialContext: (&net.Dialer{
            Timeout:   5 * time.Second,
            KeepAlive: 30 * time.Second,
        }).DialContext,
    }
    
    return &http.Client{
        Transport: tr,
        Timeout:   30 * time.Second,
    }
}

// 问题配置（导致性能瓶颈）
badTransport := &http.Transport{
    MaxIdleConnsPerHost: 2,   // 过小，导致频繁建立连接
    IdleConnTimeout:     5 * time.Second,  // 过短，连接无法有效复用
}

// 优化后配置
goodTransport := &http.Transport{
    MaxIdleConnsPerHost: 20,     // 增加到合理值
    IdleConnTimeout:     90 * time.Second,  // 延长复用时间
    MaxConnsPerHost:     30,     // 限制最大连接数
}

resp, err := client.Get(url)
if err != nil {
    return err
}
defer func() {
    if resp.Body != nil {
        // 先读取剩余数据，确保连接可以复用
        io.Copy(io.Discard, resp.Body)
        // 再关闭Body
        resp.Body.Close()
    }
}()

sem := make(chanstruct{}, 10) // 最大并发10
var wg sync.WaitGroup

for _, url := range urls {
    wg.Add(1)
    gofunc(u string) {
        defer wg.Done()
        sem <- struct{}{}
        deferfunc() { <-sem }()
        
        // 执行HTTP请求
        resp, err := client.Get(u)
        // ... 处理响应
    }(url)
}
wg.Wait()

// 在程序中添加pprof端点
go func() {
    log.Println(http.ListenAndServe("localhost:6060", nil))
}()

transport := &http.Transport{
    ForceAttemptHTTP2: true,  // 启用HTTP/2
    MaxIdleConnsPerHost: 1,   // HTTP/2下可以更少
}