---

panlei

2019-11-01 0b252e824bda2655741abeaa7f6868c2b603986e

 labelFilter/req.go

@@ -68,8 +68,9 @@
         for _, url := range ruleGroup.Urls {
            // 为每个url建立一个chan
            if strings.Contains(url.Url,"114") {
               urlPool[url.Url] = make(chan structure.ResultMsg)
               urlPool[url.Url] = make(chan structure.ResultMsg,10)
               go GoPush(url.Url)
               return
            }
         }
      }
@@ -109,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() {