panlei
2019-08-22 eaab6d509a94dad4c4082d09602fa84028bec8a7
ruleserver/readyDataForRule.go
@@ -8,16 +8,15 @@
   "errors"
   "fmt"
   "github.com/go-yaml/yaml"
   "github.com/golang/protobuf/proto"
   "io/ioutil"
   "math"
   "nanomsg.org/go-mangos"
   "nanomsg.org/go-mangos/protocol/req"
   "nanomsg.org/go-mangos/transport/tcp"
   "net"
   "os"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "github.com/golang/protobuf/proto"
   "ruleprocess/structure"
   "strconv"
   "time"
@@ -337,11 +336,11 @@
   //bytes := []byte("ndfasojdfaidsos")
   if err = sock.Send(bytes); err != nil {
      logger.Error("推送socket发送数据失败: %s", err.Error())
      os.Exit(1)
      //os.Exit(1)
   }
   if msg, err = sock.Recv(); err != nil {
      logger.Error("接收响应失败: %s", err.Error())
      os.Exit(1)
      //os.Exit(1)
   }
   logger.Debug("数据推送成功!收到响应,数据长度为:",len(msg))
   return msg