From 77e5c74f72c3d2e8470d19a3236ef38198e4cb66 Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期三, 26 六月 2019 19:55:02 +0800 Subject: [PATCH] test --- service/FaceSdkService.go | 12 ++++++++++-- 1 files changed, 10 insertions(+), 2 deletions(-) diff --git a/service/FaceSdkService.go b/service/FaceSdkService.go index 2f10210..31330ef 100644 --- a/service/FaceSdkService.go +++ b/service/FaceSdkService.go @@ -20,20 +20,24 @@ func TestPushImgMsg() { InitService() imgData := readImgFile() + fmt.Println("imgData.len:",len(imgData)) for { PushImgMsg(protomsg.Recvmsg{ Id:uuid.NewV4().String(), Addr:"", Picdata:imgData, }) - + fmt.Println("pushed img") time.Sleep(5*time.Second) } } func readImgFile() []byte{ filePath := "/home/user/workspace/timg.jpg" - bytes, _ := ioutil.ReadFile(filePath) + bytes, err := ioutil.ReadFile(filePath) + if err !=nil { + fmt.Println("Read img err:",err) + } return bytes } @@ -45,14 +49,18 @@ func InitService(){ + fmt.Println("service init!") imgPushChan = make(chan protomsg.Recvmsg) client_push := deliver.NewClient(deliver.PushPull, Url_Service_PUSH) client_pull := deliver.NewClient(deliver.PushPull, Url_Service_PULL) for { select { case is := <- imgPushChan: + fmt.Println("imgPushChan in") b, _ := json.Marshal(is) client_push.Send(b) + default: + fmt.Println("no img in") } } -- Gitblit v1.8.0