Go 标准库之 GoRequests 介绍与基本使用

news/发布时间2024/5/17 17:57:17

目录
  • 一、介绍
  • 二、安装
  • 三、导入
  • 四、基本使用
    • 4.1 发送GET 请求
    • 4.2 POST请求发送JSON数据
    • 4.3 Post 文件上传
    • 4.4 GoRequests 使用代理
    • 4.5 Gorequests 使用session

一、介绍

官方文档 DOC: https://pkg.go.dev/github.com/levigross/grequests

Github: http://github.com/levigross/grequests

Python中的Requests库非常强大,所以Go开发者模仿Python的Requests库,由此诞生了Grequests库。Grequests提供了一系列便利功能,使得发送HTTP请求变得简单高效。下面就是Grequests在Golang中实现的一些关键特性:

  • 响应序列化Grequests支持将HTTP响应内容序列化为JSON和XML格式,让处理API响应时更为方便。
  • 文件上传和下载:提供了便捷的方式来上传和下载文件,无需复杂的配置。
  • HTTP动词支持:支持广泛的HTTP动词,包括GET、HEAD、POST、PUT、DELETE、PATCH以及OPTIONS,可以覆盖大多数HTTP请求场景。

二、安装

要开始使用Grequests库,你需要先在你的Go环境中安装它。通过下面的命令即可完成安装:

go get -u github.com/levigross/grequests

三、导入

在安装完Grequests后,你可以通过import语句把它引入到你的Go代码中:

import "github.com/levigross/grequests"

四、基本使用

4.1 发送GET 请求

下面是一个发送GET请求的示例,其中演示了如何获取HTTP响应并打印出来:

func Get() {resp, err := grequests.Get("http://127.0.0.1:8080/book/", nil)if err != nil {log.Fatalln("Unable to make request: ", err)}if !resp.Ok {log.Fatalln("请求超时!")}// 解析响应的JSON数据var data []map[string]interface{}if err := resp.JSON(&data); err != nil {log.Fatalln("Unable to parse JSON response: ", err)}fmt.Println(data)
}

上面的代码首先使用Get方法发送GET请求,然后检查是否有错误发生。如果没有错误,就可以通过resp.Json()方法获取响应的文本内容。

4.2 POST请求发送JSON数据

在下面的例子中,我们创建了一个map对象来保存我们想要发送的JSON数据。然后我们通过ROption创建了一个请求选项对象,并在其中指定了JSON为发送的数据类型。最后,我们调用Post方法来发送请求:

func Post() {postData := map[string]string{"id":   "1","name": "Go入门到进阶",}geq := &grequests.RequestOptions{JSON: postData,}resp, err := grequests.Post("http://127.0.0.1:8080/book/create", geq)if err != nil {log.Fatalln("Unable to make request: ", err)}fmt.Println(resp.String())
}

下面是代码的逐行解释:

  1. postData := map[string]string{"id": "1", "name": "Go入门到进阶"}
    • 这里定义了一个map[string]string类型的变量postData,其中包含了两个键值对,分别是"id"和"name",它们的值分别是"1"和"Go入门到进阶"。
  2. geq := &grequests.RequestOptions{JSON: postData}
    • 这里创建了一个grequests.RequestOptions类型的变量geqgrequests.RequestOptions是一个结构体,用于配置HTTP请求的各种选项,如URL、方法、头信息、数据等。在这个例子中,我们通过JSON字段将postData作为JSON数据传递给POST请求。
  3. resp, err := grequests.Post("http://127.0.0.1:8080/book/create", geq)
    • 这里调用grequests.Post函数发起一个POST请求。http://127.0.0.1:8080/book/create是请求的目标URL,而geq是请求的配置选项。grequests.Post函数会返回一个Response对象和一个可能的错误。
  4. if err != nil { log.Fatalln("Unable to make request: ", err) }
    • 如果grequests.Post函数调用时发生错误,这个条件块会执行。log.Fatalln函数会打印错误消息并退出程序。
  5. fmt.Println(resp.String())
    • 如果请求成功,这个条件块会执行。resp.String()方法会返回响应体的字符串表示,然后使用fmt.Println函数将其打印到标准输出。
      总的来说,这段代码的作用是向本地服务器(假设在127.0.0.1:8080上)的/book/create路径发送一个POST请求,请求体是JSON格式的数据,包含一个ID和书名。如果请求成功,它会打印出服务器的响应。如果请求失败,它会打印出错误信息并退出程序。

4.3 Post 文件上传

文件上传同样简单。你可以通过RequestOptions指定文件:

func UploadFile() {// 允许您通过指定磁盘上的位置来创建FileUpload结构片// 打开要上传的文件file, err := os.Open("./go.mod")if err != nil {log.Fatalln("Unable to open file: ", err)}defer file.Close()// 创建FileUpload结构片ro := &grequests.RequestOptions{Files: []grequests.FileUpload{{FileName:     "1.txt", // 上传后的文件名称FieldName:    "file",  // 上传文件对应字段FileContents: file, // 使用文件内容作为FileContents}},}// 发送POST请求resp, err := grequests.Post("http://127.0.0.1:8080/book/upload/", ro)if err != nil {log.Fatalln("Unable to make request: ", err)}fmt.Println(resp.String())
}

在上述代码中,我们创建了一个FileUpload结构,通过FileNameFieldNameFileContents来指定我们要上传的文件详情。

4.4 GoRequests 使用代理

gorequest代理,下面是一个简单的例子,需要把Proxies中的URL添加为*url.URL代理:

func Proxy() {// 代理服务器const proxyServer = "http-pro.xxx.com:9010"// 代理隧道验证信息const proxyUser = "xxxxxxxxx"const proxyPass = "xxxxxxxxx"// 初始化代理URLproxyUrl, _ := url.Parse("http://" + proxyUser + ":" + proxyPass + "@" + proxyServer)// 创建请求选项ro := &grequests.RequestOptions{Proxies: map[string]*url.URL{"http": proxyUrl,},Headers: map[string]string{"user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36",},}// 发起GET请求resp, err := grequests.Get("http://www.example.com", ro)if err != nil {fmt.Println("Error:", err)return}// 打印响应状态码fmt.Println("Status code:", resp.StatusCode)// 打印响应体fmt.Println("Response:", resp.String())
}

下面是代码的逐行解释:

  1. // 代理服务器
    • 这一行是一个注释,声明了接下来的代码将定义代理服务器的URL。
  2. const proxyServer = "http-pro.xxx.com:9010"
    • 这里定义了一个常量proxyServer,它的值是代理服务器的URL,格式为http://host:port
  3. // 代理隧道验证信息
    • 这一行是一个注释,声明了接下来的代码将定义代理隧道的验证信息。
  4. const proxyUser = "xxxxxxxxx"
    • 这里定义了一个常量proxyUser,它的值是代理隧道的用户名。
  5. const proxyPass = "xxxxxxxxx"
    • 这里定义了一个常量proxyPass,它的值是代理隧道的密码。
  6. // 初始化代理URL
    • 这一行是一个注释,说明接下来的代码将创建代理URL。
  7. proxyUrl, _ := url.Parse("http://" + proxyUser + ":" + proxyPass + "@" + proxyServer)
    • 这行代码使用url.Parse函数创建了一个代理URL。它将代理隧道的用户名、密码和代理服务器地址组合成一个URL,格式为http://username:password@host:port_是忽略返回值的约定,因为返回值通常不需要使用。
  8. // 创建请求选项
    • 这一行是一个注释,说明接下来的代码将创建一个grequests.RequestOptions结构体,用于配置HTTP请求。
  9. ro := &grequests.RequestOptions{
    • 这里开始定义grequests.RequestOptions结构体变量ro
  10. Proxies: map[string]*url.URL{
    • 这里定义了Proxies字段,它是一个映射,将协议(如"http")映射到代理URL。
  11. "http": proxyUrl,
    • 这行代码将代理URL设置为HTTP协议的代理。
  12. },
    • 这是映射定义的结束。
  13. Headers: map[string]string{
    • 这里定义了Headers字段,它是一个映射,将HTTP头字段(如"user-agent")映射到相应的值。
  14. "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36",
    • 这行代码设置了一个HTTP头字段,即用户代理(User-Agent),用于标识发起请求的客户端。
  15. },
    • 这是映射定义的结束。
  16. }
    • 这是grequests.RequestOptions结构体变量的定义结束。
  17. // 发起GET请求
    • 这一行是一个注释,说明接下来的代码将发起一个GET请求。
  18. resp, err := grequests.Get("http://www.example.com", ro)
    • 这行代码使用grequests.Get函数发起一个GET请求。http://www.example.com是请求的目标URL,而ro是请求的配置选项。grequests.Get函数会返回一个Response对象和一个可能的错误。
  19. if err != nil {
    • 如果grequests.Get函数调用时发生错误,这个条件块会执行。
  20. fmt.Println("Error:", err)
    • 这行代码打印出错误信息。
  21. return
    • 这行代码表示如果发生错误,函数将返回,不继续执行。
  22. }
    • 这是错误处理块的结束。
  23. fmt.Println("Status code:", resp.StatusCode)
    • 如果请求成功,这行代码会打印出响应的状态码。
  24. fmt.Println("Response:", resp.String())

4.5 Gorequests 使用session

下面是使用Session的一个例子:

session := grequests.Session{RequestOptions: &grequests.RequestOptions{Headers: map[string]string{"authority":  "mp3.haoge500.com","referer":    "https://www.zz123.com/","User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36",},},}

本文由博客一文多发平台 OpenWrite 发布!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.ulsteruni.cn/article/48765758.html

如若内容造成侵权/违法违规/事实不符,请联系编程大学网进行投诉反馈email:xxxxxxxx@qq.com,一经查实,立即删除!

相关文章

泰国股票盘搭建【TG:@Gangguhk】

功能最强大的股票配资系统 我们的股票配资系统是由拥有10年项目开发经验的资深技术人员,针对股票配资市场情况及股票投资者需要而精心研发,可同时运行于手机端、电脑端的多屏杠杆融资风控管理系统。功能包括自设配资额度、多级代理、交易管理、客户管理、警戒平仓、系统监控、…

openGauss AI4DB-数据库自治运维

AI4DB: 数据库自治运维 如上文所述,AI4DB主要用于对数据库进行自治运维和管理,从而帮助数据库运维人员减少运维工作量。在实现上,DBMind的AI4DB框架具有监控和服务化的性质,同时也提供即时AI工具包,提供开箱即用的AI运维功能(如索引推荐)。AI4DB的监控平台以开源的Prome…

服务端测试开发必备技能:Mock测试

什么是mock测试 Mock 测试就是在测试活动中,对于某些不容易构造或者不容易获取的数据/场景,用一个Mock对象来创建以便测试的测试方法。 Mock测试常见场景无法控制第三方系统接口的返回,返回的数据不满足要求 依赖的接口还未开发完成,就需要对被测系统进行测试Mock测试的缺点…

03、OSPF与BFD联动

OSPF与BFD联动定义 双向转发检测BFD(Bidirectional Forwarding Detection)是一种用于检测转发引擎之间通信故障的检测机制。 BFD对两个系统间的、同一路径上的同一种数据协议的连通性进行检测,这条路径可以是物理链路或逻辑链路,包括隧道。 OSPF与BFD联动就是将BFD和OSPF协…

获取layui表格(table)当前页的页码值和当前页的数据条数

获取layui表格(table)当前页的页码值和当前页的数据条数 在浏览器查看源码,获取当前页面的数据条数如下核心代码 $(".layui-laypage-limits").find("option:selected").val() //分页数目 $(".layui-laypage-skip").find("input").va…

PandasTA 源码解析(七)

.\pandas-ta\pandas_ta\momentum\stc.py # -*- coding: utf-8 -*- 从 pandas 库中导入 DataFrame 和 Series 类 从 pandas_ta.overlap 模块中导入 ema 函数 从 pandas_ta.utils 模块中导入 get_offset、non_zero_range 和 verify_series 函数# 定义函数:Schaff Trend Cycle (S…