3399proD解码速度缓慢问题 - Toybrick

import cv2
import time
import gi
gi.require_version('Gst', '1.0')
gi.require_version('GstRtspServer', '1.0')
from gi.repository import GObject, Gst, GstRtspServer
uri = "rtsp://admin:a1234567@192.168.49.94/h264/ch1/main/av_stream"
t0 = time.time()
gst_str = ('rtspsrc location={} latency=0 ! '
'rtph264depay ! h264parse ! mppvideodec ! '
'videoconvert ! video/x-raw,format=BGR,formaterate=25/1 ! appsink sync=false').format(uri)
cap = cv2.VideoCapture(gst_str, cv2.CAP_GSTREAMER)
t = time.time()
print('VideoCapture cost', t - t0)
print('cap isOpened', cap.isOpened())
width = 1920
height = 1080
out_send = cv2.VideoWriter('appsrc ! video/x-raw, format=BGR ! queue ! videoconvert ! video/x-raw,width={},height={} ! queue ! mpph264enc ! queue ! video/x-h264, stream-format=byte-stream ! h264parse ! rtph264pay pt=96 config-interval=1 ! udpsink host=127.0.0.1 port=5400'.format(width, height), cv2.CAP_GSTREAMER, 0, 25, (width, height), True)
print('out_send', out_send.isOpened())
rtsp_port_num = 8554
server = GstRtspServer.RTSPServer.new()
server.props.service = "%d" % rtsp_port_num
server.attach(None)
factory = GstRtspServer.RTSPMediaFactory.new()
factory.set_launch("(udpsrc name=pay0 port=5400 \
caps="application/x-rtp, media=video, clock-rate=90000, \
encoding-name=(string)H264, payload=96 ")")
factory.set_shared(True)
server.get_mount_points().add_factory("/test", factory)
num = 0
start = time.perf_counter()
while True:
t1 = time.time()
ret, frame = cap.read()
t2 = time.time()
print('time cost', round(t2 - t1, 4))
if not ret:
break
t3 = time.time()#
out_send.write(frame)
t4 = time.time()
if cv2.waitKey(1) & 0xFF == ord("q"):
cap.release()
out_send.release()
break
num +=1