Go编程:使用 Colly 库下载Reddit网站的图像

本文涉及的产品
检索分析服务 Elasticsearch 版,2核4GB开发者规格 1个月
实时计算 Flink 版,5000CU*H 3个月
实时数仓Hologres,5000CU*H 100GB 3个月
简介: Reddit是一个社交新闻网站,用户可以发布各种主题的内容,包括图片。本文将介绍如何使用Go语言和Colly库编写一个简单的爬虫程序,从Reddit网站上下载指定主题的图片,并保存到本地文件夹中。为了避免被目标网站反爬,我们还将使用爬虫代理服务,通过动态切换代理IP来提高爬取效率和稳定性。

亿牛云.png

概述

Reddit是一个社交新闻网站,用户可以发布各种主题的内容,包括图片。本文将介绍如何使用Go语言和Colly库编写一个简单的爬虫程序,从Reddit网站上下载指定主题的图片,并保存到本地文件夹中。为了避免被目标网站反爬,我们还将使用亿牛云爬虫代理服务,通过动态切换代理IP来提高爬取效率和稳定性。

正文

Colly库简介

Colly是一个用Go语言编写的功能强大的爬虫框架。它提供了简洁的API,拥有强劲的性能,可以自动处理cookie和session,还有提供灵活的扩展机制。Colly支持多种数据格式的解析,如HTML、XML、JSON等,还支持分布式爬取、限速、缓存、重试等功能。

亿牛云爬虫代理简介

亿牛云爬虫代理是一种专业的代理服务,通过固定云代理服务地址,建立专线网络链接,代理平台自动实现海量IP池管理及负载均衡,实时无感的毫秒级代理IP切换,提供企业级云服务的网络稳定性及请求响应速度,同时降低了客户端运算负载压力,避免了爬虫客户在代理IP策略优化上投入精力,整体提升了爬虫效率。

爬虫程序设计

我们的爬虫程序主要分为以下几个步骤:

  • 创建一个Colly实例,并设置相关选项和回调函数
  • 登录亿牛云后台,获取代理相关信息(域名、端口、用户名、密码),并设置到Colly实例中
  • 访问Reddit网站,根据指定的主题(subreddit)和过滤条件(filter),获取图片链接
  • 下载图片,并保存到本地文件夹中

爬虫程序代码

package main

import (
    "fmt"
    "io"
    "log"
    "net/http"
    "net/url"
    "os"
    "path/filepath"
    "strings"

    "github.com/gocolly/colly/v2"
)

// 定义常量
const (
    subreddit = "pics" // 主题
    filter    = "top"  // 过滤条件
    limit     = 10     // 图片数量限制
    output    = "images" // 输出文件夹

    // 亿牛云爬虫代理相关信息(需登录后台获取)
    proxyHost = "www.16yun.cn" // 域名
    proxyPort = 6443           // 端口
    proxyUser = "16YUN"        // 用户名
    proxyPass = "16IP"         // 密码
)

func main() {
   
   
    // 创建一个Colly实例
    c := colly.NewCollector(
        colly.AllowedDomains("www.reddit.com", "old.reddit.com", "i.redd.it", "i.imgur.com"),
    )

    // 设置代理(使用亿牛云爬虫代理服务)
    err := c.SetProxyFunc(func(r *http.Request) (*url.URL, error) {
   
   
        return url.Parse(fmt.Sprintf("http://%s:%s@%s:%d", proxyUser, proxyPass, proxyHost, proxyPort))
    })
    if err != nil {
   
   
        log.Fatal(err)
    }

    // 创建一个计数器,用于限制图片数量
    count := 0

    // 注册HTML回调函数,用于解析图片链接
    c.OnHTML("a[href]", func(e *colly.HTMLElement) {
   
   
        // 获取链接地址
        link := e.Attr("href")
        // 过滤非图片链接
        if !strings.HasSuffix(link, ".jpg") && !strings.HasSuffix(link, ".png") {
   
   
            return
        }
        // 限制图片数量
        if count >= limit {
   
   
            return
        }
        // 访问图片链接
        c.Visit(link)
    })

    // 注册图片回调函数,用于下载图片
    c.OnResponse(func(r *colly.Response) {
   
   
        // 获取图片URL
        url := r.Request.URL.String()
        // 获取图片文件名
        filename := filepath.Base(url)
        // 创建输出文件夹(如果不存在)
        if _, err := os.Stat(output); os.IsNotExist(err) {
   
   
            os.Mkdir(output, 0755)
        }
        // 创建图片文件
        file, err := os.Create(filepath.Join(output, filename))
        if err != nil {
   
   
            log.Fatal(err)
        }
        defer file.Close()
        // 写入图片数据
        file.Write(r.Body)
        fmt.Printf("下载图片:%s\n", url)
        count++
    })

    c.OnError(func(r *colly.Response, err error) {
   
   
        fmt.Printf("请求失败:%s\n", r.Request.URL)
        fmt.Println(err)
    })

    c.OnRequest(func(r *colly.Request) {
   
   
        fmt.Printf("请求开始:%s\n", r.URL)
    })

    c.OnResponse(func(r *colly.Response) {
   
   
        fmt.Printf("请求完成:%s\n", r.Request.URL)
    })

    c.OnScraped(func(r *colly.Response) {
   
   
        fmt.Println("爬取结束")
    })

    fmt.Println("爬取开始")
    c.Visit(fmt.Sprintf("https://old.reddit.com/r/%s/%s/", subreddit, filter))
}

结语

本文介绍了如何使用Go语言和Colly库编写一个简单的爬虫程序,从Reddit网站上下载指定主题的图片,并保存到本地文件夹中。同时,我们还使用了亿牛云爬虫代理服务,通过动态切换代理IP来提高爬取效率和稳定性,希望本文对你有所帮助。

相关文章
|
1月前
|
Rust 安全 算法
Go标准库的新 math/rand
Go标准库的新 math/rand
|
14天前
|
Kubernetes Go Docker
在K8s编程中如何使用Go
一文带你了解在K8s编程中如何使用Go
34 3
|
1月前
|
JSON 中间件 Go
go语言后端开发学习(四) —— 在go项目中使用Zap日志库
本文详细介绍了如何在Go项目中集成并配置Zap日志库。首先通过`go get -u go.uber.org/zap`命令安装Zap,接着展示了`Logger`与`Sugared Logger`两种日志记录器的基本用法。随后深入探讨了Zap的高级配置,包括如何将日志输出至文件、调整时间格式、记录调用者信息以及日志分割等。最后,文章演示了如何在gin框架中集成Zap,通过自定义中间件实现了日志记录和异常恢复功能。通过这些步骤,读者可以掌握Zap在实际项目中的应用与定制方法
go语言后端开发学习(四) —— 在go项目中使用Zap日志库
|
2天前
|
Shell Go API
Go语言grequests库并发请求的实战案例
Go语言grequests库并发请求的实战案例
|
1月前
|
存储 JSON 前端开发
一文搞懂 Go 1.21 的日志标准库 - slog
一文搞懂 Go 1.21 的日志标准库 - slog
40 2
|
1月前
|
Prometheus Cloud Native Go
Go 1.22 标准库 slices 新增函数和一些旧函数增加新特性
Go 1.22 标准库 slices 新增函数和一些旧函数增加新特性
|
20天前
|
Java 数据库连接 数据库
携手前行:在Java世界中深入挖掘Hibernate与JPA的协同效应
【8月更文挑战第31天】Java持久化API(JPA)是一种Java规范,为数据库数据持久化提供对象关系映射(ORM)方法。JPA定义了实体类与数据库表的映射及数据查询和事务控制方式,确保不同实现间的兼容性。Hibernate是JPA规范的一种实现,提供了二级缓存、延迟加载等丰富特性,提升应用性能和可维护性。通过结合JPA和Hibernate,开发者能编写符合规范且具有高度可移植性的代码,并利用Hibernate的额外功能优化数据持久化操作。
33 0
|
21天前
|
XML Go 数据库
|
23天前
|
安全 Java 测试技术
Go 高性能编程心法探秘
文章深入探讨了Go语言在高性能编程中的各种技巧,包括常用数据结构的使用、内存管理、并发编程策略,以及如何通过减少锁的使用、有效利用sync包中的工具来优化程序性能。
13 0
|
23天前
|
Go C语言
Go语言:新时代的编程英雄,让你的代码驾驭未来!
【8月更文挑战第29天】Go,或称Golang,是由谷歌开发的一种静态强类型的编译语言,旨在融合C语言的高效性和高级语言的易用性。它简洁、优雅,广泛应用于高性能服务器和网络应用开发。本文将通过环境搭建、Hello World示例、变量、常量、控制结构、函数、结构体、接口及错误处理等示例,带你快速入门Go语言,领略其简洁高效的魅力,激发你的编程热情。
31 0