关掉多协程调测

panlei

2019-12-13 2ed59d1db29aa1a58f0cca02346eb7ae722eab27

 ruleserver/readyDataForRule.go

@@ -6,7 +6,7 @@
   "encoding/json"
   "errors"
   "fmt"
   logger "github.com/alecthomas/log4go"
   "basic.com/valib/logger.git"
   "github.com/golang/protobuf/proto"
   "math"
   "nanomsg.org/go-mangos"
@@ -281,12 +281,12 @@
   //}
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
   if errSize != nil {
      _ = logger.Error("Failed set MaxRecvSize: %v", err)
      logger.Error("Failed set MaxRecvSize: %v", err)
      return nil
   }
   serverIP, _ := GetLocalIP()
   if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
      _ = logger.Error("请求socket拨号失败: %s", err.Error())
      logger.Error("请求socket拨号失败: %s", err.Error())
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
@@ -300,11 +300,11 @@
   logger.Debug("推送数据")
   //bytes := []byte("ndfasojdfaidsos")
   if err = sock.Send(bytes); err != nil {
      _ = logger.Error("推送socket发送数据失败: %s", err.Error())
      logger.Error("推送socket发送数据失败: %s", err.Error())
      //os.Exit(1)
   }
   if msg, err = sock.Recv(); err != nil {
      _ = logger.Error("接收响应失败: %s", err.Error())
      logger.Error("接收响应失败: %s", err.Error())
      //os.Exit(1)
   }
   logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg))
@@ -317,17 +317,17 @@
   var msg []byte

   if sock, err = req.NewSocket(); err != nil {
      _ = logger.Error("创建请求socket失败: %s", err.Error())
      logger.Error("创建请求socket失败: %s", err.Error())
   }
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
   if errSize != nil {
      _ = logger.Error("Failed set MaxRecvSize: %v", err)
      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())
      logger.Error("请求socket拨号失败: %s", err.Error())
   }
   logger.Info("序列化数据")

@@ -344,15 +344,15 @@
         }
         logger.Debug("推送数据")
         if err = sock.Send(bytes); err != nil {
            _ = logger.Error("推送socket发送数据失败: %s", err.Error())
            logger.Error("推送socket发送数据失败: %s", err.Error())
         }
         if msg, err = sock.Recv(); err != nil {
            _ = logger.Error("接收响应失败: %s", err.Error())
            logger.Error("接收响应失败: %s", err.Error())
         }
         logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg))
         receiver <- msg
      default:
         time.Sleep(time.Second)
         time.Sleep(time.Millisecond * 10)
      }
   }
}