|
|
@@ -67,7 +67,7 @@ func keepAlive() {
|
|
|
// continue
|
|
|
//}
|
|
|
//c_log.GlobalLogger.Error("responseMessage", responseMessage)
|
|
|
- flag, err := SendWebsocketHeartbeat(WsConn, 100)
|
|
|
+ flag, err := SendWebsocketHeartbeat(WsConn, 1000)
|
|
|
if err != nil {
|
|
|
c_log.GlobalLogger.Error("保持websocket连接活跃，请求出错，定时重试。", err)
|
|
|
}
|
|
|
@@ -114,8 +114,10 @@ func SendWebsocketHeartbeat(conn *websocket.Conn, maxRetries int) (bool, error)
|
|
|
}
|
|
|
|
|
|
var response Response
|
|
|
- if err := json.Unmarshal(message, &response); err == nil && response.Type == "response" {
|
|
|
- c_log.GlobalLogger.Info("response ", response)
|
|
|
+ err = json.Unmarshal(message, &response)
|
|
|
+ c_log.GlobalLogger.Info("response ", response)
|
|
|
+ if err == nil && response.Type == "response" {
|
|
|
+ c_log.GlobalLogger.Info("response1 ", response)
|
|
|
return true, err
|
|
|
}
|
|
|
count++
|
