---

panlei

2019-11-01 5411f87f32c95adea29ca0b3763d8dd3857b96f0

 labelFilter/req.go

@@ -4,7 +4,6 @@
   "basic.com/dbapi.git"
   "basic.com/valib/logger.git"
   "fmt"
   "github.com/golang/protobuf/proto"
   "nanomsg.org/go-mangos"
   "nanomsg.org/go-mangos/protocol/rep"
   "nanomsg.org/go-mangos/protocol/req"
@@ -115,12 +114,12 @@
      // case <-ctx.Done():
      //    return
      case data := <- urlPool[url]:

         bytes,err1 := proto.Marshal(data)
         logger.Info("数据长度为：",len(bytes))
         if err1 != nil {
            logger.Info("序列化失败：",err1)
         }
         logger.Info("接收到数据",data.Cid)
         //bytes,err1 := proto.Marshal(data)
         //logger.Info("数据长度为：",len(bytes))
         //if err1 != nil {
         //   logger.Info("序列化失败：",err1)
         //}
         //logger.Debug("groutine"+url+"推送数据")
         ////bytes := []byte("ndfasojdfaidsos")
         //if err = sock.Send(bytes); err != nil {