From f53af2c09746c35d5a3dea0311e8e30280231bc4 Mon Sep 17 00:00:00 2001
From: junleea <354425203@qq.com>
Date: Mon, 28 Oct 2024 21:11:44 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=AE=9E=E6=97=B6=E6=9F=A5?=
 =?UTF-8?q?=E7=9C=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 handler/device.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/handler/device.go b/handler/device.go
index 5ea231f..83424bc 100644
--- a/handler/device.go
+++ b/handler/device.go
@@ -233,6 +233,7 @@ func subscribeAndHandleMessages(ws *websocket.Conn, device_id int) {
 	ctx := context.Background()
 	pubsub := worker.RedisClient.Subscribe(ctx, strconv.Itoa(device_id)+"_frames_msgs")
 	defer pubsub.Close()
+	defer ws.Close()
 	ch := pubsub.Channel()
 	var check_cnt int
 	for msg := range ch {
@@ -261,10 +262,9 @@ func subscribeAndHandleMessages(ws *websocket.Conn, device_id int) {
 			clientsMux.Lock()
 			clients[ws] = false
 			clientsMux.Unlock()
-			ws.Close()
+			fmt.Println("send message to client err:", err2)
 			worker.SetRedisWithExpire(strconv.Itoa(device_id)+"_is_play", "0", time.Minute*5)
 			break
 		}
-		time.Sleep(time.Millisecond * 200)
 	}
 }