当前位置：首页 > 文章列表 > Golang > Go教程 > Golang并发处理网络请求技巧

Golang并发处理网络请求技巧

2026-03-09 15:49:03 0浏览收藏

本文全面介绍了Go语言中高效、安全处理并发网络请求的四大核心方法：基于Goroutine与WaitGroup的基础并发控制、利用Channel实现结果收集与并发数限制、借助errgroup简化错误传播与任务取消，以及通过context统一管理超时和请求生命周期；结合实际代码示例，帮助开发者根据API服务、微服务调用或数据抓取等不同场景，灵活选择最适合的并发策略，在发挥Go轻量协程优势的同时，避免资源耗尽、错误遗漏和程序提前退出等问题。

如何在Golang中处理网络请求并发_Golang网络请求并发处理方法汇总

在Go语言中处理网络请求并发非常常见，尤其是在构建API服务、微服务调用或数据抓取工具时。Golang凭借其轻量级的goroutine和强大的标准库，天生适合高并发场景。下面介绍几种常用的并发处理方法，帮助你高效、安全地管理多个网络请求。

使用Goroutine + WaitGroup控制并发

这是最基础也是最常用的并发模式。通过sync.WaitGroup等待所有goroutine完成，避免主程序提前退出。

示例：并发发起多个HTTP请求并等待结果

package main
import (
"fmt"
"net/http"
"sync"
)
func fetch(url string, wg *sync.WaitGroup) {
defer wg.Done()
resp, err := http.Get(url)
if err != nil {
fmt.Printf("Error fetching %s: %v\n", url, err)
return
}
defer resp.Body.Close()
fmt.Printf("Fetched %s with status %s\n", url, resp.Status)
}
func main() {
urls := []string{
"https://httpbin.org/get",
"https://httpbin.org/delay/1",
"https://httpbin.org/status/200",
}
var wg sync.WaitGroup
for _, url := range urls {
    wg.Add(1)
    go fetch(url, &wg)
}
wg.Wait()
}

使用Channel收集结果与控制并发数

当需要获取每个请求的结果（如响应体或状态）时，可以通过channel将结果传回主协程。同时可用带缓冲的channel限制最大并发数，防止资源耗尽。

示例：限制5个并发请求，使用channel接收结果

type result struct {
    url     string
    status  string
    err     error
}
func fetchWithResult(url string, ch chan<- result) {
resp, err := http.Get(url)
if err != nil {
ch <- result{url: url, err: err}
return
}
defer resp.Body.Close()
ch <- result{url: url, status: resp.Status}
}
func main() {
urls := [...]string{ / 同上 / }
ch := make(chan result, len(urls))
sem := make(chan struct{}, 5) // 并发信号量，最多5个并发
for _, url := range urls {
    go func(u string) {
        sem <- struct{}{}         // 获取令牌
        fetchWithResult(u, ch)
        <-sem                     // 释放令牌
    }(url)
}

for range urls {
    r := <-ch
    if r.err != nil {
        fmt.Printf("Failed: %s - %v\n", r.url, r.err)
    } else {
        fmt.Printf("Success: %s - %s\n", r.url, r.status)
    }
}
}

使用errgroup简化错误处理

golang.org/x/sync/errgroup提供了一种更优雅的方式处理并发任务中的错误。任何一次请求出错，整个组可以快速取消，并返回首个错误。

示例：使用errgroup并发请求，任一失败则中断

package main
import (
"context"
"fmt"
"net/http"
"golang.org/x/sync/errgroup"
)
func main() {
urls := [...]string{ / 同上 / }
ctx := context.Background()
g, ctx := errgroup.WithContext(ctx)
for _, url := range urls {
    url := url // 避免循环变量捕获
    g.Go(func() error {
        req, _ := http.NewRequestWithContext(ctx, "GET", url, nil)
        resp, err := http.DefaultClient.Do(req)
        if err != nil {
            return err
        }
        defer resp.Body.Close()
        fmt.Printf("Got %s: %s\n", url, resp.Status)
        return nil
    })
}

if err := g.Wait(); err != nil {
    fmt.Printf("Request failed: %v\n", err)
}
}