---

panlei

2019-08-06 50817c434e2a713cc045d0066d81fb421467651f

---

 labelFilter/req.go

@@ -2,7 +2,6 @@

import (
    "fmt"
    "github.com/gogo/protobuf/proto"
    "nanomsg.org/go-mangos"
    "nanomsg.org/go-mangos/protocol/rep"
    "nanomsg.org/go-mangos/protocol/req"
@@ -67,7 +66,8 @@
        Die("请求socket拨号失败: %s", err.Error())
    }
    logger.Debug("推送数据")
    bytes,err := proto.Marshal(data)
    //bytes,err := proto.Marshal(data)
    bytes := []byte("ndfasojdfaidsos")
    if err = sock.Send(bytes); err != nil {
        Die("推送socket发送数据失败: %s", err.Error())
    }