main.go
@@ -29,7 +29,7 @@ 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","dev","env set") var env = flag.String("env","pro","env set") func init() { flag.Parse() @@ -93,8 +93,8 @@ //_ = p.Submit(syncCalculateSum) Task(msg) } else { fmt.Println(err) logger.Info(err) //fmt.Println(err) //logger.Info(err) } } }