取消推送，看看占内存发生在何处

panlei

2019-10-30 33a8935a188127f7624b4c17c6d40c7a500c170f

取消推送，看看占内存发生在何处

 labelFilter/ruleForLabel.go

@@ -319,7 +319,7 @@
func pushData(urls []*protomsg.PushUrl, data structure.ResultMsg) {
    for _, url := range urls {
        logger.Debug("看看推送地址：",url.Url)
        Push("tcp://"+url.Url, data)
        //Push("tcp://"+url.Url, data)
    }
}


 main.go

@@ -7,6 +7,7 @@
    "net/http"
    _ "net/http/pprof"
    "ruleprocess/insertdata"
    "ruleprocess/labelFilter"
    "ruleprocess/structure"
    "ruleprocess/util"
    "time"
@@ -106,7 +107,7 @@
                    insertdata.InsertToEs(resultMsg)
                    logger.Debug("插入完Es所用时间：", time.Since(start))
                    //事件推送
                    //go labelFilter.Judge(resultMsg)
                    go labelFilter.Judge(resultMsg)
                //}(msg)
            }
        }