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-01-21 16:15:53 +08:00
parent edceb1cf1e
commit f81facf4cd
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/server/game/external.go
View File

@ -52,6 +52,7 @@ func HandleAdminReq(args []interface{}) {
} }
func HandleClientReq(args []interface{}) { func HandleClientReq(args []interface{}) {
start := time.Now()
if G_GameLogicPtr.SeverInfo.Status == SERVER_STATUS_CLOSE || G_GameLogicPtr.SeverInfo.Status == SERVER_STATUS_MAINTAIN { if G_GameLogicPtr.SeverInfo.Status == SERVER_STATUS_CLOSE || G_GameLogicPtr.SeverInfo.Status == SERVER_STATUS_MAINTAIN {
return // 服务器关闭或者维护中，不处理任何消息 return // 服务器关闭或者维护中，不处理任何消息
} }
@ -146,8 +147,7 @@ func HandleClientReq(args []interface{}) {
ResRegisterAccount.ResultCode = 0 ResRegisterAccount.ResultCode = 0
data, _ := proto.Marshal(ResRegisterAccount) data, _ := proto.Marshal(ResRegisterAccount)
gl.PackResInfo(a, "ResRegisterAccount", data) gl.PackResInfo(a, "ResRegisterAccount", data)
case "ReqLogin": case "ReqLogin": // 登录请求
now := time.Now().UnixMilli()
detail := &msg.ReqLogin{} detail := &msg.ReqLogin{}
proto.Unmarshal(buf, detail) proto.Unmarshal(buf, detail)
accountInfo := db.GetAccountInfoFromDb(detail.UserName) accountInfo := db.GetAccountInfoFromDb(detail.UserName)
@ -187,8 +187,9 @@ func HandleClientReq(args []interface{}) {
p.(*Player).LoginBackData() p.(*Player).LoginBackData()
p.(*Player).TeLog("Login_log", nil) p.(*Player).TeLog("Login_log", nil)
} }
execTime := time.Now().UnixMilli() - now if newPlayer {
log.Debug("uid : %d, func : %s, execTime : %d ms, isNew: %v", p.(*Player).M_DwUin, m.GetFunc(), execTime, newPlayer) log.Debug("uid : %d, init user process : %s, execTime : %v , isNew: %v", p.(*Player).M_DwUin, m.GetFunc(), time.Since(start), newPlayer)
}
p.(*Player).ProcessTrigger() p.(*Player).ProcessTrigger()
case "ReqServerTime": // 获取服务器时间 case "ReqServerTime": // 获取服务器时间
detail := &msg.ReqServerTime{} detail := &msg.ReqServerTime{}
@ -202,7 +203,6 @@ func HandleClientReq(args []interface{}) {
default: default:
p, ok := internal.Agents.Load(a) p, ok := internal.Agents.Load(a)
if ok && p != G_GameLogicPtr.NotInitPlayer { if ok && p != G_GameLogicPtr.NotInitPlayer {
now := time.Now().UnixMilli()
p.(*Player).lock.Lock() //加锁 p.(*Player).lock.Lock() //加锁
backup := p.(*Player).BackUp() // 备份当前的 Player 值 backup := p.(*Player).BackUp() // 备份当前的 Player 值
defer func() { defer func() {
@ -223,11 +223,9 @@ func HandleClientReq(args []interface{}) {
return return
} }
p.(*Player).ProcessTrigger() p.(*Player).ProcessTrigger()
execTime := time.Now().UnixMilli() - now p.(*Player).TeLog("func_exec_time", map[string]interface{}{
log.Debug("uid : %d, func : %s, execTime : %d ms", p.(*Player).M_DwUin, m.GetFunc(), execTime)
p.(*Player).TeLog("Long_Method_Log", map[string]interface{}{
"method_name": m.GetFunc(), "method_name": m.GetFunc(),
"exec_time": execTime, "exec_time": time.Since(start),
}) })
} }
} }
@ -235,5 +233,5 @@ func HandleClientReq(args []interface{}) {
if b { if b {
p.(*Player).SendClientRes() p.(*Player).SendClientRes()
} }
log.Debug("uid : %d, func : %s, execTime : %s ", p.(*Player).M_DwUin, m.GetFunc(), time.Since(start))
} }

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

@ -766,6 +766,7 @@ func FriendMgrSend(m1 *msg.Msg) error {
// 异步发送消息到指定节点 节点不在线则保存消息 // 异步发送消息到指定节点 节点不在线则保存消息
func sendMessageAsync(m *msg.Msg, node int) error { func sendMessageAsync(m *msg.Msg, node int) error {
log.Debug("[Middleware] Send Async message to node: %d, message: %v", node, m)
err := mergeCluster.SendServerMsg(m, node) err := mergeCluster.SendServerMsg(m, node)
if err != nil && GoUtil.InArray(m.HandleType, save_msg_type) { if err != nil && GoUtil.InArray(m.HandleType, save_msg_type) {
saveMessage(m) saveMessage(m)
@ -777,6 +778,7 @@ func sendMessageAsync(m *msg.Msg, node int) error {
// 同步消息到指定节点 节点不在线则保存消息 // 同步消息到指定节点 节点不在线则保存消息
func sendMessageSync(m *msg.Msg, node int) (*msg.Msg, error) { func sendMessageSync(m *msg.Msg, node int) (*msg.Msg, error) {
log.Debug("[Middleware] Send Sync message to node: %d, message: %v", node, m)
msg, err := mergeCluster.CallServerMsg(m, node) msg, err := mergeCluster.CallServerMsg(m, node)
if err != nil && conf.Server.ServerType == "center" && GoUtil.InArray(m.HandleType, save_msg_type) { if err != nil && conf.Server.ServerType == "center" && GoUtil.InArray(m.HandleType, save_msg_type) {
saveMessage(m) saveMessage(m)