diff --git a/src/server/game/external.go b/src/server/game/external.go index b9445d54..9e1c5bfa 100644 --- a/src/server/game/external.go +++ b/src/server/game/external.go @@ -52,6 +52,7 @@ func HandleAdminReq(args []interface{}) { } func HandleClientReq(args []interface{}) { + start := time.Now() if G_GameLogicPtr.SeverInfo.Status == SERVER_STATUS_CLOSE || G_GameLogicPtr.SeverInfo.Status == SERVER_STATUS_MAINTAIN { return // 服务器关闭或者维护中,不处理任何消息 } @@ -146,8 +147,7 @@ func HandleClientReq(args []interface{}) { ResRegisterAccount.ResultCode = 0 data, _ := proto.Marshal(ResRegisterAccount) gl.PackResInfo(a, "ResRegisterAccount", data) - case "ReqLogin": - now := time.Now().UnixMilli() + case "ReqLogin": // 登录请求 detail := &msg.ReqLogin{} proto.Unmarshal(buf, detail) accountInfo := db.GetAccountInfoFromDb(detail.UserName) @@ -187,8 +187,9 @@ func HandleClientReq(args []interface{}) { p.(*Player).LoginBackData() p.(*Player).TeLog("Login_log", nil) } - execTime := time.Now().UnixMilli() - now - log.Debug("uid : %d, func : %s, execTime : %d ms, isNew: %v", p.(*Player).M_DwUin, m.GetFunc(), execTime, newPlayer) + if 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() case "ReqServerTime": // 获取服务器时间 detail := &msg.ReqServerTime{} @@ -202,7 +203,6 @@ func HandleClientReq(args []interface{}) { default: p, ok := internal.Agents.Load(a) if ok && p != G_GameLogicPtr.NotInitPlayer { - now := time.Now().UnixMilli() p.(*Player).lock.Lock() //加锁 backup := p.(*Player).BackUp() // 备份当前的 Player 值 defer func() { @@ -223,11 +223,9 @@ func HandleClientReq(args []interface{}) { return } p.(*Player).ProcessTrigger() - execTime := time.Now().UnixMilli() - now - 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{}{ + p.(*Player).TeLog("func_exec_time", map[string]interface{}{ "method_name": m.GetFunc(), - "exec_time": execTime, + "exec_time": time.Since(start), }) } } @@ -235,5 +233,5 @@ func HandleClientReq(args []interface{}) { if b { p.(*Player).SendClientRes() } - + log.Debug("uid : %d, func : %s, execTime : %s ", p.(*Player).M_DwUin, m.GetFunc(), time.Since(start)) } diff --git a/src/server/game/message_mgr.go b/src/server/game/message_mgr.go index eddcd85a..98aecb1d 100644 --- a/src/server/game/message_mgr.go +++ b/src/server/game/message_mgr.go @@ -766,6 +766,7 @@ func FriendMgrSend(m1 *msg.Msg) 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) if err != nil && GoUtil.InArray(m.HandleType, save_msg_type) { saveMessage(m) @@ -777,6 +778,7 @@ func sendMessageAsync(m *msg.Msg, node int) 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) if err != nil && conf.Server.ServerType == "center" && GoUtil.InArray(m.HandleType, save_msg_type) { saveMessage(m)