|
@@ -106,11 +106,12 @@ func SendWebsocketHeartbeat(conn *websocket.Conn, maxRetries int) (bool, error)
|
|
|
if count > maxRetries {
|
|
|
return false, fmt.Errorf("保持websocket连接活跃,读取websocket消息超过最大重试次数。")
|
|
|
}
|
|
|
- time.Sleep(100 * time.Millisecond)
|
|
|
+ time.Sleep(1 * time.Second)
|
|
|
_, message, err := conn.ReadMessage()
|
|
|
if err != nil {
|
|
|
- c_log.GlobalLogger.Error("保持websocket连接活跃,读取websocket消息 - 失败 ", err)
|
|
|
+ c_log.GlobalLogger.Error("保持websocket连接活跃,读取websocket消息 - 失败 ", err, " 继续读取消息。")
|
|
|
return false, err
|
|
|
+ //continue
|
|
|
}
|
|
|
|
|
|
var response Response
|