Golang編寫客戶端、服務端並實現檔案傳輸
建立Server
server := &http.Server{ Addr:":" + port, Handler: mux}
注意mux是一個實現了路由的物件。其帶有ServeHttp方法。其實也可以是一般的HandlerFunc,只要是實現了ServeHTTP的物件都行。
handler函式原型為:
func HandlerDownload(w http.ResponseWriter, r *http.Request)
通過http.HandleFunc()函式,可將其改變為帶有ServeHTTP方法的物件。
建立client request
client := &http.Client{}//建立客戶端 req, _ := http.NewRequest("GET", "http://baidu.com", nil)//建立request物件,第三個引數是body內容,建立之後可以設定head引數等。 httputil.DumpRequest(req, false)//dump出遠端伺服器返回的資訊 resp, _ := client.Do(req)//客戶端發出request請求 body, _ := ioutil.ReadAll(resp.Body) defer resp.Body.Close() log.Println(string(body))
客戶端與服務端資訊傳輸,content-type主要為二進位制或字串。字串可以自定義編碼,二進位制就是檔案或圖片等。不同的content-type含義:
x-www-form-urlencoded:客戶端提交表格時候的編碼方式,類似於url編碼
form-data:也是表格,但是支援檔案,不同key-value之間要用boundary分隔
binary:檔案,只能是單個檔案
json/html/plain text/xml等:都是字串,交由瀏覽器解析
測試Handler
測試server的Handler函式,首先需要構建request物件,然後構建responseRecorder物件,記錄handler的返回值。
func testHandler(t *testing.T) { param := url.Values{} param["page"] = []string{"1"} param["page_size"] = []string{"100"} //建立 request req, _ := http.NewRequest("GET", "/"+param.Encode(), nil) req.Header.Set("Authorization", "Token abc123") //建立 response rr := httptest.NewRecorder() //只測試函式,跳過mux路由 HandlerTest(rr, req) log.Println(rr.Body.String()) log.Println(rr.Result()) log.Println(rr.Code) }
檔案上傳
func testUpload(t *testing.T) { var client *http.Client var remoteURL string //構建server 物件 ts := httptest.NewTLSServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { b, err := httputil.DumpRequest(r, true) if err != nil { panic(err) } fmt.Printf("%s", b) })) defer ts.Close() client = ts.Client() remoteURL = ts.URL //模擬客戶端提交表格 values := map[string]io.Reader{ "file":mustOpen("123.txt"), // 123.txt是本地檔案 "key":strings.NewReader("hello world!"), "key2": strings.NewReader("hello world2!"), } err := Upload(client, remoteURL, values) if err != nil { panic(err) } } func Upload(client *http.Client, url string, values map[string]io.Reader) (err error) { // 構建multipart,然後post給服務端 var b bytes.Buffer w := multipart.NewWriter(&b) for key, r := range values { var fw io.Writer if x, ok := r.(io.Closer); ok { defer x.Close() } // 新增檔案 if x, ok := r.(*os.File); ok { if fw, err = w.CreateFormFile(key, x.Name()); err != nil { return } } else {//新增字串 // Add other fields if fw, err = w.CreateFormField(key); err != nil { return } } if _, err = io.Copy(fw, r); err != nil { return err } } // close動作會在末端寫入 boundary. w.Close() req, err := http.NewRequest("POST", url, &b) if err != nil { return } // form-data格式,且自動生成分隔符. //例Content-Type: multipart/form-data; boundary=d76....d29 req.Header.Set("Content-Type", w.FormDataContentType()) // 提交 request res, err := client.Do(req) if err != nil { return } // 檢查返回狀態嗎 if res.StatusCode != http.StatusOK { err = fmt.Errorf("bad status: %s", res.Status) } return } func mustOpen(f string) *os.File { r, err := os.Open(f) if err != nil { panic(err) } return r }
form-data的body樣例:
//檔案部分
--d6...9
Content-Disposition: form-data; name="file"; filename="123.txt"
Content-Type: application/octet-stream
//key value部分:w.CreateFormField(key);
--d6.....9
Content-Disposition: form-data; name="file"
//最末端還有分隔符
--d6.....9--
server端處理檔案
儲存客戶端上傳的檔案
Request.FormFile("FormFile")得到file物件和file頭
然後用os.File建立本地檔案
最後用io.Copy將request檔案儲存到目標檔案。
向客戶端推送檔案
os.File開啟檔案,
用file.Stat()獲取檔案屬性
設定檔案頭
w.Header().Set("Content-Type", "application/x-zip-compressed")
//也可用http.DetectContentType獲得檔案型別:application/zip
w.Header().Set("Content-Disposition", "attachment; filename="+fileSta.Name())
w.Header().Set("Content-Length", strconv.FormatInt(fileSta.Size(), 10))
推送檔案
io.Copy(ResponseWriter,file)