性能监测

panlei

2019-09-10 9fdfb9d45ca1b0f58737f754f2321d10acaf2da2

 ruleserver/readyDataForRule.go

@@ -51,7 +51,7 @@
   }
   logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort)
   bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
   Push1()
   go Push1()
}

var sender chan *protomsg.CompareArgs = make(chan *protomsg.CompareArgs)
@@ -386,13 +386,12 @@
   if errSize != nil {
      logger.Error("Failed set MaxRecvSize: %v", err)
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
   serverIP, _ := GetLocalIP()
   if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
      logger.Error("请求socket拨号失败: %s", err.Error())
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())

   logger.Info("序列化数据")

   for {