---

panlei

2019-07-05 bc2b97eafce90ba3356d34fe06302ac01b74cb30

---

 main.go

@@ -42,7 +42,7 @@
    dbapi.Init(*dbIp,*dbPort)
    go cache.Init(initchan,*dbIp,*surveyPort,*pubPort)
    logger.Info("cache init completed!!!",<- initchan)//dbserver初始化完毕
    fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕
    //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕

    go ruleserver.TimeTicker()
    nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)

 ruleserver/timeTicker.go

@@ -1,7 +1,6 @@
package ruleserver

import (
    "fmt"
    "ruleprocess/logger"
    "time"
)
@@ -28,7 +27,7 @@

func TimeTicker() {
    logger.Info("定时器执行了")
    fmt.Println("定时器执行了")
    //fmt.Println("定时器执行了")
    ticker := time.NewTicker(1 * time.Second)
    go func(ticker *time.Ticker) {
        defer ticker.Stop()
@@ -36,7 +35,7 @@
            select {
            case <-ticker.C:
                logger.Info("定时器执行单元")
                fmt.Println("定时器执行单元")
                //fmt.Println("定时器执行单元")
                // 每秒钟计数器池子里所有的计数器元素都减一，减到0的是该报警的
                for _, timeEle := range TimeEleList {
                    if timeEle.N > 0 {