Go语言之Golang http请求库HttpRequest[通俗易懂]

Go语言之Golang http请求库HttpRequest[通俗易懂]Go语言HttpRequest项目源码地址:https://github.com/kirinlabs/HttpRequest主要实现功能目录安装:发送请求传递URL参数响应内容Json响应内容定制请求头BasicAuth认证JSON请求Cookie超时关闭证书验证调试模式连接操作Respone对象实例代码具有快速构建…

大家好,又见面了,我是你们的朋友全栈君。

Go语言HttpRequest项目源码地址: https://github.com/kirinlabs/HttpRequest

主要实现功能

       支持常用的GET、POST、DELETE、PUT等

       GET 除了正常请求url,也可以附带”name=flyfreely&address=beijing”或者map[string]interface{} 两种参数,包会自动整合到QueryString中

       POST 支持string, []byte, *bytes.Reader, *bytes.Buffer, *strings.Reader, map[string]interface{}等参数; 如果发送JSON请求,几乎可以支持发送所有数据类型。

       支持自定义Transport

 

目录

安装:

发送请求

自定义Transport

传递URL参数

响应内容

Json响应内容

定制请求头

BasicAuth 认证

CookieJar

Proxy代理

JSON请求

超时   

关闭证书验证

调试模式

连接操作

Respone对象

实例代码



具有快速构建HeadersCookies设置超时时间请求、耗时、打印请求信息等功能

安装:

go get https://github.com/kirinlabs/HttpRequest

发送请求

导入HttpRequest

import "github.com/kirinlabs/HttpRequest"

实例化:

req := HttpRequest.NewRequest()

然后,尝试获取某个网页。我们来获取 Github 的公共时间线

res,err := req.Get("https://api.github.com/events")

返回一个res的Response对象和err的Error对象

 

自定义Transport

var transport *http.Transport

func init() {   
    transport = &http.Transport{
        DialContext: (&net.Dialer{
            Timeout:   30 * time.Second,
            KeepAlive: 30 * time.Second,
            DualStack: true,
        }).DialContext,
        MaxIdleConns:          100, 
        IdleConnTimeout:       90 * time.Second,
        TLSHandshakeTimeout:   5 * time.Second,
        ExpectContinueTimeout: 1 * time.Second,
    }
}

func demo(){
    // Use http.DefaultTransport
    res, err := HttpRequest.Get("http://127.0.0.1:8080")

    // Use custom Transport
    res, err := HttpRequest.Transport(transport).Get("http://127.0.0.1:8080")
}

 

Post 请求

//无参请求
res,err := req.Post("https://www.baidu.com")

//发送整数类型
res,err := req.Post("https://www.baidu.com",uint32(100))

//发送[]byte
res,err := req.Post("https://www.baidu.com",[]byte("bytes data"))

//发送*bytes.Reader,*strings.Reader,*bytes.Buffer
data := bytes.NewReader(buf []byte)
res,err := req.Post("https://www.baidu.com",data)
res,err := req.Post("https://www.baidu.com",strings.NewReader("string data"))

//请求体为文本
res,err := req.Post("https://www.baidu.com","hello")


//请求体为Json字符串
res,err := req.Post("https://www.baidu.com","{\"name\":\"github\"}")


//map传参
res.err := req.Post("https://www.baidu.com",map[string]interface{}{
    "name":"github",
    "type":1,
})

 也可以不用实例化直接发送请求

//快速发送Get请求
res,err := HttpRequest.Get("https://www.baidu.com")

res,err := HttpRequest.Get("https://www.baidu.com","title=baidu")


//快速发送Post请求
res,err := HttpRequest.Post("https://www.baidu.com")

//发送整数类型
res,err := req.Post("https://www.baidu.com",uint32(100))

//发送[]byte
res,err := req.Post("https://www.baidu.com",[]byte("bytes data"))

//发送*bytes.Reader,*strings.Reader,*bytes.Buffer
res,err := req.Post("https://www.baidu.com",bytes.NewReader(buf []byte))
res,err := req.Post("https://www.baidu.com",bytes.NewBuffer(buf []byte))
res,err := req.Post("https://www.baidu.com",strings.NewReader("string data"))


res,err := HttpRequest.Post("https://www.baidu.com","title=baidu&type=pdf")

res,err := HttpRequest.Post("https://www.baidu.com",map[string]interface{}{
    "title":"baidu",
})


//快速发送JSON请求
res,err := HttpRequest.JSON().Post("https://www.baidu.com",map[string]interface{}{
    "title":"baidu",
})

res,err := HttpRequest.JSON().Post("https://www.baidu.com",`{"title":"baidu","type":"pdf"}`)

传递URL参数

你想为URL的查询字符串(query string)传递数据。如:手工构建URL,http://www.baidu.com/index?key=value。HttpRequest允许你使用第2个参数以字符串”id=100&name=github”或map[string]interface{}{“id”:10,”name”:”github”}字典的形式把数据传递给URL:

手工传参:

res,err := req.Get("https://www.baidu.com/index?name=github")

字符串传参:

res,err := req.Get("https://www.baidu.com/index?name=github","id=100&type=1")

map传参:

res,err := req.Get("https://www.baidu.com/index?name=github",map[string]interface{}{
    "id":10,
    "type":1,
})

 

响应内容

能读取服务器响应的内容

res,err := req.Post("https://api.github.com/events")

 获取服务器返回的内容:

body,err := res.Body()

fmt.Println(string(body))

获取服务器响应状态码:

res.StatusCode()

获取服务器响应Headers:

res.Headers()

返回一个map[string]string的字典

获取请求响应时间:

res.Time()

Json响应内容

HttpRequest内置JSON解码,来解析JSON数据:

//Format the json return value
body, err := res.Json() 

fmt.Println(body)

如果JSON解码失败,会返回一个err错误

 

定制请求头

如果想为请求添加HTTP头部信息,只需要简单的传一个map给SetHeaders方法

req.SetHeaders(map[string]string{
    "Content-Type":"application/json",
    "Source":"api",
})

注:所有header值必须是字符串,SetHeaders可以多次调用,如果Key重复则会覆盖前面设置的值

 

BasicAuth 认证

如果想为请求添加HTTP头部信息,只需要简单的传一个map给SetHeaders方法

req.SetBasicAuth("username","password")

CookieJar

j, _ := cookiejar.New(nil)
j.SetCookies(&url.URL{
	Scheme: "http",
	Host:   "127.0.0.1:8000",
}, []*http.Cookie{
	&http.Cookie{Name: "identity-user", Value: "83df5154d0ed31d166f5c54ddc"},
	&http.Cookie{Name: "token_id", Value: "JSb99d0e7d809610186813583b4f802a37b99d"},
})
res, err := HttpRequest.Jar(j).Get("http://127.0.0.1:8000/city/list")
defer res.Close()
if err != nil {
	log.Fatalf("Request error:%v", err.Error())
}

Proxy代理

通过代理Ip访问

proxy, err := url.Parse("http://proxyip:proxyport")
if err != nil {
	log.Println(err)
}

res, err := HttpRequest.Proxy(http.ProxyURL(proxy)).Get("http://127.0.0.1:8000/ip")
defer res.Close()
if err != nil {
	log.Println("Request error:%v", err.Error())
}
body, err := res.Body()
if err != nil {
	log.Println("Get body error:%v", err.Error())
}
log.Println(string(body))

 

JSON请求

如果想以json方式发送请求,HttpRequest支持2种方式

设置Header头部信息

req.SetHeaders(map[string]string{"Content-Type":"application/json"})

req.Post("https://www.baidu.com","{\"name\":\"github\"}")

调用req.JSON()内置方法

//直接发磅Json字符串参数
res,err := req.JSON().Post("https://www.baidu.com","{\"name\":\"github\"}")

//自动将Map以Json方式发送参数
res,err := req.JSON().Post("https://www.baidu.com",map[string]interface{}{
    "name":"github"
})
req.SetCookies(map[string]string{
    "name":"jason"
})

超时   

 req.SetTimeout(5)

关闭证书验证

当请求https协议时提示x509: certificate signed by unknown authority时,可关闭证书验证

 req.SetTLSClient(&tls.Config{InsecureSkipVerify: true})

调试模式

req.Debug(true)

连接操作

而且还支持连接操作

req := HttpRequest.NewRequest().Debug(true).SetTimeout(5).SetHeader()

Respone对象

获取返回的Response对象

resp.Response()

获取返回码

 resp.StatusCode()

获取Body主体信息   

resp.Body() 

 返回[]byte和error

获取请求耗时

resp.Time() string   单位是毫秒

获取真实Url

res.Url()

实例代码

package main

import (
   "github.com/kirinlabs/HttpRequest"
   "fmt"
   "log"
)

func main() {

   req := HttpRequest.NewRequest()

   // 设置超时时间,不设置时,默认30s
   req.SetTimeout(5)

   // 设置Headers
   req.SetHeaders(map[string]string{
      "Content-Type": "application/x-www-form-urlencoded", //这也是HttpRequest包的默认设置
   })

   // 设置Cookies
   req.SetCookies(map[string]string{
      "sessionid": "LSIE89SFLKGHHASLC9EETFBVNOPOXNM",
   })

   postData := map[string]interface{}{
      "id":    1,
      "title": "csdn",
   }

   // GET 默认调用方法
   resp, err := req.Get("http://127.0.0.1:8000?name=flyfreely")

   // GET 传参调用方法
   // 第2个参数默认为nil,也可以传参map[string]interface{}
   // 第2个参数不为nil时,会把传入的map以query传参的形式重新构造新url
   // 新的URL: http://127.0.0.1:8000?name=flyfreely&id=1&title=csdn

   //resp, err := req.Get("http://127.0.0.1:8000?name=flyfreely", postData)

   // POST 调用方法

   //resp, err := req.Post("http://127.0.0.1:8000", postData)

   if err != nil {
      log.Println(err)
      return
   }

   if resp.StatusCode() == 200 {
      body, err := resp.Body()
      
      if err != nil {
         log.Println(err)
         return
      }
      
      fmt.Println(string(body))
   }

   或者打印Json
   if resp.StatusCode() == 200 {
      body, err := resp.Json()
      
      if err != nil {
         log.Println(err)
         return
      }
      
      fmt.Println(body)
   }
}

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/149679.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • python pymssql_python pymssql

    python pymssql_python pymssql前言最近在学习python,发现好像没有对pymssql的详细说明,于是乎把官方文档学习一遍,重要部分做个归档,方便自己以后查阅。pymssql是python用来连接MicrosoftSQLServer的一个工具库(package)。其包含两个模块:pymssql:遵从DB-API_mssql:性能更佳、更易于使用从版本2.1.x起,整个库的实现基于FreeTDSpymssql的架构如下:在W…

    2022年10月25日
    0
  • 八大排序算法

    八大排序算法概述排序有内部排序和外部排序,内部排序是数据记录在内存中进行排序,而外部排序是因排序的数据很大,一次不能容纳全部的排序记录,在排序过程中需要访问外存。我们这里说说八大排序就是内部排序。当n较大,则应采用时间复杂度为O(nlog2n)的排序方法:快速排序、堆排序或归并排序序。快速排序:是目前基于比较的内部排序中被认为是最好的方法,当待排序的关键字是随机分…

    2022年4月26日
    35
  • C#Winform从页面获取数据,传入数据库

    C#Winform从页面获取数据,传入数据库

    2022年2月22日
    48
  • python 移动文件或文件夹操作

    python 移动文件或文件夹操作目录:1、python中对文件、文件夹操作时经常用到的os模块和shutil模块常用方法2、文件操作方法大全3、目录操作方法大全————————————————————————————–1、python中对文件、文件夹操作时经常用到的os模块和shutil模块常用方法。1.得到当前工作目录,即当前Python脚本工作的目录路径:os.getcwd()2.返回指定目录下的所有文件和目录名:os.li

    2022年5月7日
    283
  • Mysql 备份的三种方式

    Mysql 备份的三种方式备份的本质就是将数据集另存一个副本,但是原数据会不停的发生变化,所以利用备份只能回复到数据变化之前的数据。那变化之后的呢?所以制定一个好的备份策略很重要。一、备份的目的做灾难恢复:对损坏的数据进行恢复和还原需求改变:因需求改变而需要把数据还原到改变以前测试:测试新功能是否可用二、备份需要考虑的问题可以容忍丢失多长时间的数据;恢复数据要在多长时间内完;恢复的时候是否需要持续提供服务;恢复的对象,是整个库,多个表,还是单个…

    2022年6月15日
    32
  • T25 截图识别文字工具

    T25 截图识别文字工具截图识别文字工具

    2022年5月1日
    40

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号