0

0

Go语言实现带会话管理的网页抓取

花韻仙語

花韻仙語

发布时间:2025-11-12 14:09:07

|

1046人浏览过

|

来源于php中文网

原创

Go语言实现带会话管理的网页抓取

本文详细介绍了在go语言中如何通过`net/http`包结合`net/http/cookiejar`实现带会话(session)管理的网页抓取。通过创建一个自定义的`http.client`实例并为其挂载一个cookie jar,开发者可以轻松模拟用户登录状态,从而访问需要认证的受限页面,实现类似python `requests`库的会话持久化功能。

在进行需要用户认证的网页抓取任务时,维持登录会话是核心挑战之一。许多网站在用户成功登录后,会通过设置Cookie来标识用户的会话状态。后续的请求需要携带这些Cookie才能被服务器识别为已认证用户。Go语言的标准库提供了强大的工具来处理这一需求,主要通过net/http包中的http.Client和net/http/cookiejar包来实现。

核心概念:http.Client与cookiejar

  1. http.Client: net/http包中的Client类型是进行HTTP请求的客户端。它提供了发送HTTP请求和接收HTTP响应的功能。默认的http.DefaultClient不维护会话状态,每次请求都是独立的。为了实现会话管理,我们需要创建一个自定义的http.Client实例。
  2. net/http/cookiejar: 这个包提供了一个实现了http.CookieJar接口的Jar类型,它可以存储和管理HTTP Cookie。当我们将一个Jar实例附加到http.Client上时,Client在发送请求时会自动从Jar中查找并添加相关的Cookie,并在接收到响应时自动将服务器设置的Cookie保存到Jar中。这样就实现了Cookie的自动管理和会话的持久化。

实现步骤

以下是使用Go语言实现带会话管理的网页抓取的详细步骤:

1. 导入必要的包

首先,需要导入net/http、net/http/cookiejar、net/url和log包。

import (
    "fmt"
    "io/ioutil"
    "log"
    "net/http"
    "net/http/cookiejar"
    "net/url"
    "strings"
)

2. 初始化Cookie Jar

创建一个新的cookiejar.Jar实例。这个Jar将用于存储和管理会话期间的所有Cookie。

立即学习go语言免费学习笔记(深入)”;

jar, err := cookiejar.New(nil)
if err != nil {
    log.Fatalf("创建Cookie Jar失败: %v", err)
}

3. 创建自定义的http.Client

将创建好的cookiejar.Jar实例赋值给http.Client的Jar字段。所有通过这个Client发起的请求都将自动处理Cookie。

星绘
星绘

豆包旗下 AI 写真、P 图、换装和视频生成

下载
client := &http.Client{
    Jar: jar,
    // 可选:设置超时时间
    Timeout: 30 * time.Second,
}

4. 执行登录请求(POST)

模拟用户登录,通常是一个POST请求,将用户名和密码作为表单数据发送到登录URL。

loginURL := "https://site.com/login" // 替换为实际的登录URL
username := "user"
password := "123456"

// 构建登录表单数据
formData := url.Values{}
formData.Set("username", username)
formData.Set("password", password)
// 某些网站可能还需要CSRF token或其他隐藏字段,需要根据实际网站情况添加

req, err := http.NewRequest("POST", loginURL, strings.NewReader(formData.Encode()))
if err != nil {
    log.Fatalf("创建登录请求失败: %v", err)
}

// 设置请求头,模拟浏览器行为
req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
req.Header.Set("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124124 Safari/537.36")
// 某些网站可能需要Origin或Referer头

resp, err := client.Do(req)
if err != nil {
    log.Fatalf("执行登录请求失败: %v", err)
}
defer resp.Body.Close() // 确保关闭响应体

// 检查登录响应状态码
if resp.StatusCode != http.StatusOK && resp.StatusCode != http.StatusFound { // 登录成功可能返回200或302重定向
    log.Printf("登录失败,状态码: %d", resp.StatusCode)
    bodyBytes, _ := ioutil.ReadAll(resp.Body)
    log.Fatalf("登录响应体: %s", string(bodyBytes))
}

fmt.Println("登录成功!")
// 此时,client.Jar中已经保存了服务器设置的会话Cookie

5. 访问受限页面(GET)

登录成功后,使用同一个http.Client实例去访问需要认证的受限页面。Client会自动携带之前保存的会话Cookie。

restrictedURL := "https://site.com/restricted/url" // 替换为实际的受限URL

req, err = http.NewRequest("GET", restrictedURL, nil)
if err != nil {
    log.Fatalf("创建受限页面请求失败: %v", err)
}

// 同样可以设置User-Agent等头信息
req.Header.Set("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124124 Safari/537.36")

resp, err = client.Do(req)
if err != nil {
    log.Fatalf("访问受限页面失败: %v", err)
}
defer resp.Body.Close()

if resp.StatusCode != http.StatusOK {
    log.Fatalf("访问受限页面失败,状态码: %d", resp.StatusCode)
}

bodyBytes, err := ioutil.ReadAll(resp.Body)
if err != nil {
    log.Fatalf("读取受限页面响应体失败: %v", err)
}

fmt.Println("成功访问受限页面,内容摘要:")
fmt.Println(string(bodyBytes)[:500]) // 打印前500字节内容

完整示例代码

package main

import (
    "fmt"
    "io/ioutil"
    "log"
    "net/http"
    "net/http/cookiejar"
    "net/url"
    "strings"
    "time" // 导入 time 包用于设置超时
)

func main() {
    // 1. 初始化Cookie Jar
    jar, err := cookiejar.New(nil)
    if err != nil {
        log.Fatalf("创建Cookie Jar失败: %v", err)
    }

    // 2. 创建自定义的http.Client并挂载Cookie Jar
    client := &http.Client{
        Jar:     jar,
        Timeout: 30 * time.Second, // 设置请求超时时间
    }

    // --- 模拟登录请求 ---
    loginURL := "https://httpbin.org/post" // 示例:使用httpbin模拟POST请求,实际请替换为目标网站登录URL
    username := "testuser"
    password := "testpass"

    // 构建登录表单数据
    formData := url.Values{}
    formData.Set("username", username)
    formData.Set("password", password)
    // 如果网站有CSRF token,需要先GET登录页获取,然后添加到formData

    loginReq, err := http.NewRequest("POST", loginURL, strings.NewReader(formData.Encode()))
    if err != nil {
        log.Fatalf("创建登录请求失败: %v", err)
    }

    // 设置请求头,模拟浏览器行为
    loginReq.Header.Set("Content-Type", "application/x-www-form-urlencoded")
    loginReq.Header.Set("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124124 Safari/537.36")
    // 注意:httpbin.org/post不会实际设置登录Cookie,这里仅作演示POST请求及Client的使用
    // 实际登录成功后,响应头中会包含Set-Cookie,并由client.Jar自动保存

    fmt.Println("正在尝试登录...")
    loginResp, err := client.Do(loginReq)
    if err != nil {
        log.Fatalf("执行登录请求失败: %v", err)
    }
    defer loginResp.Body.Close() // 确保关闭响应体

    if loginResp.StatusCode != http.StatusOK {
        log.Printf("登录请求返回非200状态码: %d", loginResp.StatusCode)
        bodyBytes, _ := ioutil.ReadAll(loginResp.Body)
        log.Fatalf("登录响应体: %s", string(bodyBytes))
    }

    fmt.Printf("登录请求成功,状态码: %d\n", loginResp.StatusCode)
    // 此时,如果目标网站设置了Cookie,client.Jar中已经保存了它们

    // --- 访问受限页面 ---
    // 示例:使用httpbin.org/cookies模拟一个需要Cookie的页面
    // 实际请替换为目标网站的受限URL
    restrictedURL := "https://httpbin.org/cookies"

    fmt.Println("正在尝试访问受限页面...")
    restrictedReq, err := http.NewRequest("GET", restrictedURL, nil)
    if err != nil {
        log.Fatalf("创建受限页面请求失败: %v", err)
    }

    restrictedReq.Header.Set("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124124 Safari/537.36")

    restrictedResp, err := client.Do(restrictedReq)
    if err != nil {
        log.Fatalf("访问受限页面失败: %v", err)
    }
    defer restrictedResp.Body.Close()

    if restrictedResp.StatusCode != http.StatusOK {
        log.Fatalf("访问受限页面失败,状态码: %d", restrictedResp.StatusCode)
    }

    bodyBytes, err := ioutil.ReadAll(restrictedResp.Body)
    if err != nil {
        log.Fatalf("读取受限页面响应体失败: %v", err)
    }

    fmt.Println("成功访问受限页面,内容:")
    fmt.Println(string(bodyBytes))

    // 打印当前Cookie Jar中的所有Cookie (可选)
    fmt.Println("\n当前Cookie Jar中的Cookie:")
    cookies := jar.Cookies(restrictedResp.Request.URL)
    for _, cookie := range cookies {
        fmt.Printf("- %s: %s\n", cookie.Name, cookie.Value)
    }
}

注意:

  • 上述代码中的https://site.com/login和https://site.com/restricted/url需要替换为实际目标网站的URL。
  • httpbin.org是一个用于测试HTTP请求的免费服务,它不会实际进行用户认证或设置会话Cookie,因此上述示例代码中访问httpbin.org/cookies时,如果之前没有手动设置Cookie,响应中的cookies字段会是空的。在实际的抓取任务中,如果登录成功,client.Jar会自动保存服务器返回的会话Cookie。
  • 某些网站可能需要额外的请求头(如Referer、Origin)或处理CSRF(跨站请求伪造)令牌。在抓取前,建议使用浏览器开发者工具分析目标网站的登录流程。
  • 为了避免被目标网站屏蔽,建议设置合理的请求间隔、使用随机的User-Agent和代理IP。

总结

通过net/http包中的http.Client和net/http/cookiejar包,Go语言提供了强大且灵活的机制来管理HTTP会话。开发者只需创建一个带有cookiejar.Jar的http.Client实例,即可自动处理登录后的Cookie管理,从而轻松实现对需要认证的网站进行网页抓取。这种方法与Python requests库的Session对象功能类似,使得在Go中进行状态化HTTP操作变得直观而高效。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
cookie
cookie

Cookie 是一种在用户计算机上存储小型文本文件的技术,用于在用户与网站进行交互时收集和存储有关用户的信息。当用户访问一个网站时,网站会将一个包含特定信息的 Cookie 文件发送到用户的浏览器,浏览器会将该 Cookie 存储在用户的计算机上。之后,当用户再次访问该网站时,浏览器会向服务器发送 Cookie,服务器可以根据 Cookie 中的信息来识别用户、跟踪用户行为等。

6427

2023.06.30

document.cookie获取不到怎么解决
document.cookie获取不到怎么解决

document.cookie获取不到的解决办法:1、浏览器的隐私设置;2、Same-origin policy;3、HTTPOnly Cookie;4、JavaScript代码错误;5、Cookie不存在或过期等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

347

2023.11.23

阻止所有cookie什么意思
阻止所有cookie什么意思

阻止所有cookie意味着在浏览器中禁止接受和存储网站发送的cookie。阻止所有cookie可能会影响许多网站的使用体验,因为许多网站使用cookie来提供个性化服务、存储用户信息或跟踪用户行为。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

411

2024.02.23

cookie与session的区别
cookie与session的区别

本专题整合了cookie与session的区别和使用方法等相关内容,阅读专题下面的文章了解更详细的内容。

92

2025.08.19

session失效的原因
session失效的原因

session失效的原因有会话超时、会话数量限制、会话完整性检查、服务器重启、浏览器或设备问题等等。详细介绍:1、会话超时:服务器为Session设置了一个默认的超时时间,当用户在一段时间内没有与服务器交互时,Session将自动失效;2、会话数量限制:服务器为每个用户的Session数量设置了一个限制,当用户创建的Session数量超过这个限制时,最新的会覆盖最早的等等。

315

2023.10.17

session失效解决方法
session失效解决方法

session失效通常是由于 session 的生存时间过期或者服务器关闭导致的。其解决办法:1、延长session的生存时间;2、使用持久化存储;3、使用cookie;4、异步更新session;5、使用会话管理中间件。

748

2023.10.18

cookie与session的区别
cookie与session的区别

本专题整合了cookie与session的区别和使用方法等相关内容,阅读专题下面的文章了解更详细的内容。

92

2025.08.19

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1100

2023.10.19

俄罗斯Yandex引擎入口
俄罗斯Yandex引擎入口

2026年俄罗斯Yandex搜索引擎最新入口汇总,涵盖免登录、多语言支持、无广告视频播放及本地化服务等核心功能。阅读专题下面的文章了解更多详细内容。

31

2026.01.28

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 22.3万人学习

Django 教程
Django 教程

共28课时 | 3.6万人学习

SciPy 教程
SciPy 教程

共10课时 | 1.3万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号