消息日志优化

This commit is contained in:
hahwu 2025-12-30 12:17:41 +08:00
parent cf11a71f03
commit 4cf882ecd2

View File

@ -201,28 +201,28 @@ func ClusterSyncHandler(data *msg.Msg) (interface{}, error) {
func PlayerLoginHandler(data *msg.Msg) (interface{}, error) { func PlayerLoginHandler(data *msg.Msg) (interface{}, error) {
// 关闭 Worker Pool // 关闭 Worker Pool
messageMgrData := getMessageData() messageMgrData := getMessageData()
messageMgrData.mu.Lock() 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 { if _, ok := messageMgrData.MessageList[int64(data.From)]; !ok {
messageMgrData.MessageList[int64(data.From)] = &MessageList{ messageMgrData.MessageList[int64(data.From)] = &MessageList{
Messages: []*msg.Msg{}, Messages: []*msg.Msg{},
} }
} }
messageMgrData.mu.Unlock() messageMgrData.mu.Unlock()
log.Debug("[Middleware] Player login success player id: %v, node: %v", data.From, data.Extra.(int)) 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 := messageMgrData.MessageList[int64(data.From)]
messages.mu.Lock() messages.mu.Lock()
defer 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 { for _, message := range messages.Messages {
go sendMessageAsync(message, node) go sendMessageAsync(message, node)
} }
log.Debug("[Middleware] Player sync logout message player id: %v, len: %d", data.From, len)
return nil, nil return nil, nil
} }