From cd3c9a30cef3b70befaeb52824140ba9a2a45d18 Mon Sep 17 00:00:00 2001
From: junleea <354425203@qq.com>
Date: Thu, 18 Jul 2024 15:48:43 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=A4=A7=E5=8F=91=E9=80=81sleep?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 handler/device.go | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/handler/device.go b/handler/device.go
index 57d309f..f5f4ee1 100644
--- a/handler/device.go
+++ b/handler/device.go
@@ -234,6 +234,7 @@ func GetRealTimeImage(c *gin.Context) {
 	go func(ws *websocket.Conn, device_id int) {
 
 	}(ws, device_id_int)
+	var check_cnt int
 
 	for {
 		if v := clients[ws]; v == true {
@@ -248,6 +249,12 @@ func GetRealTimeImage(c *gin.Context) {
 				res3, _ = json.Marshal(msg)
 			} else {
 				//若无消息则发送心跳包
+				if check_cnt < 5 {
+					check_cnt++
+					time.Sleep(time.Millisecond * 200) //设置延时200ms
+					continue
+				}
+				check_cnt = 0
 				msg.Type = "check"
 				msg.Msg = "check"
 				msg.From_user_id = -1
@@ -262,7 +269,7 @@ func GetRealTimeImage(c *gin.Context) {
 				worker.SetRedisWithExpire(strconv.Itoa(int(device.ID))+"_is_play", "0", time.Minute*5) //设置播放状态
 				break
 			}
-			time.Sleep(time.Millisecond * 100) //设置延时100ms
+			time.Sleep(time.Millisecond * 200) //设置延时200ms
 		}
 	}
 }