golang高性能的http請求 fasthttp

fasthttp 據說是目前golang性能最好的http庫，相對於自帶的net/http，性能說是有10倍的提升，具體介紹可以看看官方介紹: valyala/fasthttp

 

1,首先安裝fasthttp

go get -u github.com/valyala/fasthttp

 

2,簡單的一個get請求

package main

import (
    "github.com/valyala/fasthttp"
)

func main() {
    url := `http://httpbin.org/get`

    status, resp, err := fasthttp.Get(nil, url)
    if err != nil {
        fmt.Println("請求失敗:", err.Error())
        return
    }

    if status != fasthttp.StatusOK {
        fmt.Println("請求沒有成功:", status)
        return
    }

    fmt.Println(string(resp))
}

 

2，簡單的Post請求

func main() {
    url := `http://httpbin.org/post?key=123`
    
    // 填充表單，類似於net/url
    args := &fasthttp.Args{}
    args.Add("name", "test")
    args.Add("age", "18")

    status, resp, err := fasthttp.Post(nil, url, args)
    if err != nil {
        fmt.Println("請求失敗:", err.Error())
        return
    }

    if status != fasthttp.StatusOK {
        fmt.Println("請求沒有成功:", status)
        return
    }

    fmt.Println(string(resp))
}

 

比如有些API服務需要我們提供json body或者xml body也就是，Content-Type是application/json、application/xml或者其他類型

func main() {
    url := `http://httpbin.org/post?key=123`
    
    req := &fasthttp.Request{}
    req.SetRequestURI(url)
    
    requestBody := []byte(`{"request":"test"}`)
    req.SetBody(requestBody)

    // 默認是application/x-www-form-urlencoded
    req.Header.SetContentType("application/json")
    req.Header.SetMethod("POST")

    resp := &fasthttp.Response{}

    client := &fasthttp.Client{}
    if err := client.Do(req, resp);err != nil {
        fmt.Println("請求失敗:", err.Error())
        return
    }

    b := resp.Body()

    fmt.Println("result:\r\n", string(b))
}

 

翻閱文檔發現了他提供了幾個方法：AcquireRequest()、AcquireResponse(),而且也推薦了在有性能要求的代碼中，通過 AcquireRequest 和 AcquireResponse 來獲取 req 和 resp。

func main() {
    url := `http://httpbin.org/post?key=123`

    req := fasthttp.AcquireRequest()
    defer fasthttp.ReleaseRequest(req) // 用完需要釋放資源
    
    // 默認是application/x-www-form-urlencoded
    req.Header.SetContentType("application/json")
    req.Header.SetMethod("POST")
    
    req.SetRequestURI(url)
    
    requestBody := []byte(`{"request":"test"}`)
    req.SetBody(requestBody)

    resp := fasthttp.AcquireResponse()
    defer fasthttp.ReleaseResponse(resp) // 用完需要釋放資源

    if err := fasthttp.Do(req, resp); err != nil {
        fmt.Println("請求失敗:", err.Error())
        return
    }

    b := resp.Body()

    fmt.Println("result:\r\n", string(b))
}