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

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

P粉602998670

发布： 2025-11-10 20:59:02

原创

686人浏览过

Go语言中处理网络请求并发常用方法包括：1. 使用Goroutine+WaitGroup控制并发，确保所有请求完成；2. 通过Channel收集结果并限制并发数，避免资源耗尽；3. 利用errgroup简化错误处理与任务取消；4. 结合context实现超时控制与请求取消。根据不同场景选择合适方式，可高效管理并发网络请求。

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

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

使用Goroutine + WaitGroup控制并发

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

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

package main
<p>import (
"fmt"
"net/http"
"sync"
)</p><p>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)
}</p><p>func main() {
urls := []string{
"<a href="https://www.php.cn/link/4d2fe2e8601f7a8018594d98f28706f2">https://www.php.cn/link/4d2fe2e8601f7a8018594d98f28706f2</a>",
"<a href="https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c">https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c</a>",
"<a href="https://www.php.cn/link/98a733901e53052474f2320d0a3a9473">https://www.php.cn/link/98a733901e53052474f2320d0a3a9473</a>",
}</p><pre class='brush:php;toolbar:false;'>var wg sync.WaitGroup
for _, url := range urls {
    wg.Add(1)
    go fetch(url, &wg)
}
wg.Wait()

登录后复制

}

立即学习“go语言免费学习笔记（深入）”；

钉钉 AI 助理

钉钉AI助理汇集了钉钉AI产品能力，帮助企业迈入智能新时代。

查看详情

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

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

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

type result struct {
    url     string
    status  string
    err     error
}
<p>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}
}</p><p>func main() {
urls := [...]string{ /<em> 同上 </em>/ }
ch := make(chan result, len(urls))
sem := make(chan struct{}, 5) // 并发信号量，最多5个并发</p><pre class='brush:php;toolbar:false;'>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)
    }
}

登录后复制

}

立即学习“go语言免费学习笔记（深入）”；

使用errgroup简化错误处理

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

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

package main
<p>import (
"context"
"fmt"
"net/http"
"golang.org/x/sync/errgroup"
)</p><p>func main() {
urls := [...]string{ /<em> 同上 </em>/ }
ctx := context.Background()
g, ctx := errgroup.WithContext(ctx)</p><pre class='brush:php;toolbar:false;'>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)
}

登录后复制

}

立即学习“go语言免费学习笔记（深入）”；