From a6a3d6daca654138d1a08fb1bf0acc8c87d1f026 Mon Sep 17 00:00:00 2001 From: richboo111 Date: Thu, 27 Apr 2023 16:48:43 +0800 Subject: [PATCH] 1 --- business/partner/purchase/im/im_server.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/business/partner/purchase/im/im_server.go b/business/partner/purchase/im/im_server.go index 58f9e7177..a76db0e23 100644 --- a/business/partner/purchase/im/im_server.go +++ b/business/partner/purchase/im/im_server.go @@ -99,6 +99,9 @@ func PingTimer() { for { i++ <-ticker.C + //对美团发送心跳 + Send([]byte(HeartCheckMsg)) + for clientId, conn := range Manager.AllClient() { if err := conn.Socket.WriteControl(websocket.PingMessage, []byte{}, time.Now().Add(time.Second)); err != nil { Manager.DisConnect <- conn @@ -107,7 +110,7 @@ func PingTimer() { if err := ConnRender(conn.Socket, renderData{ClientId: clientId}); err != nil { return } - globals.SugarLogger.Debugf("clientId=%s,i=%d", clientId, i) + globals.SugarLogger.Debugf("发送心跳 clientId=%s,i=%d", clientId, i) } } }()