handler/tool.go

@@ -11,7 +11,6 @@ import (
 	"io"
 	"log"
 	"net/http"
-	"runtime"
 	"strconv"
 	"time"
 )
@@ -195,13 +194,11 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, deviceId int) {
 	count := 0
 	//定时器，发送计数器
 	tCount := 0
-	var buf []byte
 	//计算帧率
 	for {
 		//从service获取当前帧
-		newBuf, c := service.GetDeviceCurrentFrameV4(deviceId, count)
+		buf, c := service.GetDeviceCurrentFrameV4(deviceId, count)
 		if c != count {
-			buf = newBuf
 			count = c
 			err2 := ws.WriteMessage(websocket.BinaryMessage, buf)
 			if err2 != nil {
@@ -223,6 +220,7 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, deviceId int) {
 				}
 			}
 		}
+		buf = nil
 		time.Sleep(100 * time.Millisecond)
 		tCount++
 	}
@@ -232,7 +230,4 @@ func subscribeAndHandleMessagesV3(ws *websocket.Conn, deviceId int) {
 		worker.SetRedisWithExpire(strconv.Itoa(deviceId)+"_is_play", "1", time.Minute*5)
 		log.Printf("device_id: %d has set is_play to 0", deviceId)
 	}
-
-	//垃圾回收
-	runtime.GC()
 }