下面给出一套可直接复用的高性能调用模板，展示如何在 Go 1.21 中使用 net/http + context 并发拉取商品详情，开启全局连接复用与 HTTP/2，设置整体与单请求超时，JSON 解码后按价格排序并稳定打印。
步骤 1：初始化项目
- 在项目根目录执行
- go mod init example.com/apiguide
步骤 2：编写 main.go
将以下代码保存为 main.go。注意：示例 URL 为占位，请替换为你的真实 API 基址；如需鉴权，请设置环境变量 EXAMPLE_TOKEN。
package main
import (
"context"
"encoding/json"
"fmt"
"net"
"net/http"
"os"
"sort"
"sync"
"time"
)
type Product struct {
ID int json:"id"
Name string json:"name"
Price float64 json:"price"
}
func fetch(ctx context.Context, client *http.Client, id int) (Product, error) {
url := fmt.Sprintf("https://api.example.com/v1/products/%d", id) // TODO: 替换为真实接口
req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil)
if err != nil {
return Product{}, err
}
// 常用请求头：JSON、鉴权、UA
req.Header.Set("Accept", "application/json")
req.Header.Set("User-Agent", "apiguide/1.0 (+https://example.com)")
if token := os.Getenv("EXAMPLE_TOKEN"); token != "" {
req.Header.Set("Authorization", "Bearer "+token)
}
resp, err := client.Do(req)
if err != nil {
return Product{}, err
}
defer resp.Body.Close()
if resp.StatusCode != http.StatusOK {
return Product{}, fmt.Errorf("status %d", resp.StatusCode)
}
var p Product
if err := json.NewDecoder(resp.Body).Decode(&p); err != nil {
return Product{}, err
}
return p, nil
}
func main() {
// 全局 Transport：连接池、Keep-Alive、HTTP/2、超时参数
tr := &http.Transport{
Proxy: http.ProxyFromEnvironment,
DialContext: (&net.Dialer{
Timeout: 3 * time.Second, // TCP 连接超时
KeepAlive: 30 * time.Second, // 保持连接心跳
}).DialContext,
ForceAttemptHTTP2: true, // 对支持 ALPN 的 TLS 主机启用 HTTP/2
MaxIdleConns: 100, // 全局最大空闲连接
MaxIdleConnsPerHost: 20, // 每主机最大空闲连接（按并发规模调优）
MaxConnsPerHost: 0, // 0 表示不限制
IdleConnTimeout: 90 * time.Second,
TLSHandshakeTimeout: 5 * time.Second,
ExpectContinueTimeout: 1 * time.Second,
// ResponseHeaderTimeout 可选：上限等待首包时间（也可依赖每请求的 context）
// ResponseHeaderTimeout: 4 * time.Second,
}
// 复用单例 http.Client（不要为每个请求创建新 client）
client := &http.Client{
Transport: tr,
// 不设置 Client.Timeout，改用 context 控制单请求和整体超时，避免双重超时冲突
}
// 需要拉取的商品 ID
ids := []int{101, 205, 309, 412, 518}
// 整体超时（所有请求的总预算时间）
ctx, cancel := context.WithTimeout(context.Background(), 8*time.Second)
defer cancel()
var (
wg sync.WaitGroup
mu sync.Mutex
products = make([]Product, 0, len(ids))
)
for _, id := range ids {
id := id // 闭包捕获
wg.Add(1)
go func() {
defer wg.Done()
// 单请求超时（连接、TLS、首包、读取等都受此 ctx 控制）
cctx, ccancel := context.WithTimeout(ctx, 3*time.Second)
defer ccancel()
if p, err := fetch(cctx, client, id); err == nil {
mu.Lock()
products = append(products, p)
mu.Unlock()
} else {
// 需求：单请求失败或超时忽略；如需排查可打印到 stderr
// fmt.Fprintf(os.Stderr, "fetch %d error: %v\n", id, err)
}
}()
}
wg.Wait()
// 稳定排序与稳定打印：价格降序；同价时按 ID 升序再按名称升序，确保结果稳定
sort.Slice(products, func(i, j int) bool {
if products[i].Price == products[j].Price {
if products[i].ID == products[j].ID {
return products[i].Name < products[j].Name
}
return products[i].ID < products[j].ID
}
return products[i].Price > products[j].Price
})
for _, p := range products {
fmt.Printf("%d\t%s\t%.2f\n", p.ID, p.Name, p.Price)
}
// 可选：程序退出前显式关闭空闲连接
// tr.CloseIdleConnections()
}
步骤 3：运行与验证
- go run .
- 控制台将输出成功请求到的商品，按价格降序排列（同价按 ID、名称保证稳定顺序）。
- 注意：示例域名为占位。若未替换为真实 API，将无法返回数据。你可以：
- 替换为你的线上 API 并设置 EXAMPLE_TOKEN；
- 或使用本地/Mock 服务返回 JSON 验证流程。
步骤 4：行为说明与关键点
- 全局连接复用与 HTTP/2：
- 通过复用单例 http.Client 与自定义 Transport 打开连接池、Keep-Alive、HTTP/2（ForceAttemptHTTP2）。
- MaxIdleConns/MaxIdleConnsPerHost 根据并发与目标服务调优，降低握手与慢启动成本。
- 超时控制：
- 整体超时：context.WithTimeout(ctx, 8s) 控制整批请求的上限耗时。
- 单请求超时：每个 goroutine 内再包一层 3s 超时，独立控制单个请求生命周期。
- Dial/TLS/首包等由请求 context 与 Transport 超时共同约束。
- 并发与聚合：
- 使用 goroutine + WaitGroup 合并结果，失败或超时的请求被忽略，仅输出成功数据。
- 使用互斥锁安全地向切片追加结果。
- JSON 解码与稳定输出：
- json.NewDecoder 流式解码单个响应体。
- 排序采用稳定且确定的多键排序：价格降序，ID 升序，名称升序，保证输出顺序稳定可复现。
- 请求构造与鉴权：
- 新建带 ctx 的请求、设置 Accept、User-Agent 与可选 Authorization: Bearer 。
- token 从环境变量 EXAMPLE_TOKEN 读取，避免硬编码。
可选优化与扩展
- 限制并发度：使用带缓冲通道或令牌桶实现限流，例如 semaphore := make(chan struct{}, 50)。
- 重试与退避：对可重试的幂等请求引入指数退避重试，并在 ctx 剩余时间内尝试。
- 统一日志与指标：记录失败原因、时延分布、超时比率；导出 Prometheus 指标。
- 缓存：对热门商品加本地/分布式缓存，降低下游压力。
- 大响应优化：若响应极大，可用 json.Decoder 增量读取或切换到 jsoniter 以提升吞吐（权衡兼容性）。
- Header 标准化：统一 User-Agent、X-Request-ID、Trace-Context 便于跨服务追踪。
