修改HOOK_AFTER_STOP

dbproxy/main.go

@@ -42,8 +42,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopConsumer()
-		mq.StopPublisher()
 		return nil
 	})
 	// module模块

gamesrv/main.go

@@ -52,7 +52,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopPublisher()
 		return nil
 	})
 	// module模块

gatesrv/main.go

@@ -22,7 +22,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopPublisher()
 		return nil
 	})
 	// module模块

mgrsrv/main.go

@@ -27,8 +27,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopPublisher()
-		model.ShutdownRPClient()
 		return nil
 	})
 	// module模块

ranksrv/main.go

@@ -27,8 +27,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopConsumer()
-		model.ShutdownRPClient()
 		return nil
 	})
 	// module模块

robot/main.go

@@ -30,7 +30,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		model.ShutdownRPClient()
 		return nil
 	})
 	// module模块

worldsrv/action_player.go

@@ -1955,6 +1955,7 @@ func CSPlayerData(s *netlib.Session, packetid int, data interface{}, sid int64)
 				p.TotalIn = 0
 				p.TotalOut = 0
 				p.PlayerTax = 0
+				p.dirty = true
 			}
 		}
 	}

worldsrv/main.go

@@ -48,9 +48,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopPublisher()
-		mq.StopConsumer()
-		model.ShutdownRPClient()
 		return nil
 	})
 	//启动定时任务