From 4cf882ecd26272ad689f4388663d01d083eea315 Mon Sep 17 00:00:00 2001 From: hahwu <31872165+hahwu@users.noreply.github.com> Date: Tue, 30 Dec 2025 12:17:41 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=97=A5=E5=BF=97=E4=BC=98?= =?UTF-8?q?=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/server/game/message_mgr.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/server/game/message_mgr.go b/src/server/game/message_mgr.go index c0752752..82aacc66 100644 --- a/src/server/game/message_mgr.go +++ b/src/server/game/message_mgr.go @@ -201,28 +201,28 @@ func ClusterSyncHandler(data *msg.Msg) (interface{}, error) { func PlayerLoginHandler(data *msg.Msg) (interface{}, error) { // 关闭 Worker Pool messageMgrData := getMessageData() + messageMgrData.mu.Lock() - messageMgrData.PlayerList[int64(data.From)] = data.Extra.(int) + node := data.Extra.(int) + messageMgrData.PlayerList[int64(data.From)] = node if _, ok := messageMgrData.MessageList[int64(data.From)]; !ok { messageMgrData.MessageList[int64(data.From)] = &MessageList{ Messages: []*msg.Msg{}, } } messageMgrData.mu.Unlock() - log.Debug("[Middleware] Player login success player id: %v, node: %v", data.From, data.Extra.(int)) - node := data.Extra.(int) - messageMgrData.PlayerList[int64(data.From)] = node // 对玩家消息列表加锁 messages := messageMgrData.MessageList[int64(data.From)] messages.mu.Lock() defer messages.mu.Lock() // 发送离线消息 - log.Debug("[Middleware] Player sync logout message player id: %v, len: %d", data.From, len(messages.Messages)) + len := len(messages.Messages) for _, message := range messages.Messages { go sendMessageAsync(message, node) } + log.Debug("[Middleware] Player sync logout message player id: %v, len: %d", data.From, len) return nil, nil }