diff --git a/main.go b/main.go index 057e4b8..9cae25b 100644 --- a/main.go +++ b/main.go @@ -1,6 +1,7 @@ package main import ( + "LAPP_ETL/common" dal "LAPP_ETL/dao/etl" "LAPP_ETL/global" "LAPP_ETL/grmi" @@ -17,6 +18,9 @@ import ( "github.com/kardianos/service" "github.com/kataras/iris/v12" "log" + "net/http" + + _ "net/http/pprof" "os" "time" ) @@ -30,9 +34,11 @@ func (p *program) Start(s service.Service) error { go p.run() return nil } + func (p *program) run() { appMain() } + func (p *program) Stop(s service.Service) error { return nil } @@ -77,7 +83,10 @@ func main() { } func appMain() { - + //监控 + go func() { + http.ListenAndServe("0.0.0.0:8899", nil) + }() // init app global config err := config.InitConfig() if err != nil { @@ -117,7 +126,8 @@ func appMain() { if err != nil { log.Fatal("init db engine failed, error:", err) } - + common.CheckServiceDao = dal.NewETCDServiceDAO(db.AppEtcdClient, config.AppConfig.App.LocalAddr) + defer common.CheckServiceDao.RevokeLease() // start scheduler err = scheduler.Start() if err != nil {