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

修复实时查看redis发布订阅模式

This commit is contained in:
junleea 2024-10-28 21:18:54 +08:00
parent f53af2c097
commit e1bae50a04
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
handler/device.go
View File

@ -256,7 +256,7 @@ 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)) //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()