---

panlei

2019-08-16 6cd1a1f3e75cf8406fa293fd8a34386d5633a430

 main.go

@@ -6,7 +6,6 @@
   "basic.com/valib/deliver.git"
   "ruleprocess/insertdata"
   "ruleprocess/util"
   "runtime"
   "time"

   //"bufio"
@@ -74,8 +73,8 @@
            continue
         } else {
            //runtime.GOMAXPROCS(runtime.NumCPU())
            logger.Debug("使用的cpu个数：",runtime.NumCPU())
            go func(msg []byte) {
            //logger.Debug("使用的cpu个数：",runtime.NumCPU())
            //go func(msg []byte) {
               logger.Debug("当前时间戳：", time.Now().Unix())
               arg := ruleserver.SdkDatas{}
               //paramFormat(msg, &arg)
@@ -91,7 +90,7 @@
               logger.Debug("插入完Es所用时间：", time.Since(start))
               //事件推送
               //go labelFilter.Judge(resultMsg)
            }(msg)
            //}(msg)
         }
      }
   }