读公共的配置文件

panlei

2019-09-16 716810adb573f7e6b40ab52887b5b158d9824817

 main.go

@@ -7,7 +7,6 @@
   "net/http"
   _ "net/http/pprof"
   "ruleprocess/insertdata"
   "ruleprocess/labelFilter"
   "ruleprocess/util"
   "time"

@@ -31,12 +30,14 @@
var surveyPort = flag.Int("surveyPort", 40007, "survey port") //心跳
var pubPort = flag.Int("pubPort", 50007, "pubsub port")       //数据更新
var initchan = make(chan bool)
var env =  flag.String("env","pro","env set")

func init() {
   flag.Parse()
   // 日志初始化
   logger.Config("./info.log", logger.DebugLevel)
   logger.Info("日志初始化成功！")

   insertdata.Init(*env)
}
func main() {
   //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕
@@ -95,7 +96,7 @@
               insertdata.InsertToEs(resultMsg)
               logger.Debug("插入完Es所用时间：", time.Since(start))
               //事件推送
               go labelFilter.Judge(resultMsg)
               //go labelFilter.Judge(resultMsg)
            //}(msg)
         }
      }