Golang并发HTTP请求处理示例

本文深入浅出地展示了Go语言如何利用goroutine和channel实现高效、非阻塞的并发HTTP请求处理——通过定义统一的FetchResult结构体封装响应数据，主函数并发启动多个fetchURL任务并将结果安全写入带缓冲的channel，主线程按需收集并打印结果，既充分发挥了Go原生并发模型的简洁与强大，又为实际开发中批量调用API、微服务通信等高频场景提供了可直接复用的轻量级解决方案。

Go语言通过goroutine和channel提供了强大的并发支持，处理HTTP客户端请求时可以轻松实现高并发。下面是一个实用的示例，展示如何使用Golang并发发起多个HTTP请求，并高效地收集结果。

基本并发HTTP请求结构

使用goroutine并发执行HTTP请求，配合channel同步结果，避免阻塞主线程。

定义一个结果结构体来统一返回数据：

type FetchResult struct {
  URL string
  Status string
  Body []byte
  Err error
}

主函数中启动多个并发请求：

func main() {
  urls := []string{
    "https://httpbin.org/delay/1",
    "https://httpbin.org/status/200",
    "https://httpbin.org/uuid"
  }

  results := make(chan FetchResult, len(urls))

  for _, url := range urls {
    go fetchURL(url, results)
  }

  var fetched []FetchResult
  for range urls {
    result := <-results
    fetched = append(fetched, result)
  }

  close(results)
  for _, r := range fetched {
    fmt.Printf("URL: %s, Status: %s, Error: %v\n", r.URL, r.Status, r.Err)
  }
}

实现fetchURL函数

该函数负责实际发起HTTP请求并发送结果到channel：

func fetchURL(url string, ch chan
  client := &http.Client{Timeout: 10 * time.Second}
  resp, err := client.Get(url)
  if err != nil {
    ch <- FetchResult{URL: url, Err: err}
    return
  }
  defer resp.Body.Close()

  body, _ := io.ReadAll(resp.Body)
  ch <- FetchResult{
    URL: url,
    Status: resp.Status,
    Body: body,
    Err: nil,
  }
}

控制并发数量（限流）

当请求量大时，应限制最大并发数，避免系统资源耗尽。可通过带缓冲的channel实现信号量机制：

semaphore := make(chan struct{}, 5) // 最多5个并发

在循环中调用：

go func(url string) {
  semaphore <- struct{}{}
  fetchWithTimeout(url, results)
  \ }(url)

添加超时和重试机制

生产环境中建议为请求设置上下文超时和简单重试逻辑：

ctx, cancel := context.WithTimeout(context.Background(), 8*time.Second)
defer cancel()
req, _ := http.NewRequestWithContext(ctx, "GET", url, nil)
client.Do(req)

可结合for循环实现最多3次重试，每次间隔递增。

基本上就这些。Go的net/http包配合goroutine让并发请求变得直观高效，合理使用channel和context能构建出稳定可靠的客户端程序。

到这里，我们也就讲完了《Golang并发HTTP请求处理示例》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于golang,HTTP客户端的知识点！