From 1b9ec9f2b69b3d2eadbca05447b4d69d1a97a232 Mon Sep 17 00:00:00 2001 From: kercylan98 Date: Fri, 14 Jul 2023 17:41:41 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BF=AE=E5=A4=8D=20server.PushAsyncMe?= =?UTF-8?q?ssage=20=E6=97=A0=E6=B3=95=E6=AD=A3=E7=A1=AE=E8=B0=83=E7=94=A8?= =?UTF-8?q?=E5=9B=9E=E8=B0=83=E5=87=BD=E6=95=B0=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/server.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/server/server.go b/server/server.go index e0d2c61..344f66e 100644 --- a/server/server.go +++ b/server/server.go @@ -317,7 +317,6 @@ func (slf *Server) Run(addr string) error { <-messageInitFinish close(messageInitFinish) messageInitFinish = nil - fmt.Println("messageInitFinish") if slf.multiple == nil { log.Info("Server", zap.String(serverMark, "====================================================================")) log.Info("Server", zap.String(serverMark, "RunningInfo"), @@ -566,10 +565,11 @@ func (slf *Server) dispatchMessage(msg *Message) { slf.messagePool.Release(msg) } }() - if err := handle(); err != nil { - if cb { - callback(err) - } + err := handle() + if cb { + callback(err) + } else { + log.Error("Server", zap.String("MessageType", messageNames[msg.t]), zap.Any("error", err), zap.String("stack", string(debug.Stack()))) } }); err != nil { panic(err)