diff --git a/src/server/game/message_mgr.go b/src/server/game/message_mgr.go index f2da29e9..2be9a055 100644 --- a/src/server/game/message_mgr.go +++ b/src/server/game/message_mgr.go @@ -185,9 +185,9 @@ func ClusterSyncHandler(data *msg.Msg) (interface{}, error) { defer messageMgrData.mu.Unlock() TempMessageList := messageMgrData.MessageList messageMgrData.MessageList = make(map[int64]*MessageList) - for PlayerId, Message := range TempMessageList { + for _, Message := range TempMessageList { for _, msgItem := range Message.Messages { - go SendMsgToNodeAsync(msgItem, messageMgrData.PlayerList[PlayerId]) + SendMsgToCenterAsync(msgItem) } } return nil, nil @@ -263,9 +263,7 @@ func CenterPlayerMsgHandler(data *msg.Msg) (interface{}, error) { defer messages.mu.Unlock() messages.Messages = append(messages.Messages, data) if node, ok := messageMgrData.PlayerList[int64(PlayerId)]; ok { - for _, message := range messages.Messages { - go SendMsgToNodeAsync(message, node) - } + go SendMsgToNodeAsync(data, node) } return nil, nil }