使用socket实现视频会议代码

以下是一个简单的视频会议示例代码，使用 Python 的 Socket 模块实现：

`server.py`:

import socket
import cv2
import numpy as np

# 创建一个 TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 绑定 socket 到一个地址和端口号
server_address = ('localhost', 10000)
print('starting up on %s port %s' % server_address)
sock.bind(server_address)

# 开始监听传入连接
sock.listen(1)

# 等待连接
print('waiting for a connection...')
connection, client_address = sock.accept()
print('connection from', client_address)

# 加载视频
cap = cv2.VideoCapture('video.mp4')

# 循环读取每一帧并发送给客户端
while True:
    ret, frame = cap.read()
    # 将帧转换为字符串
    data = frame.tostring()
    # 发送帧大小
    connection.sendall(np.array(frame.shape).astype(np.int32).tobytes())
    # 发送帧数据
    connection.sendall(data)
    # 如果视频已经播放完毕，退出循环
    if not ret:
        break

# 关闭连接和 socket
connection.close()
sock.close()

`client.py`:

import socket
import cv2
import numpy as np

# 创建一个 TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 连接到服务器地址和端口
server_address = ('localhost', 10000)
print('connecting to %s port %s' % server_address)
sock.connect(server_address)

# 循环接收视频帧
while True:
    # 接收帧大小
    data = sock.recv(8)
    size = np.frombuffer(data, dtype=np.int32)
    # 接收帧数据
    data = sock.recv(np.prod(size)*3)
    # 将接收到的数据转换为 numpy 数组并重塑为帧大小
    frame = np.frombuffer(data, dtype=np.uint8).reshape(size)
    # 显示帧
    cv2.imshow('frame', frame)
    # 如果按下 q 键，退出循环
    if cv2.waitKey(1) & 0xFF == ord('q'):
        break

# 关闭连接和 socket
sock.close()
cv2.destroyAllWindows()

这段代码使用 OpenCV 库来读取视频帧，然后使用 numpy 将帧转换为字符串，并通过 Socket 发送给客户端。客户端接收并解码每一帧，并使用 OpenCV 库显示视频。