From 9f570d9da1bc4d087a7b83cd038227eb392899f6 Mon Sep 17 00:00:00 2001
From: weidong <weidong@im-droid.com>
Date: Sat, 13 Jan 2024 15:06:58 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=A2=9E=E5=8A=A0websocket=E4=BF=9D?=
 =?UTF-8?q?=E6=B4=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/resources/templates/page/cmd_line.html | 17 ++++++++++++++---
 1 file changed, 14 insertions(+), 3 deletions(-)

diff --git a/sec-beidou/src/main/resources/templates/page/cmd_line.html b/sec-beidou/src/main/resources/templates/page/cmd_line.html
index 8c79231e..ae2adff3 100644
--- a/sec-beidou/src/main/resources/templates/page/cmd_line.html
+++ b/sec-beidou/src/main/resources/templates/page/cmd_line.html
@@ -116,7 +116,12 @@
 
 <!-- Web socket operations-->
 <script type="text/javascript">
+	var intervalId;
+	var websocket;
+	var rxWin;
+
 	layui.$(function(){
+		rxWin = layui.$('#rx_win');
 		if(typeof(WebSocket) == "undefined"){
 			console.log("WebSocket not support for this WebBrowser!")
 		}
@@ -140,22 +145,28 @@
 		//建立webSocket连接
 		var webSocktPath;
 		webSocktPath = (basePath+"/websocket").replace("http","ws");
-		var websocket = new WebSocket(webSocktPath);
+		websocket = new WebSocket(webSocktPath);
 
 		//打开webSokcet连接时，回调该函数
 		websocket.onopen = function () {
 			console.log("Socket open");
+			intervalId = setInterval(function() {
+				websocket.send("hello");
+			}, 60000); // keepalive
+
 		}
 		websocket.onerror = function (){
 			console.log("Socket error");
 			layui.layer.alert("Open web socket failed!");
 		}
+		websocket.onclose = function (){
+			rxWin.append("websocket closed!")
+			clearInterval(intervalId);
+		}
 		//接收信息
 		websocket.onmessage = function (event) {
 			console.log(event.data);
-			var rxWin = layui.$('#rx_win');
 			rxWin.val(rxWin.val()+event.data + "\r\n");
-			var obj = document.getElementById("rx_win");
 			rxWin.scrollTop = rxWin.scrollHeight;
 		}
 	}