test

liuxiaolong

2019-06-26 77e5c74f72c3d2e8470d19a3236ef38198e4cb66

 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")
      }
   }