---

panlei

2019-08-06 9f83b0101d093be6064c7b78f0a25530f561ac8e

 labelFilter/req.go

@@ -8,6 +8,7 @@
   "nanomsg.org/go-mangos/transport/ipc"
   "nanomsg.org/go-mangos/transport/tcp"
   "os"
   "github.com/golang/protobuf/proto"
   "ruleprocess/logger"
   "ruleprocess/ruleserver"
   "time"
@@ -65,9 +66,10 @@
   if err = sock.Dial(url); err != nil {
      Die("请求socket拨号失败: %s", err.Error())
   }
   logger.Info("序列化数据")
   bytes,err := proto.Marshal(data)
   logger.Debug("推送数据")
   //bytes,err := proto.Marshal(data)
   bytes := []byte("ndfasojdfaidsos")
   //bytes := []byte("ndfasojdfaidsos")
   if err = sock.Send(bytes); err != nil {
      Die("推送socket发送数据失败: %s", err.Error())
   }