|
|
@@ -84,7 +84,7 @@ func keepAlive() {
|
|
|
c_log.GlobalLogger.Info("websocket发送心跳请求解析故障码为", responseMessage.ErrorCode)
|
|
|
}
|
|
|
|
|
|
- if responseMessage.ErrorCode != "" {
|
|
|
+ if responseMessage.Status != "OK" {
|
|
|
WsConn.Close()
|
|
|
c_log.GlobalLogger.Info("重试连接websocket...")
|
|
|
ConnectWebsocket() // 重新连接
|
|
|
@@ -114,7 +114,7 @@ func ConnectWebsocket() {
|
|
|
ReadBufferSize: 1024,
|
|
|
WriteBufferSize: 1024,
|
|
|
// 可选：设置超时等
|
|
|
- HandshakeTimeout: 5 * time.Second,
|
|
|
+ HandshakeTimeout: 5 * time.Minute,
|
|
|
}
|
|
|
|
|
|
// 建立WebSocket连接
|
