先切回调库方式

panlei

2019-08-08 1e635ccac541cdcffe34d7e09e4672c65378470e

 ruleserver/readyDataForRule.go

@@ -50,10 +50,10 @@
   }
   logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort)
   bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
   sock, err = req.NewSocket();
   if err != nil {
      logger.Error("创建请求socket失败: %s", err.Error())
   }
   //sock, err = req.NewSocket();
   //if err != nil {
   //   logger.Error("创建请求socket失败: %s", err.Error())
   //}
}

type BaseInfo struct {
@@ -167,13 +167,13 @@

// 给目标填充liker
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,
   }
   bytes := Push("tcp://192.168.1.182:40010",comArg,sock)
   bytes := bigCache.GetComparePersonBaseInfo(tableId, arg.Feature, compareThreshold)
   //comArg := &protomsg.CompareArgs{
   //   TableIds:tableId,
   //   FaceFeature:arg.Feature,
   //   CompareThreshold:compareThreshold,
   //}
   //bytes := Push("tcp://192.168.1.182:40010",comArg,sock)
   var m map[string]float32
   err1 := json.Unmarshal(bytes, &m)
   if err1 != nil {