diff --git a/handler/tool.go b/handler/tool.go index 868555f..ea048a2 100644 --- a/handler/tool.go +++ b/handler/tool.go @@ -195,11 +195,13 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, deviceId int) { count := 0 //定时器,发送计数器 tCount := 0 + var buf []byte //计算帧率 for { //从service获取当前帧 - buf, c := service.GetDeviceCurrentFrameV4(deviceId, count) + newBuf, c := service.GetDeviceCurrentFrameV4(deviceId, count) if c != count { + buf = newBuf count = c err2 := ws.WriteMessage(websocket.BinaryMessage, buf) if err2 != nil { @@ -221,7 +223,6 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, deviceId int) { } } } - buf = nil time.Sleep(100 * time.Millisecond) tCount++ }