golang http連接復用方法
更新時間:2019年07月10日 15:08:18 作者:liliangcsdn
今天小編就為大家分享一篇golang http連接復用方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
server端
golang httpserver 默認開啟keepalive連接復用選項
handler函數(shù)需要完整讀body數(shù)據(jù),構造返回消息,否則當數(shù)據(jù)不能一次發(fā)送完成時,連接復用就會失效。
示例如下
package main
import (
"fmt"
"io/ioutil"
"log"
"net/http"
"os"
"strconv"
"strings"
"time"
)
func connHandler(w http.ResponseWriter, r *http.Request) {
// parse
r.ParseForm()
response_time := r.Header.Get("sleep-time")
// <= NOTE
if _, err := ioutil.ReadAll(r.Body); err != nil {
http.Error(w, err.Error(), 500)
return
}
defer r.Body.Close()
// sleep for some time
resp_time := 1
if response_time != "" {
ms, _ := strconv.ParseFloat(response_time, 64)
resp_time = (int)(ms * 1000)
}
time.Sleep(time.Duration(resp_time) * time.Millisecond)
// parepare response
status := 200
body := ""
w.Header().Set("Content-Type", "text/plain")
w.Header().Set("Content-Length", strconv.Itoa(len(body)))
w.WriteHeader(status)
w.Write([]byte(body))
}
func main() {
http.HandleFunc("/", connHandler)
if err := http.ListenAndServe(":server_port", nil); err != nil {
log.Fatal("ListenAndServe: ", err)
}
}
client 端
客戶端需要構建全局client,完整讀 response body,并關閉body
package main
import (
"bytes"
"fmt"
"io"
"io/ioutil"
"log"
"net/http"
"time"
)
var (
httpClient *http.Client
)
const (
MaxIdleConnections int = 20
RequestTimeout int = 30
)
// init HTTPClient
func init() {
httpClient = createHTTPClient()
}
// createHTTPClient for connection re-use
func createHTTPClient() *http.Client {
client := &http.Client{
Transport: &http.Transport{
MaxIdle ConnsPerHost: MaxIdleConnections,
},
Timeout: time.Duration(RequestTimeout) * time.Second,
}
return client
}
func conn_reuse_post(conn_reuse_times int) {
var endPoint string = "http://server_ip:server_port/"
data := []byte{}
// fill data
for i := 0; i < conn_reuse_times; i++ {
// use global httpClient to send request
resp, err := httpClient.Post(endPoint, "application/x-www-form-urlencoded", bytes.NewBuffer([]byte(data)))
fmt.Println(resp)
if err != nil {
log.Println("err", err)
return
}
io.Copy(ioutil.Discard, resp.Body) // <= NOTE
resp.Body.Close() // <= NOTE
}
}
func main() {
conn_reuse_post(5)
}
以上這篇golang http連接復用方法就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
Go?CSV包實現(xiàn)結構體和csv內容互轉工具詳解
這篇文章主要介紹了Go?CSV包實現(xiàn)結構體和csv內容互轉工具詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-03-03
Golang map如何生成有序的json數(shù)據(jù)詳解
最近在學習Golang,發(fā)現(xiàn)了一個問題,覺著有必要給大家總結下,下面這篇文章主要給大家介紹了關于Golang map如何生成有序json數(shù)據(jù)的相關資料,文中通過示例代碼介紹的非常詳細,需要的朋友們下面來一起看看吧。2017-07-07

