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 2025-01-03 15:17:36 +08:00
parent 0e30ce57e7
commit 6350a86518
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/server/game/LogMgr.go
View File

@ -15,6 +15,7 @@ const (
) )
const ( const (
PLAYROOM_LOST = "playroom_lost" PLAYROOM_LOST = "playroom_lost"
LOG_LENGTH = 10000
) )
type LogMgr struct { type LogMgr struct {
@ -36,6 +37,14 @@ func (L *LogMgr) InitManager() {
L.McronSave.AddFunc("@every 10s", func() { L.McronSave.AddFunc("@every 10s", func() {
L.Lock.Lock() L.Lock.Lock()
defer L.Lock.Unlock() defer L.Lock.Unlock()
if kafkaMiddleware.KafkaMod == nil {
if len(L.L) > LOG_LENGTH {
L.L = L.L[:0]
} else if len(L.L) > LOG_LENGTH {
L.L = L.L[len(L.L)-LOG_LENGTH:]
}
return
}
for _, v := range L.L { for _, v := range L.L {
value, _ := json.Marshal(v) value, _ := json.Marshal(v)
kafkaMiddleware.SendMsg([]byte(v.EventName), value) kafkaMiddleware.SendMsg([]byte(v.EventName), value)