opencv+flask 家庭监控系统源码.zip

import cv2 import threading class RecordingThread(threading.Thread): def __init__(self, name, camera): threading.Thread.__init__(self) self.name = name self.isRunning = True self.cap = camera fourcc = cv2.VideoWriter_fourcc(*'MJPG') self.out = cv2.VideoWriter('./static/video.avi', fourcc, 20.0, (640, 480)) def run(self): while self.isRunning: ret, frame = self.cap.read() if ret: self.out.write(frame) self.out.release() def stop(self): self.isRunning = False def __del__(self): self.out.release() class VideoCamera(object): def __init__(self): # 打开摄像头， 0代表笔记本内置摄像头 self.cap = cv2.VideoCapture(0) # 初始化视频录制环境 self.is_record = False self.out = None # 视频录制线程 self.recordingThread = None # 退出程序释放摄像头 def __del__(self): self.cap.release() def get_frame(self): ret, frame = self.cap.read() if ret: ret, jpeg = cv2.imencode('.jpg', frame) # 视频录制 if self.is_record: if self.out == None: fourcc = cv2.VideoWriter_fourcc(*'MJPG') self.out = cv2.VideoWriter('./static/video.avi', fourcc, 20.0, (640, 480)) ret, frame = self.cap.read() if ret: self.out.write(frame) else: if self.out != None: self.out.release() self.out = None return jpeg.tobytes() else: return None def start_record(self): self.is_record = True self.recordingThread = RecordingThread("Video Recording Thread", self.cap) self.recordingThread.start() def stop_record(self): self.is_record = False if self.recordingThread != None: self.recordingThread.stop()