Python 3 中通过套接字的 OpenCV 实时流视频

Python 3 中通过套接字的 OpenCV 实时流视频

python
import cv2
import socket
import pickle
import struct
# 创建一个套接字对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定 IP 地址和端口号
server_socket.bind(('0.0.0.0', 8000))
# 监听连接
server_socket.listen(5)
# 接受客户端连接
client_socket, addr = server_socket.accept()
# 接收数据流
data = b""
payload_size = struct.calcsize(">L")
while True:
    while len(data) < payload_size:
        data += client_socket.recv(4096)
    
    packed_msg_size = data[:payload_size]
    data = data[payload_size:]
    msg_size = struct.unpack(">L", packed_msg_size)[0]
    
    while len(data) < msg_size:
        data += client_socket.recv(4096)
    
    frame_data = data[:msg_size]
    data = data[msg_size:]
    
    # 解析帧数据
    frame = pickle.loads(frame_data, fix_imports=True, encoding="bytes")
    frame = cv2.imdecode(frame, cv2.IMREAD_COLOR)
    
    # 显示帧图像
    cv2.imshow('Video', frame)
    cv2.waitKey(1)

python
import cv2
import socket
import pickle
import struct
# 创建一个套接字对象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 连接服务器
client_socket.connect(('127.0.0.1', 8000))
# 打开摄像头
cap = cv2.VideoCapture(0)
while True:
    # 读取帧图像
    ret, frame = cap.read()
    
    # 序列化帧数据
    data = pickle.dumps(frame, fix_imports=True)
    msg = struct.pack(">L", len(data)) + data
    
    # 发送数据流
    client_socket.sendall(msg)
    
    # 按下 'q' 键退出
    if cv2.waitKey(1) & 0xFF == ord('q'):
        break
# 关闭套接字和摄像头
client_socket.close()
cap.release()
cv2.destroyAllWindows()