---

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())
    }