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) } } }()