|
@@ -59,7 +59,7 @@ func keepAlive() {
|
|
for {
|
|
for {
|
|
select {
|
|
select {
|
|
case <-ticker.C:
|
|
case <-ticker.C:
|
|
- err := WsConn.WriteMessage(websocket.TextMessage, requestJSON)
|
|
|
|
|
|
+ err := WsConn.WriteMessage(websocket.PingMessage, requestJSON)
|
|
if err != nil {
|
|
if err != nil {
|
|
c_log.GlobalLogger.Error("保持websocket连接活跃,发送心跳请求 - 失败。", err)
|
|
c_log.GlobalLogger.Error("保持websocket连接活跃,发送心跳请求 - 失败。", err)
|
|
continue
|
|
continue
|
|
@@ -77,8 +77,7 @@ func keepAlive() {
|
|
c_log.GlobalLogger.Error("保持websocket连接活跃,解析心跳响应为json - 失败。", err)
|
|
c_log.GlobalLogger.Error("保持websocket连接活跃,解析心跳响应为json - 失败。", err)
|
|
continue
|
|
continue
|
|
}
|
|
}
|
|
- fmt.Println("websocket responseMessage:", responseMessage)
|
|
|
|
- fmt.Println("websocket responseMessage results:", responseMessage.Results)
|
|
|
|
|
|
+ c_log.GlobalLogger.Info("websocket responseMessage results:", responseMessage)
|
|
if responseMessage.Status != "" {
|
|
if responseMessage.Status != "" {
|
|
c_log.GlobalLogger.Info("websocket发送心跳请求解析状态为", responseMessage.Status)
|
|
c_log.GlobalLogger.Info("websocket发送心跳请求解析状态为", responseMessage.Status)
|
|
}
|
|
}
|