---

panlei

2019-12-13 6fd9af45e0cd30838b221f759ba59adc50653093

 algorithm/personTrack/personTrack.go

@@ -143,21 +143,21 @@
func Push(){
   var err error
   var msg []byte

   logger.Info("追踪请求通道建立")
   if sock, err = req.NewSocket(); err != nil {
      logger.Error("创建请求socket失败: %s", err.Error())
   }
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,20*1024*1024)
   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 {
   if err = sock.Dial("tcp://"+serverIP+":4011"); err != nil {
      logger.Error("请求socket拨号失败: %s", err.Error())
   }
   logger.Info("序列化数据")
   //logger.Info("序列化数据")
   initFlag = true
   for {
      select {