From ba842438f497fb4985444de2173ca4e55dea3d64 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 29 八月 2019 20:27:06 +0800
Subject: [PATCH] add detect rpc client
---
service/FDetectClient.go | 35 +++++++++++++++++++++++++++++++++++
1 files changed, 35 insertions(+), 0 deletions(-)
diff --git a/service/FDetectClient.go b/service/FDetectClient.go
new file mode 100644
index 0000000..70833cb
--- /dev/null
+++ b/service/FDetectClient.go
@@ -0,0 +1,35 @@
+package service
+
+import (
+ "basic.com/pubsub/protomsg.git"
+ "context"
+ "errors"
+ "time"
+ "webserver/extend/logger"
+
+ "google.golang.org/grpc"
+)
+
+const (
+ address = "localhost:4009"
+)
+func DoFDetectWithRpc(fdr *protomsg.FaceDetectRequest,t time.Duration) ([]*protomsg.ResultFaceDetect,error) {
+ conn,err := grpc.Dial(address, grpc.WithInsecure())
+ if err !=nil {
+ logger.Debug("grpc dial err:",err)
+ }
+ defer conn.Close()
+ c := protomsg.NewFaceDetectClient(conn)
+
+ ctx,cancel := context.WithTimeout(context.Background(), t)
+ defer cancel()
+ faces,err := c.FaceDetect(ctx,fdr)
+ if err !=nil {
+ logger.Debug("rpc call err:",err)
+ return nil,err
+ }
+ if faces !=nil {
+ return faces.Faces,nil
+ }
+ return nil,errors.New("no face detected")
+}
--
Gitblit v1.8.0