send数据用协程

panlei

2019-11-04 516d94938f664e71dd323426221b535d5e92881b

 labelFilter/req.go

@@ -135,6 +135,7 @@
      case data := <- urlPool[url]:
         //logger.Info("接收到数据",data.Cid)
         //bytes,err1 := proto.Marshal(data)
         go func(data []byte) {
         logger.Info("数据长度为：",len(data))
         //if err1 != nil {
         //   logger.Info("序列化失败：",err1)
@@ -152,7 +153,7 @@
         } else {
            logger.Debug("事件推送成功！groutine"+url+"收到响应",string(msg),pushTime,time.Since(start))
         }

         }(data)
      default:

      }