From c7f73d7d8018ea14a4dd464429c8f63ee4ca05fc Mon Sep 17 00:00:00 2001 From: lwch Date: Fri, 20 Aug 2021 10:10:07 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E6=B2=A1=E6=9C=89=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E7=9A=84client=E4=BC=9A=E8=A2=AB=E6=96=AD=E5=BC=80?= =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- code/server/handler/handler.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/code/server/handler/handler.go b/code/server/handler/handler.go index a9a22ca..d83bd31 100644 --- a/code/server/handler/handler.go +++ b/code/server/handler/handler.go @@ -83,9 +83,6 @@ func (h *Handler) readHandshake(c *network.Conn) (string, error) { // onMessage forward message func (h *Handler) onMessage(msg *network.Msg) { - if msg.GetXType() == network.Msg_keepalive { - return - } to := msg.GetTo() h.RLock() cli := h.clients[to] @@ -95,6 +92,9 @@ func (h *Handler) onMessage(msg *network.Msg) { return } cli.updated = time.Now() + if msg.GetXType() == network.Msg_keepalive { + return + } h.msgHook(msg) cli.writeMessage(msg) }