From d46e44d35f25b8c07a14f8ff52496e9e22d41243 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Thu, 21 Mar 2024 19:33:02 +0800 Subject: [PATCH] 1 --- server/imserver_new/listener/handlermgr.go | 2 +- server/imserver_new/player/player.go | 5 +++++ server/imserver_new/player/playermgr.go | 12 ++++++++++++ 3 files changed, 18 insertions(+), 1 deletion(-) diff --git a/server/imserver_new/listener/handlermgr.go b/server/imserver_new/listener/handlermgr.go index e987d433..1a74de55 100644 --- a/server/imserver_new/listener/handlermgr.go +++ b/server/imserver_new/listener/handlermgr.go @@ -13,10 +13,10 @@ func (this *HandlerMgr) init() { ss.RegHandlerId(int(ss.SSMessageIdE__SS_Ping), constant.WSP_LISTENER_HANDLER_ID) ss.RegHandlerId(int(ss.SSMessageIdE__SS_WSP_SocketDisconnect), constant.WSP_LISTENER_HANDLER_ID) - cs.RegHandlerId(int(cs.CMMessageIdE__CMPing), constant.PLAYER_MGR_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMLogin), constant.PLAYER_MGR_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMReconnect), constant.PLAYER_MGR_HANDLER_ID) + cs.RegHandlerId(int(cs.CMMessageIdE__CMPing), constant.PLAYER_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMSearchUser), constant.PLAYER_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMSearchUserByAccountId), constant.PLAYER_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMAddFriendRequest), constant.PLAYER_HANDLER_ID) diff --git a/server/imserver_new/player/player.go b/server/imserver_new/player/player.go index a82e9240..f58c9c56 100644 --- a/server/imserver_new/player/player.go +++ b/server/imserver_new/player/player.go @@ -101,6 +101,11 @@ func (this *player) reBind(socket f5.WspCliConn) { _playerMgr.socketHash[this.socket] = this } +func (this *player) CMPing(hdr *f5.MsgHdr, msg *cs.CMPing) { + rspMsg := new(cs.SMPing) + this.SendMsg(rspMsg) +} + // CMSearchUser 搜索用户 func (this *player) CMSearchUser(hdr *f5.MsgHdr, msg *cs.CMSearchUser) { sinceId := msg.GetSinceId() diff --git a/server/imserver_new/player/playermgr.go b/server/imserver_new/player/playermgr.go index b78cd5a8..cc8007e3 100644 --- a/server/imserver_new/player/playermgr.go +++ b/server/imserver_new/player/playermgr.go @@ -337,3 +337,15 @@ func (this *playerMgr) RemoveSocketCloseEvent(evHandle *SocketCloseEventHandle) panic("RemoveSocketCloseEvent error") } } + +func (this *playerMgr) ProcessCMMsg(handler *cs.CsNetMsgHandler, hdr *f5.MsgHdr) { + switch handler.HandlerId { + case constant.PLAYER_MGR_HANDLER_ID: + cs.DispatchMsg(handler, hdr, this) + case constant.PLAYER_HANDLER_ID: + hum := this.internalGetPlayerBySocket(hdr.GetSocket()) + if hum != nil { + cs.DispatchMsg(handler, hdr, hum) + } + } +}