---

panlei

2019-11-01 b4add78c5c4f581f8c005c8b4ccf090e03424be1

 labelFilter/req.go

@@ -110,33 +110,37 @@
   }
   logger.Info("序列化数据")

   for {
      select {
      // case <-ctx.Done():
      //    return
      case data := <- urlPool[url]:
         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 {
         //   Die("groutine"+url+"推送socket发送数据失败: ", err.Error())
         //}
         //msg, err = sock.Recv();
         //if err != nil {
         //   Die("groutine"+url+"接收响应失败: ", err.Error())
         //} else {
         //   logger.Debug("事件推送成功！groutine"+url+"收到响应",string(msg))
         //}

      default:

   for v := range urlPool[url]{
      logger.Info(v)
      }
   }

   //for {
   //   select {
   //   // case <-ctx.Done():
   //   //    return
   //   case data := <- urlPool[url]:
   //      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 {
   //      //   Die("groutine"+url+"推送socket发送数据失败: ", err.Error())
   //      //}
   //      //msg, err = sock.Recv();
   //      //if err != nil {
   //      //   Die("groutine"+url+"接收响应失败: ", err.Error())
   //      //} else {
   //      //   logger.Debug("事件推送成功！groutine"+url+"收到响应",string(msg))
   //      //}
   //
   //   default:
   //
   //   }
   //}
   sock.Close()
}
//func main() {