| | |
| | | "net/http" |
| | | "time" |
| | | ) |
| | | var weedfsUri = "http://192.168.1.182:9500/submit" |
| | | func PostFormData(uri string, filename, paramName string, file multipart.File) (maps map[string]interface{}, err0 error) { |
| | | // 上传图片(二进制流) |
| | | func PostFormBufferData(uri string, fileData []byte, fileName string,) (maps map[string]interface{}, err0 error) { |
| | | body := &bytes.Buffer{} |
| | | writer := multipart.NewWriter(body) |
| | | _, err := writer.CreateFormFile(paramName, filename) |
| | | _, err := writer.CreateFormFile("file", fileName) |
| | | if err != nil { |
| | | return nil, err |
| | | } |
| | | boundary := writer.Boundary() |
| | | //close_string := fmt.Sprintf("\r\n--%s--\r\n", boundary) |
| | | close_buf := bytes.NewBufferString(fmt.Sprintf("\r\n--%s--\r\n", boundary)) |
| | | file := bytes.NewBuffer(fileData) |
| | | request_reader := io.MultiReader(body, file, close_buf) |
| | | //_, err = io.Copy(part, file) |
| | | //writer.WriteField(key, val) |
| | |
| | | } |
| | | }() |
| | | defer resp.Body.Close() |
| | | body = &bytes.Buffer{} |
| | | _, err = body.ReadFrom(resp.Body) |
| | | if err != nil { |
| | | log.Fatal(err) |
| | | { |
| | | body := &bytes.Buffer{} |
| | | _, err := body.ReadFrom(resp.Body) |
| | | if err != nil { |
| | | log.Fatal(err) |
| | | } |
| | | fmt.Println(resp.StatusCode) |
| | | //fmt.Println(resp.Header) |
| | | fmt.Println(body) |
| | | //decoder := json.NewDecoder(strings.NewReader(body.String())) |
| | | decoder := make(map[string]interface{}) |
| | | if err := json.Unmarshal([]byte(body.String()), &decoder); err != nil { |
| | | return nil, err |
| | | } |
| | | return decoder, nil |
| | | } |
| | | fmt.Println(resp.StatusCode) |
| | | //fmt.Println(body) |
| | | //decoder := json.NewDecoder(strings.NewReader(body.String())) |
| | | decoder := make(map[string]interface{}) |
| | | if err := json.Unmarshal([]byte(body.String()), &decoder); err != nil { |
| | | return nil, err |
| | | } |
| | | return decoder, nil |
| | | } |
| | | } |