新闻中心
如何用Golang实现并发HTTP请求_Golang 并发HTTP请求实践
使用goroutine和WaitGroup可实现Go语言中的并发HTTP请求,通过示例代码展示了基础并发、channel收集结果及worker池控制并发数的方法。

在Go语言中发起并发HTTP请求是构建高性能网络服务的常见需求。Golang原生支持并发,通过goroutine和channel可以轻松实现高效的并行请求处理。下面介绍几种实用的方法来实现并发HTTP请求,并给出可运行的示例代码。
使用Goroutine + WaitGroup发起并发请求
最基础的方式是为每个HTTP请求启动一个goroutine,使用sync.WaitGroup等待所有请求完成。
这种方式简单直观,适合不需要返回结果顺序的场景。
示例代码:
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/5f69e19efaba426d62faeab93c308f5c">https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c</a>",
"<a href="https://www.php.cn/link/98a733901e53052474f2320d0a3a9473">https://www.php.cn/link/98a733901e53052474f2320d0a3a9473</a>",
"<a href="https://www.php.cn/link/7ac09a39f051ff62eefbafd363b1bbb3">https://www.php.cn/link/7ac09a39f051ff62eefbafd363b1bbb3</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传递返回值。
这样既能并发执行,又能统一处理结果,避免竞态条件。
示例:
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{
"<a href="https://www.php.cn/link/4d2fe2e8601f7a8018594d98f28706f2">https://www.php.cn/link/4d2fe2e8601f7a8018594d98f28706f2</a>",
"<a href="https://www.php.cn/link/8c4b0479f20772cb9b68cf5f161d1e6f">https://www.php.cn/link/8c4b0479f20772cb9b68cf5f161d1e6f</a>",
"<a href="https://www.php.cn/link/ef246753a70fce661e16668898810624">https://www.php.cn/link/ef246753a70fce661e16668898810624</a>",
}</p><pre class="brush:php;toolbar:false;">ch := make(chan result, len(urls))
for _, url := range urls {
go fetchWithResult(url, ch)
}
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)
}
}}
控制并发数量:使用带缓冲的Worker池
无限制地创建goroutine可能导致系统资源耗尽。可以通过固定数量的worker从任务队列中取任务,实现并发控制。
TeemIp - IPAM and DDI solution
TeemIp是一个免费、开源、基于WEB的IP地址管理(IPAM)工具,提供全面的IP管理功能。它允许您管理IPv4、IPv6和DNS空间:跟踪用户请求,发现和分配IP,管理您的IP计划、子网空间、区域和DNS记录,符合最佳的DDI实践。同时,TeemIp的配置管理数据库(CMDB)允许您管理您的IT库存并将您的配置项(CIs)与它们使用的IP关联起来。项目源代码位于https://github.com/TeemIP
10
查看详情
这种方式适合大量URL请求的场景,防止对目标服务器造成过大压力。
实现方式:
- 创建一个任务channel,放入所有待请求的URL
- 启动固定数量的worker goroutine
- 每个worker从channel读取URL并执行请求
- 使用WaitGroup等待所有worker退出
示例代码片段:
func worker(tasks <-chan string, wg *sync.WaitGroup) {
defer wg.Done()
for url := range tasks {
resp, err := http.Get(url)
if err != nil {
fmt.Printf("Error: %s -> %v\n", url, err)
continue
}
fmt.Printf("OK: %s -> %s\n", url, resp.Status)
resp.Body.Close()
}
}
<p>func main() {
urls := []string{ /<em> 大量URL </em>/ }
tasks := make(chan string, len(urls))
for _, url := range urls {
tasks <- url
}
close(tasks)</p><pre class="brush:php;toolbar:false;">var wg sync.WaitGroup
for i := 0; i < 5; i++ { // 并发数为5
wg.Add(1)
go worker(tasks, &wg)
}
wg.Wait()}
优化HTTP客户端配置
默认的http.Client可能不够高效。自定义Client可提升性能:
- 复用TCP连接(启用Keep-Alive)
- 设置合理的超时时间
- 限制最大空闲连接数
示例配置:
client := &http.Client{
Timeout: 10 * time.Second,
Transport: &http.Transport{
MaxIdleConns: 100,
IdleConnTimeout: 90 * time.Second,
DisableCompression: true,
},
}
// 使用 client.Do(req) 替代 http.Get
基本上就这些。Golang的并发模型让HTTP并发请求变得简单而高效。根据实际需求选择合适的模式——小规模请求用WaitGroup,需结果汇总用channel,大规模任务用worker池配合限流。合理配置HTTP客户端能进一步提升稳定性和吞吐量。
以上就是如何用Golang实现并发HTTP请求_Golang 并发HTTP请求实践的详细内容,更多请关注其它相关文章!
# 是一个
# 江苏朋友圈营销推广方案
# dtcms seo
# 可克达拉市网站seo优化排名
# 关于网站建设工具
# 来宾网站的建设
# 廊坊seo优化推广费用
# 东莞seo计费管理
# 重庆做网站建设哪家快
# 济宁网站推广威星hfqjwl作词
# 青海网站建设800元
# 如何在
# 不需要
# golang
# 客户端
# 如何实现
# 子网
# 如何使用
# 复用
# 如何用
# 您的
# 并发请求
# ai
# go语言
# go
# http请求
相关栏目:
【
科技资讯46185 】
【
网络学院92790 】
相关推荐:
魅族20怎样在浏览器开无图省流_iPhone魅族20浏览器开无图省流【流量节省】
随机参数递归函数的基准调用次数与时间复杂度探究
Golang如何实现Web接口签名验证_Golang Web接口签名校验开发方法
Composer如何处理Git子模块(submodule)依赖_Composer与Git Submodule的对比与选择
海棠账号登录入口_登录海棠账户同步阅读记录
网易大神怎么保存别人动态的图片_网易大神动态图片保存方法
解决Django多数据库/多Schema环境下外键迁移问题
火狐浏览器占用内存高卡顿怎么办 火狐浏览器性能优化设置技巧
实现分段式页面滚动导航:CSS与J*aScript教程
sublime侧边栏怎么增强功能_SideBarEnhancements for sublime安装与配置
在Runstone环境中高效处理TasteDive API的JSON数据
如何在CSS中使用浮动制作导航栏_float实现水平菜单
Windows 11怎么彻底关闭定位_Windows 11服务中禁用Geolocation
Win11网速慢怎么解决 Win11网络设置优化解除限速
天猫双十一预售商品怎么退款_天猫双十一预售退款操作指南
qq邮箱日历功能怎么用_创建日程与会议邀请的技巧
Linux如何构建多环境配置管理_Linux多环境配置方案
AO3最新镜像入口 Archive of Our Own官方平台访问
一加 Nord 5 隐私权限异常_一加 Nord 5 系统安全优化
漫蛙manwa官网登录界面_漫蛙漫画网页版主站入口
三星GalaxyZFold5怎样在相册制作折叠屏分镜_iPhone三星GalaxyZFold5相册制作折叠屏分镜【创意编辑】
poki免费入口快捷访问 poki人气小游戏直接玩站点
Win11怎么用U盘重装系统 Win11制作启动盘并重装系统完整教程【详解】
抖音小游戏合成大西瓜免费秒玩入口链接 抖音小游戏热门合集秒玩网站
CSS布局中意外空白:解决padding-top导致的顶部间距问题
Bilibili动漫最新防封地址发布-Bilibili动漫2025年最稳正版入口推荐
高德地图沿途添加点失败如何解决 高德多点规划方法
照顾宝贝2小游戏免费秒玩入口
192.168.1.1管理中心入口 192.168.1.1路由器网页设置平台
《刺客信条:影》PS5 Pro和Switch 2画面对比
微信聊天记录怎么加密_微信聊天记录加密方法
Python getattr() 异常处理深度解析:避免程序意外退出
Python模块化编程:有效管理依赖与避免循环引用
C++ explicit关键字防止隐式转换_C++构造函数安全规范
css滚动动画效果怎么实现_使用Animate.css滚动触发动画类
Golang如何实现Web文件静态资源服务器_Golang静态资源服务器开发与实践
Yandex搜索引擎官网入口_俄罗斯Yandex免登录一键直达
b站赚钱渠道_b站收益来源
126邮箱账号注册 电脑版登录入口
蛙漫漫画官网在线入口 蛙漫全本漫画免费阅读平台
AO3官方镜像站点汇总 AO3同人作品网页版直达链接
在命令行怎么运行html项目_命令行运行html项目方法【教程】
Golang如何实现微服务鉴权与权限控制_Golang微服务鉴权与权限管理实践
c++中为什么推荐使用using替代typedef_c++现代化类型别名
css元素hover动画延迟生效怎么办_使用animation-delay调整触发时间
如何创建没有密码的Windows本地账户_跳过微软账户登录的技巧【教程】
J*aScript设计模式实践_j*ascript代码优化
QQ邮箱网页版入口页面 QQ邮箱在线登录入口官网
在J*a中如何隐藏复杂性_使用门面模式组织对象交互
CSS条件样式无法按设备触发怎么排查_media条件语句正确设置解决触发问题


2025-11-25
浏览次数:次
返回列表