当前位置:首页 > 文章列表 > Golang > Go教程 > Golang并发爬虫实战:goroutine池抓取多个URL

Golang并发爬虫实战:goroutine池抓取多个URL

2026-05-23 13:02:15 0浏览 收藏
本文深入剖析了Golang并发爬虫实践中最易被忽视却致命的三大陷阱:无节制启动goroutine导致内存暴涨与崩溃、HTTP客户端未全局复用引发连接耗尽与超时频发、错误处理粗放致使可恢复请求大量丢失;通过引入信号量限流、复用并精细配置http.Client、按错误类型精准重试、强制读取/关闭响应体等实战方案,揭示真正制约高并发稳定性的并非并发模型本身,而是HTTP协议细节在大规模goroutine协同下的连锁失效——每一条看似微小的疏漏,都可能在数分钟后引爆整个系统。

Golang怎么实现并发爬虫_Golang如何用goroutine池并发抓取多个URL【实战】

goroutine 泄漏:不加控制地起 goroutine 必崩

并发爬虫最常踩的坑不是性能差,而是程序跑着跑着内存爆了、CPU 拉满、最后 panic: runtime: out of memory。根本原因是没限制并发数,每个 URL 都 go fetch(url),几千个 URL 就起几千个 goroutine,而 HTTP 客户端连接、DNS 解析、TLS 握手全在背后排队堆积。

实操建议:

  • 永远不用裸写 go fetch(url),必须套进池里——用 semaphore.NewWeighted(n)(golang.org/x/sync/semaphore)或带缓冲的 channel 做并发闸门
  • 哪怕只设 n = 10,也能把 goroutine 数压到两位数,同时避免目标站封 IP 或触发限流
  • 别信“goroutine 很轻”,它默认栈 2KB,上万 goroutine 光栈就吃掉 20MB+,加上 net/http 的连接池和 TLS 状态,实际开销远超预期

HTTP 客户端复用:不重用 http.Client 就是自找超时和连接耗尽

每次请求都 new 一个 http.Client,会反复创建底层 http.Transport,导致连接无法复用、DNS 缓存失效、TLS 会话不复用,最终表现是大量 context deadline exceeded 或 dial tcp: lookup failed。

实操建议:

  • 全局复用一个 *http.Client,设置合理的 Timeout、IdleConnTimeout 和 MaxIdleConnsPerHost
  • 例如:client := &http.Client{Timeout: 10 * time.Second},再配 Transport 时设 MaxIdleConnsPerHost: 100,否则默认 2,连 3 个 URL 就卡住
  • 别在 goroutine 里改 client.Timeout —— 它不是并发安全的;要差异化超时,用 ctx.WithTimeout() 传进 client.Do(req.WithContext(ctx))

错误处理不落地:忽略 io.EOF、net.ErrClosed 和重试逻辑

真实网络环境里,resp, err := client.Do(req) 失败太常见:DNS 挂了、对方关了连接、中间代理截断、甚至 TLS 版本不匹配。但很多人只判 err != nil 就跳过,结果丢掉大量可恢复请求。

实操建议:

  • 区分错误类型:对 url.Error 看 Err 字段,net.OpError 判 Timeout(),net.ErrClosed 可重试,http.ErrUseLastResponse 要手动读 resp.Body
  • 简单重试用 for i := 0; i + time.Sleep(100 * time.Millisecond),别用指数退避搞复杂——爬虫不是金融交易系统
  • 务必 defer resp.Body.Close(),否则连接永远不归还给连接池,MaxIdleConnsPerHost 形同虚设

响应体读取不完整:不读完 resp.Body 就丢弃,连接池直接瘫痪

写 if resp.StatusCode == 200 { parse(resp.Body) } 然后不管 else 分支,或者解析出错就 return,会导致 resp.Body 没被读完或没关闭。后果是:该连接卡在 idle 状态,后续请求拿不到新连接,Client 最终阻塞在 transport.roundTrip。

实操建议:

  • 无论成功失败,都要确保 resp.Body 被读完或关闭。最稳妥是 io.Copy(io.Discard, resp.Body) 再 Close()
  • 如果只想要状态码和 header,用 resp, err := client.Head(url),它不传 body,省带宽也省连接
  • 别用 strings.NewReader(string(body)) 二次解析——body 是 io.ReadCloser,转 string 会吃光内存,大页面直接 OOM

真正难的不是并发模型,是 HTTP 协议细节在高并发下的连锁反应。比如一个没关的 Body,可能让整个连接池在 5 分钟后才超时释放——而这 5 分钟里,你还在不断起新的 goroutine。

本篇关于《Golang并发爬虫实战:goroutine池抓取多个URL》的介绍就到此结束啦,但是学无止境,想要了解学习更多关于Golang的相关知识,请关注golang学习网公众号!

phpEnv安装Rancher教程及使用指南phpEnv安装Rancher教程及使用指南
上一篇
phpEnv安装Rancher教程及使用指南
零基础学英语:百词斩使用教程与心得
下一篇
零基础学英语:百词斩使用教程与心得
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • PubMedQA数据集详解:生物医学问答基准、功能与应用指南
    PubMedQA
    深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
    463次使用
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    527次使用
  • LMArena是什么?伯克利AI模型评估平台使用指南与功能解析
    LMArena
    LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
    545次使用
  • 斯坦福HELM:大语言模型Holistic Evaluation整体评估框架详解
    HELM
    深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
    494次使用
  • MMBench详解:多模态大模型基准测试、功能特点与使用指南
    MMBench
    MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
    313次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议 和 隐私政策
返回登录
  • 重置密码