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

在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 target='_blank' href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyerpV6iZXHe3vUmsyZr5vTk6a8ZIZkrrKFmnmyh6O_t7dsgXaJ0bOIg8-FzalskdN9qbGGl2m0gI2qfmuGsrKVu2mNrJHPs4VuoQ' rel='nofollow'>https://httpbin.org/get</a>",
"<a target='_blank' href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyerpV6iZXHe3vUmsyZr5vTk6a8eYanvpGjpn2MhqKu3LOijnmMlbN4cpSSt89pkqp5qLBkep6yo6Nkf42hpLLdyqKBrIXRsot-lpHdz3Y' rel='nofollow'>https://httpbin.org/delay/1</a>",
"<a target='_blank' href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyerpV6iZXHe3vUmsyZr5vTk6bFZYKcyYGOqnyzgq-yprOifauEz757hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Jtt' rel='nofollow'>https://httpbin.org/status/200</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()}
使用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)
}
}}
使用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)
}}
超时控制与上下文传递
网络请求必须设置超时,避免长时间阻塞。使用context.WithTimeout可统一控制所有请求的最长执行时间。
建议做法:
- 为每个请求绑定context,设置合理超时(如5秒)
- 在errgroup或自定义goroutine中传递context
- 客户端也可设置默认超时:http.Client{Timeout: 5 * time.Second}
基本上就这些常用方式。根据场景选择:简单并发用WaitGroup,需结果用channel+缓冲池,强调错误处理和取消用errgroup。配合context做超时和取消,能写出稳定高效的并发网络代码。
今天关于《Golang并发处理网络请求技巧》的内容介绍就到此结束,如果有什么疑问或者建议,可以在golang学习网公众号下多多回复交流;文中若有不正之处,也希望回复留言以告知!
相关阅读
更多>
-
505 收藏
-
503 收藏
-
502 收藏
-
502 收藏
-
502 收藏
最新阅读
更多>
-
375 收藏
-
499 收藏
-
183 收藏
-
310 收藏
-
435 收藏
-
487 收藏
-
402 收藏
-
178 收藏
-
423 收藏
-
404 收藏
-
237 收藏
-
132 收藏
课程推荐
更多>
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 485次学习