fix bug

liuxiaolong

2019-06-26 6ec6ad3a594049599b912c8e9acc7ec996ad0cdb

fix bug

 service/FaceSdkService.go

@@ -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
            }

    }
        }
    }()

}