如何在python中将多个摄像头视频流传输到单个套接字

import cv2
import socket
import struct
import pickle

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('localhost', 8000))
server_socket.listen(5)

while True:
    client_socket, addr = server_socket.accept()
    print('连接来自:', addr)
    
    # 创建多个摄像头对象
    camera1 = cv2.VideoCapture(0)
    camera2 = cv2.VideoCapture(1)
    
    while True:
        # 读取摄像头帧
        ret1, frame1 = camera1.read()
        ret2, frame2 = camera2.read()
        
        # 将帧序列化为字节流
        data1 = pickle.dumps(frame1)
        data2 = pickle.dumps(frame2)
        
        # 将帧大小打包为4字节数据
        size1 = struct.pack('!I', len(data1))
        size2 = struct.pack('!I', len(data2))
        
        # 发送帧大小和帧数据
        client_socket.sendall(size1 + data1)
        client_socket.sendall(size2 + data2)
        
        # 按下'q'键退出循环
        if cv2.waitKey(1) & 0xFF == ord('q'):
            break
    
    # 关闭摄像头和套接字
    camera1.release()
    camera2.release()
    client_socket.close()

import cv2
import socket
import struct
import pickle

# 创建套接字并连接服务器
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect(('localhost', 8000))

while True:
    # 接收帧大小
    size1 = client_socket.recv(4)
    size2 = client_socket.recv(4)
    
    # 解包帧大小
    size1 = struct.unpack('!I', size1)[0]
    size2 = struct.unpack('!I', size2)[0]
    
    # 接收帧数据
    data1 = b''
    data2 = b''
    while len(data1) < size1:
        data1 += client_socket.recv(4096)
    while len(data2) < size2:
        data2 += client_socket.recv(4096)
    
    # 反序列化帧数据
    frame1 = pickle.loads(data1)
    frame2 = pickle.loads(data2)
    
    # 显示帧
    cv2.imshow('Camera 1', frame1)
    cv2.imshow('Camera 2', frame2)
    
    # 按下'q'键退出循环
    if cv2.waitKey(1) & 0xFF == ord('q'):
        break

# 关闭套接字
client_socket.close()