fix bug

liuxiaolong

2019-06-26 2e2f869cc7c24b0e2cf2d1f6f60bc01fde327210

 service/FaceSdkService.go

@@ -12,8 +12,8 @@
)

const (
   Url_Service_PUSH = "tcp:///tmp///webserver-2.ipc"
   Url_Service_PULL = "tcp:///tmp///webserver-1.ipc"
   Url_Service_PUSH = "tcp:///tmp///webserver_2.ipc"
   Url_Service_PULL = "tcp:///tmp///webserver_1.ipc"
)
var imgPushChan chan protomsg.Recvmsg

@@ -53,30 +53,35 @@
   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 {

   go func() {
      for {
         select {
         case is := <- imgPushChan:
            fmt.Println("imgPushChan in")
            b, _ := json.Marshal(is)
            client_push.Send(b)
      default:
         fmt.Println("no img in")
         default:
            //fmt.Println("no img in")
         }
      }
   }
   }()

   //接收人脸提取结果
   for {
      resultBytes, err := client_pull.Recv()
      if err !=nil{
         fmt.Println("pull err:",err)
         continue
      }
      rMsg := protomsg.SdkMessage{}
      if err := proto.Unmarshal(resultBytes, &rMsg);err !=nil{
         fmt.Println("recv MSG:",rMsg)
         resultMap[rMsg.Cid] = rMsg
      }
   go func() {
      //接收人脸提取结果
      for {
         resultBytes, err := client_pull.Recv()
         if err !=nil{
            fmt.Println("pull err:",err)
            continue
         }
         rMsg := protomsg.SdkMessage{}
         if err := proto.Unmarshal(resultBytes, &rMsg);err !=nil{
            fmt.Println("recv MSG:",rMsg)
            resultMap[rMsg.Cid] = rMsg
         }

   }
      }
   }()

}