加个取联动数据的判断以防偶尔的nil导致宕机

panlei

2019-08-09 ed50fd820fa8299f328e85400a08db997e86b349

 main.go

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

   //"bufio"
@@ -73,9 +72,9 @@
            fmt.Println("recv error : ", err)
            continue
         } else {
            runtime.GOMAXPROCS(runtime.NumCPU())
            logger.Debug("使用的cpu个数：",runtime.NumCPU())
            go func(msg []byte) {
            //runtime.GOMAXPROCS(runtime.NumCPU())
            //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)
         }
      }
   }