使用python通过ZMQ pubsub发送视频？

import zmq
import cv2
import numpy as np

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://127.0.0.1:5555")

cap = cv2.VideoCapture('video.mp4')  # 或者使用摄像头：cap = cv2.VideoCapture(0)

while cap.isOpened():
    ret, frame = cap.read()
    if not ret:
        break
    
    # 将帧转换为字节流
    frame_bytes = cv2.imencode('.jpg', frame)[1].tobytes()
    
    # 发送帧数据
    socket.send(frame_bytes)

import zmq
import cv2
import numpy as np

context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://127.0.0.1:5555")
socket.setsockopt_string(zmq.SUBSCRIBE, '')

while True:
    frame_bytes = socket.recv()
    
    # 将字节流转换为图像
    frame = cv2.imdecode(np.frombuffer(frame_bytes, dtype=np.uint8), cv2.IMREAD_COLOR)
    
    # 显示图像
    cv2.imshow('Video', frame)
    
    if cv2.waitKey(1) & 0xFF == ord('q'):
        break

cap.release()
cv2.destroyAllWindows()