dbproxy/main.go

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

gamesrv/main.go

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

gatesrv/main.go

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

mgrsrv/main.go

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

ranksrv/main.go

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

worldsrv/action_player.go

@@ -1956,7 +1956,6 @@ 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

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

worldsrv/player.go

@@ -654,7 +654,6 @@ func (this *Player) LoadMessage(lastLogoutTime int64, isFirstLogin, isSkipWeek b
 					}
 					this.verifyMessage(maxTs)
 				}
-				this.MessageShowRed()
 			}
 		}), "GetMessage").StartByFixExecutor("logic_message")
 }