From cf11a71f034248129ad62923459f30e193b07ac3 Mon Sep 17 00:00:00 2001 From: hahwu <31872165+hahwu@users.noreply.github.com> Date: Tue, 30 Dec 2025 12:08:29 +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 | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/src/server/game/message_mgr.go b/src/server/game/message_mgr.go index f6d431dc..c0752752 100644 --- a/src/server/game/message_mgr.go +++ b/src/server/game/message_mgr.go @@ -210,17 +210,16 @@ func PlayerLoginHandler(data *msg.Msg) (interface{}, error) { } messageMgrData.mu.Unlock() - // 对玩家消息列表加锁 - messageMgrData.MessageList[int64(data.From)].mu.Lock() - defer messageMgrData.MessageList[int64(data.From)].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.Unlock() + defer messages.mu.Lock() + // 发送离线消息 + log.Debug("[Middleware] Player sync logout message player id: %v, len: %d", data.From, len(messages.Messages)) for _, message := range messages.Messages { go sendMessageAsync(message, node) }