Golang如何实现HTTP请求并发控制

使用channel信号量可限制并发数，通过固定容量channel作为令牌控制同时运行的goroutine数量；示例中以10为最大并发，利用sem<-struct{}{}获取令牌，defer触发<-sem释放，结合WaitGroup等待所有任务完成；还可采用Worker池模式，预先启动固定worker协程从任务channel消费URL，更优管理资源；同时应结合context实现超时与取消，使用WithTimeout创建带超时的ctx并传入Do方法，确保单个请求不阻塞整体流程，提升健壮性；关键细节包括关闭resp.Body和正确释放channel令牌，避免资源泄漏。

在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
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">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。

PatentPal专利申请写作

AI软件来为专利申请自动生成内容

13

查看详情

这种方式更适用于大规模任务调度，能更好地控制内存和系统资源使用。

- 创建一个任务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令牌。

以上就是Golang如何实现HTTP请求并发控制的详细内容，更多请关注php中文网其它相关文章！