main.go
@@ -87,7 +87,7 @@ } else { //runtime.GOMAXPROCS(runtime.NumCPU()) //logger.Debug("使用的cpu个数:",runtime.NumCPU()) go func(msg []byte) { //go func(msg []byte) { logger.Debug("当前时间戳:", time.Now().Unix()) arg := structure.SdkDatas{} //paramFormat(msg, &arg) @@ -105,8 +105,8 @@ esEnd := time.Since(start) logger.Debug("插入完Es所用时间:", esEnd) //事件推送 //labelFilter.PushSomthing(resultMsg) }(msg) labelFilter.PushSomthing(resultMsg) //}(msg) } } }