使用分离方式，修改视频流返回方式

handler/tool.go

@@ -143,11 +143,11 @@ func GetRealTimeImage(c *gin.Context) {
 		return
 	}
 	//查看设备是否在获取
-	is_get, ok := service.DeviceIsGettingFrame.Load(device.ID)
-	if !ok || is_get == false {
+	isGet, ok := service.DeviceIsGettingFrame.Load(device.ID)
+	if !ok || isGet == false {
 		//直接返回
 		c.JSON(http.StatusOK, gin.H{"code": 4, "message": "device not getting frame or not exist"})
-		log.Printf("device:%d not found", device.ID)
+		log.Printf("device:%d not found,isGet:%v , ok = %v", device.ID, isGet, ok)
 		return
 	}
 	ws, err := upgrader.Upgrade(c.Writer, c.Request, nil)

main.go

@@ -110,6 +110,8 @@ func ReadConfigAndSetSystem() {
 				service.Device1CurrentFrame = gocv.NewMat()
 			case 50:
 				service.Device50CurrentFrame = gocv.NewMat()
+			case 73:
+				service.Device73CurrentFrame = gocv.NewMat()
 			}
 			go service.GetVideoStream(device.ID)
 			log.Printf("device:%d has started!\n", device.ID)

service/tool.go

@@ -161,7 +161,9 @@ func GetDeviceCurrentFrameV3(deviceId int) (gocv.Mat, int) {
 		Device50CurrentFrame.CopyTo(&frame)
 		//查看帧状态
 		//log.Printf("frame:%v,Device50CurrentFrame:%v\n", frame.Empty(), Device50CurrentFrame.Empty())
-
+	case 73:
+		frame = gocv.NewMatWithSize(Device73CurrentFrame.Rows(), Device73CurrentFrame.Cols(), Device73CurrentFrame.Type())
+		Device73CurrentFrame.CopyTo(&frame)
 	}
 
 	frameCount, ok := DeviceFrameCount[deviceId]