liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
richboo111
2023-04-27 16:48:43 +08:00
parent b5dab616bc
commit a6a3d6daca
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
business/partner/purchase/im/im_server.go
View File

@@ -99,6 +99,9 @@ func PingTimer() {
for { for {
i++ i++
<-ticker.C <-ticker.C
//对美团发送心跳
Send([]byte(HeartCheckMsg))
for clientId, conn := range Manager.AllClient() { for clientId, conn := range Manager.AllClient() {
if err := conn.Socket.WriteControl(websocket.PingMessage, []byte{}, time.Now().Add(time.Second)); err != nil { if err := conn.Socket.WriteControl(websocket.PingMessage, []byte{}, time.Now().Add(time.Second)); err != nil {
Manager.DisConnect <- conn Manager.DisConnect <- conn
@@ -107,7 +110,7 @@ func PingTimer() {
if err := ConnRender(conn.Socket, renderData{ClientId: clientId}); err != nil { if err := ConnRender(conn.Socket, renderData{ClientId: clientId}); err != nil {
return return
} }
globals.SugarLogger.Debugf("clientId=%s,i=%d", clientId, i) globals.SugarLogger.Debugf("发送心跳 clientId=%s,i=%d", clientId, i)
} }
} }
}() }()