---

panlei

2019-08-09 302d2934b0950ac6cc509ca099fa9d9cc2e5b17b

---

 main.go

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

    //"bufio"
@@ -73,10 +72,10 @@
                fmt.Println("recv error : ", err)
                continue
            } else {
                runtime.GOMAXPROCS(runtime.NumCPU())
                logger.Debug("使用的cpu个数：",runtime.NumCPU())
                go func(msg []byte) {
                    logger.Debug("当前时间戳：", time.Now().Unix())
                //runtime.GOMAXPROCS(runtime.NumCPU())
                //logger.Debug("使用的cpu个数：",runtime.NumCPU())
                //go func(msg []byte) {
                    //logger.Debug("当前时间戳：", time.Now().Unix())
                    arg := ruleserver.SdkDatas{}
                    //paramFormat(msg, &arg)
                    start := time.Now()
@@ -91,7 +90,7 @@
                    logger.Debug("插入完Es所用时间：", time.Since(start))
                    //事件推送
                    //go labelFilter.Judge(resultMsg)
                }(msg)
                //}(msg)
            }
        }
    }

 ruleserver/timeTicker.go

@@ -32,8 +32,8 @@
}

func TimeTicker() {
    logger.Info("定时器执行了")
    fmt.Println("定时器执行了")
    //logger.Info("定时器执行了")
    //fmt.Println("定时器执行了")
    ticker := time.NewTicker(1 * time.Second)
    go func(ticker *time.Ticker) {
        defer ticker.Stop()