main.go
@@ -7,6 +7,7 @@ "net/http" _ "net/http/pprof" "ruleprocess/insertdata" "ruleprocess/labelFilter" "ruleprocess/util" "time" @@ -40,7 +41,7 @@ func main() { //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 go func() { http.ListenAndServe("0:0:0:0:8069",nil) http.ListenAndServe("0.0.0.0:8899",nil) }() flag.Parse() wg := sync.WaitGroup{} @@ -94,7 +95,7 @@ insertdata.InsertToEs(resultMsg) logger.Debug("插入完Es所用时间:", time.Since(start)) //事件推送 //go labelFilter.Judge(resultMsg) go labelFilter.Judge(resultMsg) //}(msg) } }