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