python3.6socket传输视频资源-CSDN下载

共2个文件

py：2个

5星 · 超过95%的资源需积分: 42 42 浏览量 2018-05-23 17:15:48 上传评论 10 收藏 3KB RAR 举报

在Python 3.6中，Socket编程是一种基础的网络通信技术，它允许程序之间通过网络进行数据交换。在这个场景中，我们关注的是如何利用Socket库来实现TCP协议下的视频传输。TCP（Transmission Control Protocol）是一种面向连接的、可靠的传输协议，确保了数据包的有序、无损传输，非常适合于大容量数据如视频的传送。我们需要了解Python Socket的基本用法。在Python中，`socket`模块提供了低级别的套接字接口。创建一个Socket对象可以通过`socket.socket()`函数完成，指定传输层协议（TCP或UDP）和地址族（通常为AF_INET，表示IPv4）： ```python import socket s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) ``` 接着，服务器端需要绑定一个特定的IP地址和端口号，然后监听连接请求： ```python server_address = ('localhost', 12345) s.bind(server_address) s.listen(1) # 最大连接队列长度为1 ``` 当客户端想要连接服务器时，它也需要创建一个Socket对象，并调用`connect()`方法： ```python client_address = ('localhost', 12345) c = socket.socket(socket.AF_INET, socket.SOCK_STREAM) c.connect(client_address) ``` 在视频传输中，服务器接收到连接请求后，会创建一个新的Socket对象用于与客户端通信，并接受客户端的连接： ```python connection, client_address = s.accept() ``` 接下来，我们需要将视频文件拆分成多个数据块，然后通过Socket逐块发送。Python的`read()`方法可以读取文件内容，配合`sendall()`方法发送数据： ```python with open('video.mp4', 'rb') as f: chunk = f.read(1024) # 分块大小，可以根据网络状况调整 while chunk: connection.sendall(chunk) chunk = f.read(1024) ``` 客户端则通过`recv()`方法接收数据，并写入到本地文件，从而重建视频： ```python with open('received_video.mp4', 'wb') as f: while True: chunk = connection.recv(1024) if not chunk: break f.write(chunk) ``` 在传输完成后，记得关闭Socket连接，释放资源： ```python connection.close() s.close() c.close() ``` 以上就是使用Python 3.6的Socket进行TCP视频传输的基本流程。在实际应用中，还需要考虑错误处理、超时重试、断点续传、多线程/异步处理等高级特性，以提高传输的稳定性和效率。同时，为了防止内存溢出，可能需要对大文件的读取和接收进行优化，例如使用缓冲区或者分块读写。对于网络状况不稳定的环境，TCP的流控制和拥塞控制机制能提供一定的保障，但依然需要根据具体需求进行策略调整。

资源推荐

资源详情

资源评论

收起资源包目录

SOCKET传输视频.rar （2个子文件）

SOCKET传输视频

video_C.py 4KB

video_S.py 4KB

import socket import cv2 import threading import struct import numpy #TCP连接 #1.　客户端连接端口后，首先发送需要协商的分辨率和帧数，以致能够使传输“协议”一致 #2.　客户端使用线程，对图片进行收集 #3.　对收到的每一张图片进行解码，并利用OpenCV播放出来，即可实现C/S两端实时视频传输。 #4 利用服务器端打开端口8880，此时客户端连接后，便可以在客户端中捕获到服务器端的视频。 class Camera_Connect_Object: #定义一个摄像头类 def __init__(self,D_addr_port=["",8880]): #类的构造函数，当创建了这个类的实例时就会调用该方法 self.resolution=[640,480] #self 代表类的实例 self.addr_port=D_addr_port #绑定的端口和ip self.src=888+15 #双方确定传输帧数，（888）为校验值 self.interval=0 #图片播放时间间隔 self.img_fps=15 #每秒传输多少帧数 def Socket_Connect(self): self.client=socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 选择TCP连接方式 self.client.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) # 操作系统会在服务器socket被关闭或服务器进程终止后马上释放该服务器的端口，否则操作系统会保留几分钟该端口。 self.client.connect(self.addr_port) #连接对应的端口位置，包括IP和端口，传输给客户端 print("IP is %s:%d" % (self.addr_port[0],self.addr_port[1])) #输入连接的IP和端口号 def RT_Image(self): self.name=self.addr_port[0]+" Camera" self.client.send(struct.pack("lhh", self.src, self.resolution[0], self.resolution[1])) #按照格式打包发送帧数和分辨率 while(1): info=struct.unpack("lhh",self.client.recv(8)) #将接收到的8位二进制解包 buf_size=info[0] #获取读的图片总长度 if buf_size: try: self.buf=b"" #代表bytes类型 temp_buf=self.buf while(buf_size): #读取每一张图片的长度 temp_buf=self.client.recv(buf_size) buf_size-=len(temp_buf) self.buf+=temp_buf #获取图片 data = numpy.fromstring(self.buf, dtype='uint8') #按uint8转换为图像矩阵 self.image = cv2.imdecode(data, 1) #图像解码 cv2.imshow(self.name, self.image) #展示图片 except: pass; finally: if(cv2.waitKey(10)==27): #每10ms刷新一次图片，按‘ESC’（27）退出 self.client.close() cv2.destroyAllWindows() break def Get_Data(self,interval): showThread=threading.Thread(target=self.RT_Image) showThread.start() if __name__ == '__main__': camera=Camera_Connect_Object() camera.addr_port[0]=input("Please input IP:") camera.addr_port=tuple(camera.addr_port) camera.Socket_Connect() camera.Get_Data(camera.interval)

评论收藏

内容反馈