参考：
从【OpenCV】利用Flask+Python+OpenCV实现摄像头读取图像帧网页视频流_小风
基于OpenCV + flask 实现的网络实时视频流传输 | 附源码
【opencv-python】利用opencv读取rtsp的实时帧_frootguo的博客-CSDN博客_opencv读取rtmp
Python调用海康威视网络相机之——python读取相机rtsp码流显示画面_ciky奇的博客-CSDN博客_python 海康摄像头
1、FLASK安装
Pycharm 2021.3.3 中文输入，测试了很多无效。最好采用以下：
Ubuntu 20.04 系统自带中文输入法在PyCharm只能输入3个字母的问题_依巴谷32349的博客-CSDN博客
2、运行
Pycharm中
菜单Run -> run...
错误1：
SyntaxError: (unicode error) 'utf-8' codec can't decode byte 0xd6 in position 0: invalid continuation byte
中文编码问题，用UTF8
错误2：ImportError: numpy.core.multiarray failed to import
安装
pip install numpy==1.16.4
pip install matplotlib==3.4.3? (最新3.5.1要求numpy>1.17)
执行结果
FLASK_APP = app.py
FLASK_ENV = development
FLASK_DEBUG = 0
In folder /home/robot/anaconda3/envs/tf/flask
/home/robot/anaconda3/envs/tf/bin/python -m flask run
* Serving Flask app 'app.py' (lazy loading)
* Environment: development
* Debug mode: off
* Running on http://127.0.0.1:5000/ (Press CTRL+C to quit)
3、代码
?app.py
# -*-coding:utf-8-*-
from flask import Flask, render_template, Response
from RtspCapture import RtspCapture
app = Flask(__name__)
@app.route('/')
def index():
return render_template('index.html')
def gen(rtsp):
while True:
this_frame = rtsp.cap_frame()
if this_frame is not None:
yield (b'--frame\r\n'
b'Content-Type: image/jpeg\r\n\r\n' + this_frame + b'\r\n')
@app.route('/video_feed')
def video_feed():
cap = RtspCapture()
cap.start()
return Response(gen(cap),
mimetype='multipart/x-mixed-replace; boundary=frame')
if __name__ == '__main__':
app.run(host='127.0.0.1', port=9011, threaded=True)
RtspCapture.py
import os
import cv2
import time
import threading
import queue
class RtspCapture(object):
read_thread = None # background thread that reads frames from camera
get_thread = None # 从imglist中获取帧的进程
pop_frame = None # current frame is stored here by background thread
last_access = 0 # time of last client access to the camera
imgList = None
url = "rtsp://admin:admin888@192.168.1.64:554/h264/ch1/sub/av_stream"
top = 100
lock = None
def __init__(self):
top = 100
def start(self):
# self.imgList = Manager().list()
self.imgList = queue.Queue(self.top)
self.lock = threading.Lock()
if self.read_thread is None:
# start background frame thread
self.read_thread = threading.Thread(target=self.read)
self.read_thread.start()
if self.get_thread is None:
self.last_access = time.time()
self.get_thread = threading.Thread(target=self.get_frame)
self.get_thread.start()
def set_url(self, src):
self.url = src
# 向共享缓冲栈中写入数据:
def read(self):
print('Process to write: %s' % os.getpid())
cap = cv2.VideoCapture(self.url)
while True:
_, img = cap.read()
if _:
if self.imgList.full():
self.imgList.get()
self.imgList.put(img)
# 在缓冲栈中读取数据:
def get_frame(self):
print('Process to get: %s' % os.getpid())
while True:
if not self.imgList.empty():
self.lock.acquire()
value = self.imgList.get(False) # 非阻塞方法
self.pop_frame = value
self.lock.release()
def cap_frame(self):
if self.pop_frame is None:
print('frame is None')
else:
# print('set frame')
self.lock.acquire()
jpg = cv2.imencode('.jpg', self.pop_frame)[1].tobytes()
self.lock.release()
return jpg
index.html
<html>
<head>
<title>视频流演示</title>
</head>
<body>
<h1>视频流演示</h1>
<img src="{{ url_for('video_feed') }}">
</body>
</html>遗留问题：
延迟暂时没有解决