|
|
@@ -192,8 +192,6 @@ func connectWebSocket() bool {
|
|
|
|
|
|
wsConn = conn
|
|
|
|
|
|
- // 建立链接即 开始发送心跳请求
|
|
|
- echo()
|
|
|
|
|
|
/*// 设置心跳处理事件
|
|
|
wsConn.SetPingHandler(func(message string) error {
|
|
|
@@ -214,7 +212,8 @@ func connectWebSocket() bool {
|
|
|
// defer wsConn.Close()
|
|
|
// 建立基点接口连接
|
|
|
ctrl.GetConnection(wsConn)
|
|
|
-
|
|
|
+ // 建立链接即 开始发送心跳请求
|
|
|
+ echo()
|
|
|
//重连后更新心跳时间，避免因心跳超时再重连
|
|
|
heartTime = time.Now()
|
|
|
lockReconnect = false
|
|
|
@@ -403,13 +402,13 @@ func echo() {
|
|
|
for {
|
|
|
mt, message, err := wsConn.ReadMessage()
|
|
|
if err != nil {
|
|
|
- //log.Println("read:", err)
|
|
|
+ log.Println("read:", err)
|
|
|
break
|
|
|
}
|
|
|
- //log.Printf("recv: %s", message)
|
|
|
+ // log.Printf("recv: %s", message)
|
|
|
err = wsConn.WriteMessage(mt, message)
|
|
|
if err != nil {
|
|
|
- //log.Println("write:", err)
|
|
|
+ log.Println("write:", err)
|
|
|
break
|
|
|
}
|
|
|
}
|
xuchl