Go-Resty连接池优化实战：解决高并发场景下的性能问题

client := resty.New()
client.SetTransport(&http.Transport{
    MaxIdleConns:        100,              // 最大空闲连接数
    MaxIdleConnsPerHost: 100,              // 每个host的最大空闲连接数
    MaxConnsPerHost:     100,              // 每个host的最大连接数
    IdleConnTimeout:     90 * time.Second, // 空闲连接超时时间
})
 

// 适用于一般API调用场景
client := resty.New().SetTransport(&http.Transport{
    MaxIdleConns:        50,
    MaxIdleConnsPerHost: 50,
    MaxConnsPerHost:     100,
    IdleConnTimeout:     60 * time.Second,
})
 

// 适用于微服务内部调用
client := resty.New().SetTransport(&http.Transport{
    MaxIdleConns:        200,
    MaxIdleConnsPerHost: 200,
    MaxConnsPerHost:     400,
    IdleConnTimeout:     120 * time.Second,
    // 开启长连接
    DisableKeepAlives: false,
})
 

// 添加性能监控
client.OnBeforeRequest(func(c *resty.Client, r *resty.Request) error {
    r.SetContext(context.WithValue(r.Context(), "startTime", time.Now()))
    return nil
})
 
client.OnAfterResponse(func(c *resty.Client, r *resty.Response) error {
    startTime := r.Request.Context().Value("startTime").(time.Time)
    duration := time.Since(startTime)
    // 记录请求耗时
    log.Printf("请求耗时: %v", duration)
    return nil
})
 

// 定期打印连接池状态
go func() {
    ticker := time.NewTicker(1 * time.Minute)
    for range ticker.C {
        // 这里可以添加自定义的监控指标
        log.Printf("当前连接池状态: %+v", client.GetTransport())
    }
}()