From 4c501317613af34645a9641b3da72577e583d07a Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Fri, 20 Oct 2023 14:12:29 +0800 Subject: [PATCH] fix --- server/websocket/internal/logic/datatransferlogic.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/server/websocket/internal/logic/datatransferlogic.go b/server/websocket/internal/logic/datatransferlogic.go index e7a52f30..827717f8 100644 --- a/server/websocket/internal/logic/datatransferlogic.go +++ b/server/websocket/internal/logic/datatransferlogic.go @@ -322,10 +322,14 @@ func (w *wsConnectItem) heartbeat() { w.debug = nil } //发送心跳信息 - if err := w.conn.WriteMessage(websocket.PongMessage, w.respondDataFormat(constants.WEBSOCKET_HEARTBEAT, websocket_data.HeartBeatMsg{ - WsCount: currentWebsocketConnectCount, - CombineCount: currentRequestCombineApiCount, - })); err != nil { + var d interface{} + if w.debug != nil { + d = websocket_data.HeartBeatMsg{ + WsCount: currentWebsocketConnectCount, + CombineCount: currentRequestCombineApiCount, + } + } + if err := w.conn.WriteMessage(websocket.PongMessage, w.respondDataFormat(constants.WEBSOCKET_HEARTBEAT, d)); err != nil { logx.Error("发送心跳信息异常,关闭连接:", w.uniqueId, err) w.close() return