From 73000facfdc05d2c72d418aa4b7b2cc9c078d695 Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期三, 26 六月 2019 19:45:58 +0800 Subject: [PATCH] test --- service/FaceSdkService.go | 25 ++++++++++++++++++++++++- 1 files changed, 24 insertions(+), 1 deletions(-) diff --git a/service/FaceSdkService.go b/service/FaceSdkService.go index bd23acf..2f10210 100644 --- a/service/FaceSdkService.go +++ b/service/FaceSdkService.go @@ -6,6 +6,9 @@ "encoding/json" "fmt" "github.com/gogo/protobuf/proto" + "github.com/satori/go.uuid" + "io/ioutil" + "time" ) const ( @@ -13,6 +16,26 @@ Url_Service_PULL = "tcp:///tmp///webserver-1.ipc" ) var imgPushChan chan protomsg.Recvmsg + +func TestPushImgMsg() { + InitService() + imgData := readImgFile() + for { + PushImgMsg(protomsg.Recvmsg{ + Id:uuid.NewV4().String(), + Addr:"", + Picdata:imgData, + }) + + time.Sleep(5*time.Second) + } +} + +func readImgFile() []byte{ + filePath := "/home/user/workspace/timg.jpg" + bytes, _ := ioutil.ReadFile(filePath) + return bytes +} func PushImgMsg(is protomsg.Recvmsg){ imgPushChan <- is @@ -42,7 +65,7 @@ } rMsg := protomsg.SdkMessage{} if err := proto.Unmarshal(resultBytes, &rMsg);err !=nil{ - fmt.Println(rMsg) + fmt.Println("recv MSG:",rMsg) resultMap[rMsg.Cid] = rMsg } -- Gitblit v1.8.0