為了模擬客戶(hù)端和服務(wù)器端惑淳，我這兒開(kāi)了兩個(gè)進(jìn)程，進(jìn)程A（監(jiān)聽(tīng)地址：http://192.168.50.250:8080 路由/objects）進(jìn)程B（監(jiān)聽(tīng)地址：http://192.168.50.250:8081 路由:/objetcs）方法都是post架馋。進(jìn)程A是監(jiān)聽(tīng)客戶(hù)上傳的文件，然后模擬http clien上傳給進(jìn)程B西饵。在B中將文件存儲(chǔ)或者將內(nèi)容打印悼沿。
進(jìn)程A post /ojects:
func PostFile(c *gin.Context){
var b bytes.Buffer
w := multipart.NewWriter(&b)
c.Request.ParseMultipartForm(100000)
multiPartform ,_:= c.MultipartForm()
err := utils.CreatFormFiles(&b,multiPartform,w)
if err != nil{
fmt.Println(err)
return
}
request,err:=http.NewRequest(http.MethodPost,"http://192.168.50.250:8081/objects",&b)
if err != nil{
fmt.Println(err)
return
}
//模擬客戶(hù)端請(qǐng)求，還可以在request.Form中添加其他信息牺荠，如username翁巍，password等key_values
client := http.Client{Timeout:5*time.Second}
request.Header.Set("Content-Type",w.FormDataContentType())
resp,err := client.Do(request)
if err != nil{
fmt.Println(err)
return
}
handlers.SendRespense(c,resp.StatusCode,"ok")
}
CreatFormFiles:
func CreatFormFiles(b *bytes.Buffer,form *multipart.Form,w *multipart.Writer)error{
for name,files := range form.File{
for _,file := range files{
f,err := file.Open()
if err != nil{
return err
}
fw,err := w.CreateFormFile(name,file.Filename)
if err != nil{
return err
}
_,err = io.Copy(fw,f)
if err != nil{
return err
}
}
}
w.Close() //要關(guān)閉，會(huì)將w.w.boundary刷寫(xiě)到w.writer中
return nil
}
進(jìn)程B post /obcjetcs：
c.Header("Access-Control-Allow-Origin", "*")
c.Header("Access-Control-Allow-Methods", "GET,POST,PUT,PATCH,DELETE,OPTIONS")
c.Header("Access-Control-Allow-Headers", "authorization, origin, content-type, accept")
c.Header("Allow", "HEAD,GET,POST,PUT,PATCH,DELETE,OPTIONS")
c.Header("Content-Type", "multipart/form-data")
c.Request.ParseMultipartForm(5000000)
form,err := c.MultipartForm()
if err != nil{
c.JSON(500,"bad form")
}
fheaders := form.File["upload"]
for _,fheader := range fheaders{
fmt.Printf("name:%s,f:%v","upload",fheader.Filename)
}
c.JSON(200,"ok")
image.png
