ljydlv
/
videoplayer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复实时查看

This commit is contained in:
junleea 2024-10-28 20:56:26 +08:00
parent 1ce27b543d
commit 81e0c2a5bf
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
handler/device.go
View File

@ -221,11 +221,11 @@ func GetRealTimeImage(c *gin.Context) {
ws, err := upgrader.Upgrade(c.Writer, c.Request, nil) ws, err := upgrader.Upgrade(c.Writer, c.Request, nil)
clients[ws] = true clients[ws] = true
if err != nil { if err != nil {
fmt.Println(err) fmt.Println("connect wss err:", err)
return return
} }
defer ws.Close()
worker.SetRedisWithExpire(strconv.Itoa(int(device.ID))+"_is_play", "1", time.Minute*5) worker.SetRedisWithExpire(strconv.Itoa(int(device.ID))+"_is_play", "1", time.Minute*5)
fmt.Println("device_id:", device_id_int, " has set is_play to 1")
go subscribeAndHandleMessages(ws, device_id_int) go subscribeAndHandleMessages(ws, device_id_int)
} }
@ -255,11 +255,13 @@ func subscribeAndHandleMessages(ws *websocket.Conn, device_id int) {
msgObj.From_user_id = -1 msgObj.From_user_id = -1
res3, _ = json.Marshal(msgObj) res3, _ = json.Marshal(msgObj)
} }
fmt.Println("send message to client length:", len(res3))
err2 := ws.WriteMessage(websocket.TextMessage, res3) err2 := ws.WriteMessage(websocket.TextMessage, res3)
if err2 != nil { if err2 != nil {
clientsMux.Lock() clientsMux.Lock()
clients[ws] = false clients[ws] = false
clientsMux.Unlock() clientsMux.Unlock()
ws.Close()
worker.SetRedisWithExpire(strconv.Itoa(device_id)+"_is_play", "0", time.Minute*5) worker.SetRedisWithExpire(strconv.Itoa(device_id)+"_is_play", "0", time.Minute*5)
break break
} }