|
@@ -23,23 +23,22 @@ func main() {
|
|
|
flag.Parse()
|
|
|
var c config.Config
|
|
|
conf.MustLoad(*configFile, &c)
|
|
|
- closeNotify, err := node.NewNode(c.Etcd.Hosts...).Register(c.Etcd.Key, fmt.Sprint(c.Port))
|
|
|
- if err != nil {
|
|
|
- panic(err)
|
|
|
- }
|
|
|
// logx 根据配置初始化
|
|
|
logx.MustSetup(c.Logx)
|
|
|
//初始化mysql
|
|
|
InitMysql(c.Mysql.BaseService)
|
|
|
- //
|
|
|
ctx := svc.NewServiceContext(c)
|
|
|
server := rest.MustNewServer(c.RestConf)
|
|
|
defer server.Stop()
|
|
|
handler.RegisterHandlers(server, ctx)
|
|
|
-
|
|
|
fmt.Printf("Starting server at %s:%d...\n", c.Host, c.Port)
|
|
|
- server.Start()
|
|
|
-
|
|
|
+ closeNotify, err := node.NewNode(c.Etcd.Hosts...).Register(c.Etcd.Key, fmt.Sprint(c.Port))
|
|
|
+ if err != nil {
|
|
|
+ panic(err)
|
|
|
+ }
|
|
|
+ go func() {
|
|
|
+ server.Start()
|
|
|
+ }()
|
|
|
quit := make(chan os.Signal, 1)
|
|
|
signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
|
|
|
<-quit
|