httputils

package module
v0.0.0-...-7132ba2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 8, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

README

httptuils

A simple HTTP Request package for golang. GET POST DELETE PUT change from github.com/kirinlabs/HttpRequest

Installation

go get github.com/gkuanine/httputils

How do we use httptuils?
Create request object use http.DefaultTransport

resp, err := httputils.Get("http://127.0.0.1:8000") resp, err := httputils.SetTimeout(5).Get("http://127.0.0.1:8000") resp, err := httputils.Debug(true).SetHeaders(map[string]string{}).Get("http://127.0.0.1:8000")

OR

req := httputils.NewRequest() req := httputils.NewRequest().Debug(true).SetTimeout(5) resp, err := req.Get("http://127.0.0.1:8000") resp, err := req.Get("http://127.0.0.1:8000",nil) resp, err := req.Get("http://127.0.0.1:8000?id=10&title=httputils") resp, err := req.Get("http://127.0.0.1:8000?id=10&title=httputils","address=beijing")


#### Set headers
```go
req.SetHeaders(map[string]string{
    "Content-Type": "application/x-www-form-urlencoded",
    "Connection": "keep-alive",
})

req.SetHeaders(map[string]string{
    "Source":"api",
})
Set cookies
req.SetCookies(map[string]string{
    "name":"json",
    "token":"",
})

OR

httputils.SetCookies(map[string]string{
    "age":"19",
}).Post()
Set basic auth
req.SetBasicAuth("username","password")
Set timeout
req.SetTimeout(5)  //default 30s
Transport

If you want to customize the Client object and reuse TCP connections, you need to define a global http.RoundTripper or & http.Transport, because the reuse of the http connection pool is based on 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 := httputils.Get("http://127.0.0.1:8080")
    // Use custom Transport
    res, err := httputils.Transport(transport).Get("http://127.0.0.1:8080")
}
Keep Alives，Only effective for custom Transport
req.DisableKeepAlives(false)

httputils.Transport(transport).DisableKeepAlives(false).Get("http://127.0.0.1:8080")
Ignore Https certificate validation，Only effective for custom Transport
req.SetTLSClient(&tls.Config{InsecureSkipVerify: true})

httputils.Transport(transport).SetTLSClient(&tls.Config{InsecureSkipVerify: true}).Get("http://127.0.0.1:8080")
Object-oriented operation mode
req := httputils.NewRequest().
	Debug(true).
	SetHeaders(map[string]string{
	    "Content-Type": "application/x-www-form-urlencoded",
	}).SetTimeout(5)
resp,err := req.Get("http://127.0.0.1")

resp,err := httputils.NewRequest().Get("http://127.0.0.1")
GET
Query parameter
resp, err := req.Get("http://127.0.0.1:8000")
resp, err := req.Get("http://127.0.0.1:8000",nil)
resp, err := req.Get("http://127.0.0.1:8000?id=10&title=httputils")
resp, err := req.Get("http://127.0.0.1:8000?id=10&title=httputils","address=beijing")

OR

resp, err := httputils.Get("http://127.0.0.1:8000")
resp, err := httputils.Debug(true).SetHeaders(map[string]string{}).Get("http://127.0.0.1:8000")
Multi parameter
resp, err := req.Get("http://127.0.0.1:8000?id=10&title=httputils",map[string]interface{}{
    "name":  "jason",
    "score": 100,
})
defer resp.Close()

body, err := resp.Body()
if err != nil {
    return
}

return string(body)
POST
// Send nil
resp, err := httputils.Post("http://127.0.0.1:8000")

// Send integer
resp, err := httputils.Post("http://127.0.0.1:8000", 100)

// Send []byte
resp, err := httputils.Post("http://127.0.0.1:8000", []byte("bytes data"))

// Send io.Reader
resp, err := httputils.Post("http://127.0.0.1:8000", bytes.NewReader(buf []byte))
resp, err := httputils.Post("http://127.0.0.1:8000", strings.NewReader("string data"))
resp, err := httputils.Post("http://127.0.0.1:8000", bytes.NewBuffer(buf []byte))

// Send string
resp, err := httputils.Post("http://127.0.0.1:8000", "title=github&type=1")

// Send JSON
resp, err := httputils.PostJson("http://127.0.0.1:8000", "{\"id\":10,\"title\":\"httputils\"}")

// Send map[string]interface{}{}
resp, err := req.Post("http://127.0.0.1:8000", map[string]interface{}{
    "id":    10,
    "title": "httputils",
})
defer resp.Close()

body, err := resp.Body()
if err != nil {
    return
}
return string(body)

resp, err := httputils.Post("http://127.0.0.1:8000")
resp, err := httputils.JSON().Post("http://127.0.0.1:8000",map[string]interface{}{"title":"github"})
resp, err := httputils.Debug(true).SetHeaders(map[string]string{}).JSON().Post("http://127.0.0.1:8000","{\"title\":\"github\"}")
Jar
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"},
})
resp, err := httputils.Jar(j).Get("http://127.0.0.1:8000/city/list")
defer resp.Close()

if err != nil {
	log.Fatalf("Request error：%v", err.Error())
}
Proxy
proxy, err := url.Parse("http://proxyip:proxyport")
if err != nil {
	log.Println(err)
}

resp, err := httputils.Proxy(http.ProxyURL(proxy)).Get("http://127.0.0.1:8000/ip")
defer resp.Close()

if err != nil {
	log.Println("Request error：%v", err.Error())
}

body, err := resp.Body()
if err != nil {
	log.Println("Get body error：%v", err.Error())
}
log.Println(string(body))
Upload

Params: url, filename, fileinput

resp, err := req.Upload("http://127.0.0.1:8000/upload", "/root/demo.txt","uploadFile")
body, err := resp.Body()
defer resp.Close()
if err != nil {
    return
}
return string(body)
Debug
Default false
req.Debug(true)
Print in standard output：
[httputils]
-------------------------------------------------------------------
Request: GET http://127.0.0.1:8000?name=iceview&age=19&score=100
Headers: map[Content-Type:application/x-www-form-urlencoded]
Cookies: map[]
Timeout: 30s
ReqBody: map[age:19 score:100]
-------------------------------------------------------------------

Json

Post JSON request

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

Or

req.JSON().Post("http://127.0.0.1:8000", map[string]interface{}{
    "id":    10,
    "title": "github",
})

req.JSON().Post("http://127.0.0.1:8000", "{\"title\":\"github\",\"id\":10}")
Post request
resp, err := req.Post("http://127.0.0.1:8000", map[string]interface{}{
    "id":    10,
    "title": "httputils",
})
Print formatted JSON
str, err := resp.Export()
if err != nil {
   return
}
Unmarshal JSON
var u User
err := resp.Json(&u)
if err != nil {
   return err
}

var m map[string]interface{}
err := resp.Json(&m)
if err != nil {
   return err
}
Response
Response() *http.Response
resp, err := req.Post("http://127.0.0.1:8000/") //res is a http.Response object
StatusCode() int
resp.StatusCode()
Body() ([]byte, error)
body, err := resp.Body()
log.Println(string(body))
Close() error
resp.Close()
Time() string
resp.Time()  //ms
Print formatted JSON
str, err := resp.Export()
if err != nil {
   return
}
Unmarshal JSON
var u User
err := resp.Json(&u)
if err != nil {
   return err
}

var m map[string]interface{}
err := resp.Json(&m)
if err != nil {
   return err
}
Url() string
resp.Url()  //return the requested url
Headers() http.Header
resp.Headers()  //return the response headers
resp.Headers().Get("Content-Type")

resp.Cookies()  //return the response cookies
Advanced
GET
import "github.com/gkuanine/httputils"
   
resp,err := httputils.Get("http://127.0.0.1:8000/")
resp,err := httputils.Get("http://127.0.0.1:8000/","title=github")
resp,err := httputils.Get("http://127.0.0.1:8000/?title=github")
resp,err := httputils.Debug(true).JSON().Get("http://127.0.0.1:8000/")
POST
import "github.com/gkuanine/httputils"
   
resp,err := httputils.Post("http://127.0.0.1:8000/")
resp,err := httputils.SetHeaders(map[string]string{
	"title":"github",
}).Post("http://127.0.0.1:8000/")
resp,err := httputils.Debug(true).JSON().Post("http://127.0.0.1:8000/")
Example
import "github.com/gkuanine/httputils"
   
resp,err := httputils.Get("http://127.0.0.1:8000/")
resp,err := httputils.Get("http://127.0.0.1:8000/","title=github")
resp,err := httputils.Get("http://127.0.0.1:8000/?title=github")
resp,err := httputils.Get("http://127.0.0.1:8000/",map[string]interface{}{
	"title":"github",
})
resp,err := httputils.Debug(true).JSON().SetHeaders(map[string]string{
	"source":"api",
}).SetCookies(map[string]string{
	"name":"httputils",
}).Post("http://127.0.0.1:8000/")


//Or
req := httputils.NewRequest()
req := req.Debug(true).SetHeaders()
resp,err := req.Debug(true).JSON().SetHeaders(map[string]string{
    "source":"api",
}).SetCookies(map[string]string{
    "name":"httputils",
}).Post("http://127.0.0.1:8000/")

httputils

Documentation

Index

Constants

View Source 
const DEFAULT_RETRY_TIMES = 3

Variables

This section is empty.

Functions

func Export 

func Export(v interface{}) string

func IntByte 

func IntByte(v interface{}) []byte

func Json 

func Json(v interface{}) string

Types

type Request 

type Request struct {
	// contains filtered or unexported fields
}

func CheckRedirect 

func CheckRedirect(v func(req *http.Request, via []*http.Request) error) *Request

func Debug 

func Debug(v bool) *Request

Debug model

func DisableKeepAlives 

func DisableKeepAlives(v bool) *Request

func JSON 

func JSON() *Request

func Jar 

func Jar(v http.CookieJar) *Request

func NewRequest 

func NewRequest() *Request

func Proxy 

func Proxy(v func(*http.Request) (*url.URL, error)) *Request

func SetBasicAuth 

func SetBasicAuth(username, password string) *Request

func SetCookies 

func SetCookies(cookies map[string]string) *Request

func SetHeaders 

func SetHeaders(headers map[string]string) *Request

func SetTLSClient 

func SetTLSClient(v *tls.Config) *Request

func SetTimeout 

func SetTimeout(d time.Duration) *Request

func TLSClient 

func TLSClient(v *tls.Config) *Request

func Transport 

func Transport(v *http.Transport) *Request

func (*Request) CheckRedirect 

func (r *Request) CheckRedirect(v func(req *http.Request, via []*http.Request) error) *Request

func (*Request) Debug 

func (r *Request) Debug(v bool) *Request

Debug model

func (*Request) Delete 

func (r *Request) Delete(url string, data ...interface{}) (*Response, error)

Delete is a delete http request

func (*Request) DisableKeepAlives 

func (r *Request) DisableKeepAlives(v bool) *Request

func (*Request) GetRetry 

func (r *Request) GetRetry(url string, retry int, data ...interface{}) (*Response, error)

Get is a get http request

func (*Request) JSON 

func (r *Request) JSON() *Request

func (*Request) Jar 

func (r *Request) Jar(v http.CookieJar) *Request

func (*Request) PostJson 

func (r *Request) PostJson(url string, data ...interface{}) (*Response, error)

func (*Request) PostJsonRetry 

func (r *Request) PostJsonRetry(url string, retry int, data ...interface{}) (*Response, error)

PostJson is a post http request

func (*Request) PostRetry 

func (r *Request) PostRetry(url string, retry int, data ...interface{}) (*Response, error)

Post is a post http request

func (*Request) Proxy 

func (r *Request) Proxy(v func(*http.Request) (*url.URL, error)) *Request

func (*Request) Put 

func (r *Request) Put(url string, data ...interface{}) (*Response, error)

Put is a put http request

func (*Request) SetBasicAuth 

func (r *Request) SetBasicAuth(username, password string) *Request

Set basic auth

func (*Request) SetCookies 

func (r *Request) SetCookies(cookies map[string]string) *Request

Set cookies

func (*Request) SetHeaders 

func (r *Request) SetHeaders(headers map[string]string) *Request

Set headers

func (*Request) SetTLSClient 

func (r *Request) SetTLSClient(v *tls.Config) *Request

func (*Request) SetTimeout 

func (r *Request) SetTimeout(d time.Duration) *Request

func (*Request) TLSClient 

func (r *Request) TLSClient(v *tls.Config) *Request

func (*Request) Transport 

func (r *Request) Transport(v *http.Transport) *Request

func (*Request) Upload 

func (r *Request) Upload(url, filename, fileinput string) (*Response, error)

Upload file

type Response 

type Response struct {
	// contains filtered or unexported fields
}

func Delete 

func Delete(url string, data ...interface{}) (*Response, error)

Delete is a delete http request

func Get 

func Get(url string, data ...interface{}) (*Response, error)

Get is a get http request

func GetRetry 

func GetRetry(url string, retry int, data ...interface{}) (*Response, error)

Get is a get http request

func Post 

func Post(url string, data ...interface{}) (*Response, error)

func PostJson 

func PostJson(url string, data ...interface{}) (*Response, error)

Post is a post http request

func PostJsonRetry 

func PostJsonRetry(url string, retry int, data ...interface{}) (*Response, error)

Post is a post http request

func PostRetry 

func PostRetry(url string, retry int, data ...interface{}) (*Response, error)

Post is a post http request

func Put 

func Put(url string, data ...interface{}) (*Response, error)

Put is a put http request

func Upload 

func Upload(url, filename, fileinput string) (*Response, error)

Upload file

func (*Response) Body 

func (r *Response) Body() ([]byte, error)

func (*Response) Close 

func (r *Response) Close() error

func (*Response) Content 

func (r *Response) Content() (string, error)

func (*Response) Cookies 

func (r *Response) Cookies() []*http.Cookie

func (*Response) Export 

func (r *Response) Export() (string, error)

func (*Response) Headers 

func (r *Response) Headers() http.Header

func (*Response) Json 

func (r *Response) Json(v interface{}) error

func (*Response) Response 

func (r *Response) Response() *http.Response

func (*Response) StatusCode 

func (r *Response) StatusCode() int

func (*Response) Time 

func (r *Response) Time() string

func (*Response) Unmarshal 

func (r *Response) Unmarshal(v interface{}) error

func (*Response) Url 

func (r *Response) Url() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.