pet_home/pet_home_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

中心服优化

Browse Source
This commit is contained in:
hahwu 2026-03-06 18:41:28 +08:00
parent df883aeea7
commit e1022d475e
1 changed files with 26 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
src/server/game/message_mgr.go
View File

@ -103,32 +103,32 @@ func (m *MessageMgr) MessageMgrInit() {
}
func FixBug() {
messageMgrData := getMessageData()
// 先更新 PlayerList（需要加锁）
messageMgrData.mu.Lock()
defer messageMgrData.mu.Unlock()
now := GoUtil.Now()
for k, v := range messageMgrData.MessageList {
if k < 100000 {
delete(messageMgrData.MessageList, k)
continue
}
isLose := CheckPlayerLose(int(k))
// 反向遍历以安全删除元素
for i := len(v.Messages) - 1; i >= 0; i-- {
if v.Messages[i].Type == msg.HANDLE_TYPE_CHAMPSHIP_NOTIFY || (v.Messages[i].End != 0 && v.Messages[i].End < now) {
// 删除消息
v.Messages = append(v.Messages[:i], v.Messages[i+1:]...)
}
if isLose && v.Messages[i].Type == msg.HANDLE_TYPE_CHAMPSHIP_RESULT {
// 删除消息
v.Messages = append(v.Messages[:i], v.Messages[i+1:]...)
}
}
if len(v.Messages) == 0 {
delete(messageMgrData.MessageList, k)
}
}
// messageMgrData := getMessageData()
// // 先更新 PlayerList（需要加锁）
// messageMgrData.mu.Lock()
// defer messageMgrData.mu.Unlock()
// now := GoUtil.Now()
// for k, v := range messageMgrData.MessageList {
// if k < 100000 {
// delete(messageMgrData.MessageList, k)
// continue
// }
// isLose := CheckPlayerLose(int(k))
// // 反向遍历以安全删除元素
// for i := len(v.Messages) - 1; i >= 0; i-- {
// if v.Messages[i].Type == msg.HANDLE_TYPE_CHAMPSHIP_NOTIFY || (v.Messages[i].End != 0 && v.Messages[i].End < now) {
// // 删除消息
// v.Messages = append(v.Messages[:i], v.Messages[i+1:]...)
// }
// if isLose && v.Messages[i].Type == msg.HANDLE_TYPE_CHAMPSHIP_RESULT {
// // 删除消息
// v.Messages = append(v.Messages[:i], v.Messages[i+1:]...)
// }
// }
// if len(v.Messages) == 0 {
// delete(messageMgrData.MessageList, k)
// }
// }
}
// 注册处理器