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-12-30 11:48:50 +08:00
parent 07935149a7
commit 2ca9f004bd
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -588,15 +588,15 @@ func LoggingMiddleware() MessageMiddleware {
return func(next MessageHandlerFunc) MessageHandlerFunc {
return func(message *msg.Msg) (interface{}, error) {
start := time.Now()
log.Debug("[Middleware] Processing message type: %d, time: %v", message.Type, start)
log.Debug("[Middleware] Processing message : %v, time: %v", message, start)
result, err := next(message)
duration := time.Since(start)
if err != nil {
log.Error("[Middleware] Message type: %d failed, duration: %v, error: %v", message.Type, duration, err)
log.Error("[Middleware] Message : %v failed, duration: %v, error: %v", message, duration, err)
} else {
log.Debug("[Middleware] Message type: %d success, duration: %v", message.Type, duration)
log.Debug("[Middleware] Message : %v success, duration: %v", message, duration)
}
return result, err
@ -634,7 +634,7 @@ func TimeoutMiddleware(timeout time.Duration) MessageMiddleware {
case result := <-resultChan:
return result.Data, result.Error
case <-time.After(timeout):
log.Error("[Middleware] Message type: %d timeout after %v", message.Type, timeout)
log.Error("[Middleware] Message : %v timeout after %v", message, timeout)
return nil, fmt.Errorf("message handler timeout")
}
}
@ -655,7 +655,7 @@ func RetryMiddleware(maxRetries int) MessageMiddleware {
}
if i < maxRetries {
log.Debug("[Middleware] Retry %d/%d for message type: %d, error: %v", i+1, maxRetries, message.Type, err)
log.Debug("[Middleware] Retry %d/%d for message : %v, error: %v", i+1, maxRetries, message, err)
time.Sleep(time.Millisecond * 100 * time.Duration(i+1))
}
}