main.go
@@ -88,9 +88,8 @@ fmt.Println("recv error : ", err) continue } else { //runtime.GOMAXPROCS(runtime.NumCPU()) //logger.Debug("使用的cpu个数:",runtime.NumCPU()) go func(msg []byte) { //go func(msg []byte) { logger.Debug("当前时间戳:", time.Now().Unix()) //log.Warn(time.Now().Format("2006-01-02 15:04:05")) arg := structure.SdkDatas{} @@ -110,7 +109,7 @@ logger.Debug("插入完Es所用时间:", esEnd) //事件推送 labelFilter.PushSomthing(resultMsg) }(msg) //}(msg) } } }