|
@@ -60,7 +60,7 @@ func keepAlive() {
|
|
|
|
|
|
requestJSON, err := json.Marshal(request)
|
|
|
if err != nil {
|
|
|
- c_log.GlobalLogger.Error("保持websocket连接活跃,解析requestJSON - 失败。", err)
|
|
|
+ //c_log.GlobalLogger.Error("保持websocket连接活跃,解析requestJSON - 失败。", err)
|
|
|
}
|
|
|
|
|
|
for {
|
|
@@ -68,13 +68,13 @@ func keepAlive() {
|
|
|
case <-ticker.C:
|
|
|
err := WsConn.WriteMessage(websocket.TextMessage, requestJSON)
|
|
|
if err != nil {
|
|
|
- c_log.GlobalLogger.Error("保持websocket连接活跃,发送心跳请求 - 失败。", err)
|
|
|
+ //c_log.GlobalLogger.Error("保持websocket连接活跃,发送心跳请求 - 失败。", err)
|
|
|
WsConn.Close()
|
|
|
- c_log.GlobalLogger.Info("重试连接websocket...")
|
|
|
+ //c_log.GlobalLogger.Info("重试连接websocket...")
|
|
|
ConnectWebsocket() // 重新连接
|
|
|
continue
|
|
|
}
|
|
|
- c_log.GlobalLogger.Info("保持websocket连接活跃,发送心跳请求 - 成功。")
|
|
|
+ //c_log.GlobalLogger.Info("保持websocket连接活跃,发送心跳请求 - 成功。")
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -183,13 +183,13 @@ func ConnectWebsocket() {
|
|
|
return
|
|
|
}
|
|
|
reconnectionInProgress = true
|
|
|
- c_log.GlobalLogger.Info("初始化Websocket连接 - 开始。")
|
|
|
+ //c_log.GlobalLogger.Info("初始化Websocket连接 - 开始。")
|
|
|
serverURL := LocalConfig.Node.Ip + ":" + LocalConfig.LocalWebsocketPort
|
|
|
path := "/"
|
|
|
|
|
|
// 构建WebSocket连接URL
|
|
|
u := url.URL{Scheme: "ws", Host: serverURL, Path: path}
|
|
|
- c_log.GlobalLogger.Info("URL:", u.String())
|
|
|
+ //c_log.GlobalLogger.Info("URL:", u.String())
|
|
|
|
|
|
// 创建一个Dialer实例,用于建立WebSocket连接
|
|
|
dialer := websocket.Dialer{
|
|
@@ -203,15 +203,15 @@ func ConnectWebsocket() {
|
|
|
coon, _, err := dialer.Dial(u.String(), nil)
|
|
|
if err != nil {
|
|
|
fmt.Println("err:", err)
|
|
|
- c_log.GlobalLogger.Error("初始化Websocket连接 - 失败。")
|
|
|
+ //c_log.GlobalLogger.Error("初始化Websocket连接 - 失败。")
|
|
|
time.Sleep(5 * time.Second)
|
|
|
reconnectionInProgress = false
|
|
|
- c_log.GlobalLogger.Info("重试连接websocket...")
|
|
|
+ //c_log.GlobalLogger.Info("重试连接websocket...")
|
|
|
continue
|
|
|
}
|
|
|
|
|
|
WsConn = coon
|
|
|
- c_log.GlobalLogger.Info("初始化Websocket连接 - 成功。")
|
|
|
+ //c_log.GlobalLogger.Info("初始化Websocket连接 - 成功。")
|
|
|
// 连接成功,退出循环
|
|
|
reconnectionInProgress = false
|
|
|
break
|