From 6be5f42ff0e8c9671dd0e99eb2988e8c7c305d91 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 10 九月 2019 17:06:35 +0800
Subject: [PATCH] dial fix
---
ruleserver/readyDataForRule.go | 28 +++++++++++++++-------------
1 files changed, 15 insertions(+), 13 deletions(-)
diff --git a/ruleserver/readyDataForRule.go b/ruleserver/readyDataForRule.go
index 66e22a0..cbf9a5a 100644
--- a/ruleserver/readyDataForRule.go
+++ b/ruleserver/readyDataForRule.go
@@ -55,6 +55,10 @@
if err != nil {
logger.Error("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
}
+ serverIP, _ := GetLocalIP()
+ if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
+ logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
+ }
}
type BaseInfo struct {
@@ -169,15 +173,15 @@
// 缁欑洰鏍囧～鍏卨iker
func (arg *Arg) fillLiker(tableId []string, compareThreshold float32) {
//bytes := bigCache.GetComparePersonBaseInfo(tableId, arg.Feature, compareThreshold)
- //comArg := &protomsg.CompareArgs{
- // TableIds:tableId,
- // FaceFeature:arg.Feature,
- // CompareThreshold:compareThreshold,
- // Source:false,
- //}
- //serverIp, _ := GetLocalIP()
- //bytes := Push("tcp://"+serverIp+":4010",comArg,sock)
- bytes := []byte{}
+ comArg := &protomsg.CompareArgs{
+ TableIds:tableId,
+ FaceFeature:arg.Feature,
+ CompareThreshold:compareThreshold,
+ Source:false,
+ }
+
+ bytes := Push(comArg,sock)
+ //bytes := []byte{}
var scResult protomsg.SdkCompareResult
err1 := proto.Unmarshal(bytes, &scResult)
if err1 != nil {
@@ -334,7 +338,7 @@
}
}
-func Push(url string,data *protomsg.CompareArgs,sock mangos.Socket) []byte{
+func Push(data *protomsg.CompareArgs,sock mangos.Socket) []byte{
//var sock mangos.Socket
var err error
var msg []byte
@@ -349,9 +353,7 @@
}
//sock.AddTransport(ipc.NewTransport())
sock.AddTransport(tcp.NewTransport())
- if err = sock.Dial(url); err != nil {
- logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
- }
+
logger.Info("搴忓垪鍖栨暟鎹�")
bytes,err1 := proto.Marshal(data)
logger.Info("鏁版嵁闀垮害涓猴細",len(bytes))
--
Gitblit v1.8.0