要编写一段用于通过Socket接收视频流并在客户端显示的程序，我们可以采用Python语言，并借助`opencv-python`(cv2)库来进行图像处理和展示、以及`socket`模块来负责网络通信部分。 下面是一段简单的示例代码： 服务器端(发送视频帧): ```python import cv2 import socket import pickle import struct # 创建TCP/IP套接字 server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) host_ip = '192.168.x.xx' # 替换为本机IP地址 port = 5050 # 端口号可以自定义选择未被占用的值 backlog = 5 server_address = (host_ip, port) print('开启服务:', server_address) server_socket.bind(server_address) server_socket.listen(backlog) client_socket, client_addr = server_socket.accept() data = b"" payload_size = struct.calcsize("L") cap=cv2.VideoCapture(0) # 打开摄像头捕获设备，默认是第一个可用的摄像装置编号设为0 while True: ret,frame=cap.read() if not ret : break data_frame=pickle.dumps(frame) # 将帧数据序列化成字符串 message_size = struct.pack("L", len(data_frame)) try: client_socket.sendall(message_size + data_frame) except Exception as e : print(f"传输错误 {e}") break cap.release() ``` 客户端(接受并播放视频): ```python import numpy as np import cv2 import socket import pickle import struct # 创建一个新的套接字对象s client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) host_ip = "192.168.x.xx" port = 5050 client_socket.connect((host_ip,port)) data=b"" payload_size = struct.calcsize("L") while True: while len(data)< payload_size: packet = client_socket.recv(4*1024) if not packet:break data+=packet 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(4*1024) frame_data = data[:msg_size] data = data[msg_size:] frame=pickle.loads(frame_data) cv2.imshow("Receiving...",frame) key=cv2.waitKey(1)&0xFF if key==ord('q') or key ==27:# 按下 ESC 或 q 键退出循环 break client_socket.close() cv2.destroyAllWindows() ``` 以上代码展示了如何构建基本的实时视频流媒体系统。实际应用中可能需要考虑更多因素如异常处理、性能优化等。 请注意将两个脚本中的 IP 地址替换为你环境中正确的地址信息，并确保防火墙允许相应的端口连接。