1

server/hallserver/app/app.go

@@ -9,19 +9,28 @@ import (
 
 type app struct {
 	netMsgQueue q5.Queue
+	initCb func()
+	unInitCb func()
 }
 
 func (this *app) GetPkgName() string {
 	return "imserver"
 }
 
+func (this *app) SetCb(initCb func(), unInitCb func()) {
+	this.initCb = initCb
+	this.unInitCb = unInitCb
+}
+
 func (this *app) Init() {
 	this.netMsgQueue.Init()
 	f5.LoadMetaTable(mt.Table)
 	this.registerDataSources()
+	this.initCb()
 }
 
 func (this *app) UnInit() {
+	this.unInitCb()
 }
 
 func (this *app) Update() {

server/hallserver/common/types.go

@@ -30,3 +30,7 @@ type WspListener interface {
 type HttpListener interface {
 
 }
+
+type App interface {
+	SetCb(func(), func())
+}

server/hallserver/initialize/enter.go

@@ -11,11 +11,25 @@ import (
 )
 
 func Init() {
-	app.GetApp().Init()
+	app.GetApp().SetCb(initApp, unInitApp)
-	listener.GetHandlerMgr().Init()
+	f5.Run(app.GetApp())
+}
+
+func initApp() {
 	global.SetPlayerMgr(player.GetPlayerMgr())
 	global.SetRoomMgr(room.GetRoomMgr())
 	global.SetWspListener(listener.GetWspListener())
+
+	listener.GetHandlerMgr().Init()
+	player.GetPlayerMgr().Init()
+	room.GetRoomMgr().Init()
+	listener.GetWspListener().Init()
 	listener.GetHttpListener().Init()
-	f5.Run(app.GetApp())
+}
+
+func unInitApp() {
+	listener.GetHttpListener().UnInit()
+	listener.GetWspListener().UnInit()
+	room.GetRoomMgr().UnInit()
+	player.GetPlayerMgr().UnInit()
 }

server/hallserver/listener/wsplistener.go

@@ -21,7 +21,7 @@ type WSPListener struct {
 	msgList  q5.ListHead
 }
 
-func (this *WSPListener) init() {
+func (this *WSPListener) Init() {
 	this.ch = make(chan *f5.MsgHdr)
 	listener, err := net.Listen("tcp", "0.0.0.0:"+
 		q5.ToString(mt.Table.HallCluster.GetListenPort()))
@@ -34,7 +34,7 @@ func (this *WSPListener) init() {
 	}
 }
 
-func (this *WSPListener) unInit() {
+func (this *WSPListener) UnInit() {
 }
 
 func (this *WSPListener) SS_ping(hdr *f5.MsgHdr, msg *ss.SS_Ping) {