package main import ( "flag" "os" "time" "go-common/app/admin/main/push/conf" "go-common/app/admin/main/push/http" "go-common/app/admin/main/push/service" ecode "go-common/library/ecode/tip" "go-common/library/log" "go-common/library/net/trace" "go-common/library/os/signal" "go-common/library/syscall" ) var ( s *service.Service ) func main() { flag.Parse() if err := conf.Init(); err != nil { panic(err) } log.Init(conf.Conf.Log) defer log.Close() trace.Init(conf.Conf.Tracer) defer trace.Close() ecode.Init(conf.Conf.Ecode) s = service.New(conf.Conf) http.Init(conf.Conf, s) log.Info("push-admin start") signalHandler() } func signalHandler() { ch := make(chan os.Signal, 1) signal.Notify(ch, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT) for { si := <-ch switch si { case syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGSTOP, syscall.SIGINT: time.Sleep(time.Second * 2) log.Info("get a signal %s, stop the push-admin process", si.String()) s.Close() s.Wait() time.Sleep(time.Second) return case syscall.SIGHUP: default: return } } }