main.go 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. package main
  2. import (
  3. "flag"
  4. "os"
  5. "time"
  6. "go-common/app/admin/main/apm/conf"
  7. "go-common/app/admin/main/apm/http"
  8. "go-common/app/admin/main/apm/service"
  9. ecode "go-common/library/ecode/tip"
  10. "go-common/library/log"
  11. "go-common/library/os/signal"
  12. "go-common/library/queue/databus/report"
  13. "go-common/library/syscall"
  14. )
  15. var (
  16. s *service.Service
  17. )
  18. func main() {
  19. flag.Parse()
  20. if err := conf.Init(); err != nil {
  21. log.Error("conf.Init() error(%v)", err)
  22. panic(err)
  23. }
  24. ecode.Init(conf.Conf.Ecode)
  25. log.Init(conf.Conf.Log)
  26. defer log.Close()
  27. report.InitManager(conf.Conf.ManagerReport)
  28. // service init
  29. s = service.New(conf.Conf)
  30. http.Init(conf.Conf, s)
  31. log.Info("apm-admin start")
  32. signalHandler()
  33. }
  34. func signalHandler() {
  35. var (
  36. ch = make(chan os.Signal, 1)
  37. )
  38. signal.Notify(ch, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT)
  39. for {
  40. si := <-ch
  41. log.Info("get a signal %s, stop the apm-admin process", si.String())
  42. switch si {
  43. case syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT:
  44. s.Close()
  45. time.Sleep(time.Second)
  46. return
  47. case syscall.SIGHUP:
  48. default:
  49. return
  50. }
  51. }
  52. }