使用channel信号量可限制并发数，通过固定容量channel作为令牌控制同时运行的goroutine数量；示例中以10为最大并发，利用sem
在Go语言中处理HTTP请求的并发控制，关键在于合理使用goroutine、channel和context。直接大量发起HTTP请求可能导致资源耗尽或被目标服务限流，因此需要对并发数量进行限制。下面介绍几种常见的实现方式。
使用带缓冲的channel控制并发数
通过一个固定容量的channel作为信号量，可以有效限制同时运行的goroutine数量。
定义一个channel，容量即为最大并发数。每次启动一个请求前先向channel写入数据（占位），请求完成后再读出，这样就能保证最多只有N个请求同时进行。
示例代码：func fetch(urls []string) {
client := &http.Client{Timeout: 10 * time.Second}
sem := make(chan struct{}, 10) // 最大并发10
var wg sync.WaitGroup
for _, url := range urls {
wg.Add(1)
go func(u string) {
defer wg.Done()
sem <- struct{}{} // 获取令牌
defer func() { <-sem }() // 释放令牌
resp, err := client.Do(http.NewRequest("GET", u, nil))
if err != nil {
log.Printf("Error fetching %s: %v", u, err)
return
}
defer resp.Body.Close()
// 处理响应
}(url)
}
wg.Wait()
}
立即学习“go语言免费学习笔记（深入）”；
使用Worker池模式
预先启动固定数量的工作协程，通过任务队列分发URL，避免动态创建过多goroutine。
这种方式更适用于大规模任务调度，能更好地控制内存和系统资源使用。
- 创建一个任务channel接收待请求的URL
- 启动固定数量的worker从channel读取并执行请求
- 使用WaitGroup等待所有任务完成
结合Context实现超时与取消
每个HTTP请求应绑定独立的context，设置合理的超时时间，防止某个请求长时间阻塞整个流程。
可以在请求级别设置超时，也可以为整批请求设置统一的上下文控制。
建议做法：
- 使用ctx, cancel := context.WithTimeout(context.Background(), totalTimeout)控制整体执行时间
- 将context传入http.NewRequestWithContext
- 在defer中调用cancel()释放资源
基本上就这些。控制并发的核心是限制同时运行的请求数量，channel信号量简单直接，worker池适合复杂场景，加上context能提升程序健壮性。不复杂但容易忽略细节，比如忘记关闭response body或未正确释放channel令牌。
