fix

constants/websocket.go

@@ -9,6 +9,9 @@ const (
 	WEBSOCKET_CONNECT_SUCCESS Websocket = "WEBSOCKET_CONNECT_SUCCESS" //ws连接成功 （1级消息，单向通信）
 )
 
+// 心跳
+const WEBSOCKET_HEARTBEAT Websocket = "WEBSOCKET_HEARTBEAT"
+
 // websocket消息类型(通用通知类别)
 const (
 	WEBSOCKET_COMMON_NOTIFY Websocket = "WEBSOCKET_COMMON_NOTIFY" //通用回调通知（1级消息，单向通信）

server/websocket/internal/logic/datatransferlogic.go

@@ -322,7 +322,10 @@ func (w *wsConnectItem) heartbeat() {
 				w.debug = nil
 			}
 			//发送心跳信息
-			if err := w.conn.WriteMessage(websocket.PongMessage, nil); err != nil {
+			if err := w.conn.WriteMessage(websocket.PongMessage, w.respondDataFormat(constants.WEBSOCKET_HEARTBEAT, websocket_data.HeartBeatMsg{
+				WsCount:      currentWebsocketConnectCount,
+				CombineCount: currentRequestCombineApiCount,
+			})); err != nil {
 				logx.Error("发送心跳信息异常，关闭连接:", w.uniqueId, err)
 				w.close()
 				return

utils/websocket_data/base_data.go

@@ -23,3 +23,9 @@ type ConnectErrMsg struct {
 type ConnectUnAuth struct {
 	Message string `json:"message"`
 }
+
+// 心跳数据
+type HeartBeatMsg struct {
+	WsCount      int `json:"ws_count"`
+	CombineCount int `json:"combine_count"`
+}