package service
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"basic.com/valib/deliver.git"
|
"encoding/json"
|
"fmt"
|
"github.com/gogo/protobuf/proto"
|
)
|
|
const (
|
Url_Service_PUSH = "tcp:///tmp///webserver-2.ipc"
|
Url_Service_PULL = "tcp:///tmp///webserver-1.ipc"
|
)
|
var imgPushChan chan protomsg.Recvmsg
|
|
func PushImgMsg(is protomsg.Recvmsg){
|
imgPushChan <- is
|
}
|
|
var resultMap map[string]protomsg.SdkMessage
|
|
|
func InitService(){
|
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:
|
b, _ := json.Marshal(is)
|
client_push.Send(b)
|
}
|
}
|
|
//接收人脸提取结果
|
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(rMsg)
|
resultMap[rMsg.Cid] = rMsg
|
}
|
|
}
|
|
}
|
