---

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