From ca177f11067d4886e615a2179e943ed6acc687b4 Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期一, 15 七月 2019 10:54:07 +0800 Subject: [PATCH] 把es插入路径换成配置文件里的 --- util/upload.go | 59 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 59 insertions(+), 0 deletions(-) diff --git a/util/upload.go b/util/upload.go index a5e4870..90e2d0d 100644 --- a/util/upload.go +++ b/util/upload.go @@ -135,4 +135,63 @@ } return decoder, nil } +} + +func UploadFromMat(rook gocv.Mat)(maps map[string]interface{}, err0 error){ + // 涓婁紶 + fdata, _ := gocv.IMEncode(".jpg", rook) + body := &bytes.Buffer{} + writer := multipart.NewWriter(body) + _, err1 := writer.CreateFormFile("file", "fasjuierf") + if err1 != nil { + return nil, err1 + } + 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(fdata) + request_reader := io.MultiReader(body, file, close_buf) + //_, err = io.Copy(part, file) + //writer.WriteField(key, val) + request, err := http.NewRequest("POST", "http://192.168.1.182:6333/submit", request_reader) + request.Header.Add("Content-Type", writer.FormDataContentType()) + timeout := time.Duration(5 * time.Second) //瓒呮椂鏃堕棿50ms + client := &http.Client{Timeout: timeout} + resp, err := client.Do(request) + if err != nil { + log.Fatal(err) + return nil, err + } + defer func() { + if r := recover(); r != nil { + fmt.Printf("panic鐨勫唴瀹�%v\n", r) + msg := "涓婁紶鍥剧墖鏈嶅姟鍣ㄥ紓甯�" + if _, ok := r.(error); ok { + msg = r.(error).Error() + fmt.Println("panic--recover()寰楀埌鐨勬槸error绫诲瀷") + } + if _, ok := r.(string); ok { + msg = r.(string) + fmt.Println("panic--recover()寰楀埌鐨勬槸string绫诲瀷") + } + err0 = errors.New(msg) + } + }() + defer resp.Body.Close() + { + 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 + } } \ No newline at end of file -- Gitblit v1.8.0