真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

使用golang語(yǔ)言怎么對(duì)http請(qǐng)求進(jìn)行封裝-創(chuàng)新互聯(lián)

這篇文章給大家介紹使用golang語(yǔ)言怎么對(duì)http請(qǐng)求進(jìn)行封裝，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

成都創(chuàng)新互聯(lián)公司主要從事網(wǎng)站設(shè)計(jì)制作、成都網(wǎng)站設(shè)計(jì)、網(wǎng)頁(yè)設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)虞城,十余年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(yōu)惠、服務(wù)專業(yè),歡迎來(lái)電咨詢建站服務(wù):13518219792

在GOPATH 中創(chuàng)建 utils 文件夾 放置這兩個(gè)文件

http.go

package utils 
import (
 "crypto/tls"
 "encoding/json"
 "errors"
 "fmt"
 "io/ioutil"
 "net/http"
 "net/url"
 "strings"
 "sync"
) 
var (
 GET_METHOD = "GET"
 POST_METHOD = "POST"
 SENDTYPE_FROM = "from"
 SENDTYPE_JSON = "json"
) 
type HttpSend struct {
 Link  string
 SendType string
 Header map[string]string
 Body  map[string]string
 sync.RWMutex
} 
func NewHttpSend(link string) *HttpSend {
 return &HttpSend{
  Link:  link,
  SendType: SENDTYPE_FROM,
 }
} 
func (h *HttpSend) SetBody(body map[string]string) {
 h.Lock()
 defer h.Unlock()
 h.Body = body
} 
func (h *HttpSend) SetHeader(header map[string]string) {
 h.Lock()
 defer h.Unlock()
 h.Header = header
} 
func (h *HttpSend) SetSendType(send_type string) {
 h.Lock()
 defer h.Unlock()
 h.SendType = send_type
} 
func (h *HttpSend) Get() ([]byte, error) {
 return h.send(GET_METHOD)
} 
func (h *HttpSend) Post() ([]byte, error) {
 return h.send(POST_METHOD)
} 
func GetUrlBuild(link string, data map[string]string) string {
 u, _ := url.Parse(link)
 q := u.Query()
 for k, v := range data {
  q.Set(k, v)
 }
 u.RawQuery = q.Encode()
 return u.String()
} 
func (h *HttpSend) send(method string) ([]byte, error) {
 var (
  req  *http.Request
  resp  *http.Response
  client http.Client
  send_data string
  err  error
 ) 
 if len(h.Body) > 0 {
  if strings.ToLower(h.SendType) == SENDTYPE_JSON {
   send_body, json_err := json.Marshal(h.Body)
   if json_err != nil {
    return nil, json_err
   }
   send_data = string(send_body)
  } else {
   send_body := http.Request{}
   send_body.ParseForm()
   for k, v := range h.Body {
    send_body.Form.Add(k, v)
   }
   send_data = send_body.Form.Encode()
  }
 } 
 //忽略https的證書
 client.Transport = &http.Transport{
  TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
 } 
 req, err = http.NewRequest(method, h.Link, strings.NewReader(send_data))
 if err != nil {
  return nil, err
 }
 defer req.Body.Close()
 
 //設(shè)置默認(rèn)header
 if len(h.Header) == 0 {
  //json
  if strings.ToLower(h.SendType) == SENDTYPE_JSON {
   h.Header = map[string]string{
    "Content-Type": "application/json; charset=utf-8",
   }
  } else { //form
   h.Header = map[string]string{
    "Content-Type": "application/x-www-form-urlencoded",
   }
  }
 } 
 for k, v := range h.Header {
  if strings.ToLower(k) == "host" {
   req.Host = v
  } else {
   req.Header.Add(k, v)
  }
 } 
 resp, err = client.Do(req)
 if err != nil {
  return nil, err
 }
 defer resp.Body.Close()
 
 if resp.StatusCode != http.StatusOK {
  return nil, errors.New(fmt.Sprintf("error http code :%d", resp.StatusCode))
 } 
 return ioutil.ReadAll(resp.Body)
}

http_test.go

package utils 
import (
 "testing"
) 
func Test_Get(t *testing.T) {
 h := NewHttpSend(GetUrlBuild("http://127.0.0.1/test.php", map[string]string{"name": "xiaochuan"}))
 _, err := h.Get()
 if err != nil {
 t.Error("請(qǐng)求錯(cuò)誤:", err)
 } else {
 t.Log("正常返回")
 }
} 
func Test_Post(t *testing.T) {
 h := NewHttpSend("http://127.0.0.1/test.php")
 h.SetBody(map[string]string{"name": "xiaochuan"})
 _, err := h.Post()
 if err != nil {
 t.Error("請(qǐng)求錯(cuò)誤:", err)
 } else {
 t.Log("正常返回")
 }
} 
func Test_Json(t *testing.T) {
 h := NewHttpSend("http://127.0.0.1/test.php")
 h.SetSendType("JSON")
 h.SetBody(map[string]string{"name": "xiaochuan"})
 _, err := h.Post()
 if err != nil {
 t.Error("請(qǐng)求錯(cuò)誤:", err)
 } else {
 t.Log("正常返回")
 }
} 
func Benchmark_GET(b *testing.B) {
 for i := 0; i < b.N; i++ {
 h := NewHttpSend(GetUrlBuild("http://127.0.0.1/test.php", map[string]string{"name": "xiaochuan"}))
 _, err := h.Get()
 if err != nil {
 b.Error("請(qǐng)求錯(cuò)誤:", err)
 } else {
 b.Log("正常返回")
 }
 }
}

補(bǔ)充：golang中發(fā)送http請(qǐng)求的幾種常見(jiàn)情況

整理一下golang中各種http的發(fā)送方式

最初的一些項(xiàng)目中，很多的地方都使用到了golang發(fā)送http請(qǐng)求，之后再對(duì)請(qǐng)求收到的結(jié)果進(jìn)行一些處理，所用到的模式也比較固定，這里整理一下集中http的發(fā)送方式，先記錄這么多，再一點(diǎn)一點(diǎn)添加。

最基本的場(chǎng)景

方式一 使用http.Newrequest

先生成http.client -> 再生成 http.request -> 之后提交請(qǐng)求：client.Do(request) -> 處理返回結(jié)果，每一步的過(guò)程都可以設(shè)置一些具體的參數(shù)，下面是一個(gè)最樸素最基本的例子：

//question ???將stdout重定向?yàn)閞esponse信息？？？
package main 
import (
 "fmt"
 "io"
 "net/http"
 "os"
) 
func main() {
 //生成client 參數(shù)為默認(rèn)
 client := &http.Client{} 
 //生成要訪問(wèn)的url
 url := "http://www.baidu.com"  
 //提交請(qǐng)求
 reqest, err := http.NewRequest("GET", url, nil) 
 if err != nil {
 panic(err)
 } 
 //處理返回結(jié)果
 response, _ := client.Do(reqest) 
 //將結(jié)果定位到標(biāo)準(zhǔn)輸出 也可以直接打印出來(lái) 或者定位到其他地方進(jìn)行相應(yīng)的處理
 stdout := os.Stdout
 _, err = io.Copy(stdout, response.Body) 
 //返回的狀態(tài)碼
 status := response.StatusCode 
 fmt.Println(status) 
}

方式二 先生成client，之后用client.get/post..

client結(jié)構(gòu)自己也有一些發(fā)送api的方法，比如client.get,client.post,client.postform..等等?；旧虾w了主要的http請(qǐng)求的類型，通常不進(jìn)行什么特殊的配置的話，這樣就可以了，其實(shí)client的get或者post方法，也是對(duì)http.Newerequest方法的封裝，里面還額外添加了req.Header.Set("Content-Type", bodyType)一般用的話，也是ok的

方式三 http. Get/Post..

具體實(shí)現(xiàn)的時(shí)候，還是采用的先前提到的模式，先生成一個(gè)默認(rèn)的client，之后調(diào)用http.Newrequest方法。

對(duì)每個(gè)步驟進(jìn)行細(xì)節(jié)性的說(shuō)明

生成client時(shí)候的參數(shù)配置

最常見(jiàn)的一個(gè)參數(shù)是使用https的方式發(fā)送信息時(shí)候client端的設(shè)置。如果生成client的時(shí)候，什么信息都不添加，就會(huì)使用默認(rèn)的值。具體的信息包括：

 Transport RoundTripper
 CheckRedirect func(req *Request, via []*Request) error
 Jar CookieJar
 Timeout time.Duration

第一個(gè)參數(shù)是一個(gè)RoundTripper接口，里面包含了一個(gè)RoundTrip函數(shù)，指定了一些http請(qǐng)求的基本機(jī)制。

http.Transport中涉及到的參數(shù)較多，要是不指定的話，就會(huì)使用默認(rèn)的DefaultTransport參數(shù)，里面包含一些默認(rèn)的請(qǐng)求時(shí)間以及proxy機(jī)制之類的。

具體的細(xì)節(jié)參數(shù)涉及到好多，有的都沒(méi)有使用到過(guò)比如那些我握手時(shí)間之類的，目前使用到的最多的就是https的相關(guān)參數(shù)：TLSClientConfig，這是一個(gè)*tls.Config類型，其中涉及到的參數(shù)還是有很多，一個(gè)基本的是用案例如下，僅僅是在配置中制定了rooca以及客戶度端使用的證書。

通常發(fā)送https請(qǐng)求的時(shí)候，前面的參數(shù)可以使用如下方式進(jìn)行處理：

pool := x509.NewCertPool()
 caCertPath := "certs/cert_server/ca.crt" 
 caCrt, err := ioutil.ReadFile(caCertPath)
 if err != nil {
 fmt.Println("ReadFile err:", err)
 return
 }
 pool.AppendCertsFromPEM(caCrt) 
 cliCrt, err := tls.LoadX509KeyPair("certs/cert_server/client.crt", "certs/cert_server/client.key")
 if err != nil {
 fmt.Println("Loadx509keypair err:", err)
 return
 } 
 tr := &http.Transport{
 TLSClientConfig: &tls.Config{
 RootCAs:  pool,
 Certificates: []tls.Certificate{cliCrt},
 },
 }
 client := &http.Client{Transport: tr}

生成request時(shí)候的參數(shù)配置

生成request的時(shí)候，主要的是幾個(gè)基本的參數(shù)。NewRequest函數(shù)有三個(gè)基本的參數(shù)，NewRequest(method, urlStr string, body io.Reader)第一個(gè)是請(qǐng)求的類型，GET, POST, PUT, etc.要設(shè)成大寫的形式。第二個(gè)參數(shù)是請(qǐng)求要訪問(wèn)的url，第三個(gè)參數(shù)是請(qǐng)求的body中的內(nèi)容，需要是一個(gè)io.Reader的類型。

注意io.Reader的接口中是一個(gè)Read方法，實(shí)現(xiàn)了Read方法的類型應(yīng)該都可以作為io.Reader來(lái)返回,Read(p []byte) (n int, err error)函數(shù)具體的功能就是讀入len(p)長(zhǎng)度的內(nèi)容到p中，返回讀入的長(zhǎng)度以及錯(cuò)誤信息。

通常是采用strings.NewReader函數(shù)，將一個(gè)string類型轉(zhuǎn)化為io.Reader類型，或者bytes.NewBuffer函數(shù)，將[]byte類型轉(zhuǎn)化為io.Reader類型。

此外還可以給request的header中添加一些額外的信息，比如下面例子中添加了請(qǐng)求的body的類型以及token的信息。

reqest.Header.Set("Content-Type", "application/x-www-form-urlencoded")

reqest.Header.Set("Authorization", "qwertyuiopasdfghjklzxcvbnm1234567890")

還有比如模擬表單提交，可以把提交的類型設(shè)置為url.Values類型再進(jìn)行Encode：

// use map as struct
 var clusterinfo = url.Values{}
 //var clusterinfo = map[string]string{}
 clusterinfo.Add("userName", user)
 clusterinfo.Add("password", pw)
 clusterinfo.Add("cloudName", clustername)
 clusterinfo.Add("masterIp", masterip)
 clusterinfo.Add("cacrt", string(caCrt)) 
 data := clusterinfo.Encode() 
 url := "https://10.10.105.124:8443/user/checkAndUpdate"
 reqest, err := http.NewRequest("POST", url, strings.NewReader(data))

最常見(jiàn)的一種情況是發(fā)送一個(gè)json文件過(guò)去，可以把Header的類型設(shè)置成為：

"Content-Type", "application/json; charset=utf-8"

其余的部分按照先前同樣的方式進(jìn)行設(shè)置發(fā)送提交就好。

request的類型的屬性還是比較多的，慢慢整理。

生成的response結(jié)果的處理

一般在client構(gòu)建好之后，要采用client.Do(request)方法提交client請(qǐng)求，之后會(huì)返回一個(gè)*Response類型。response中的參數(shù)一般也比較多，我們需要的最多的通常是Body參數(shù)，一般通過(guò)body, _ := ioutil.ReadAll(resp.Body)會(huì)把body轉(zhuǎn)化為[]byte類型返回過(guò)來(lái), 之后再進(jìn)行其他的處理。

關(guān)于使用golang語(yǔ)言怎么對(duì)http請(qǐng)求進(jìn)行封裝就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。


網(wǎng)站題目：使用golang語(yǔ)言怎么對(duì)http請(qǐng)求進(jìn)行封裝-創(chuàng)新互聯(lián)
網(wǎng)站URL：http://weahome.cn/article/cooedc.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220（工作日）

18980820575（7×24）

提交需求

返回頂部