python利用socket实现udp文件传输功能
作者:_在水一方 时间:2023-07-07 14:15:33
本文实例为大家分享了UDP实现文件传输的具体代码,供大家参考,具体内容如下
tcp进行文件传输看这里–python实现TCP文件接发
这里实现的接收方一直接收,发送方每次发送一个文件,方便我在其他函数中调用发送文件。
使用udp 容易出现丢包现象需要处理
要注意 tcp 和udp的套接字不一样
# udp:
udp_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
# tcp
tcp_socketr = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
1、发送
# import socket
# import tqdm
# import os
# import threading
#
# # 由客户端向服务器传数据,文件
import threading
import socket
import tqdm
import os
import cv2
from time import ctime, sleep
def send(address, filename):
# 传输数据间隔符
SEPARATOR = '<SEPARATOR>'
# 服务器信息
host, port = address
# 文件缓冲区
Buffersize = 4096*10
# 传输文件名字
filename = filename
# 文件大小)
file_size = os.path.getsize(filename)
# 创建socket链接
s = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
print(f'服务器连接中{host}:{port}')
s.connect((host, port))
print('与服务器连接成功')
# 发送文件名字和文件大小,必须进行编码处理
# s.sendto(f'{filename}{SEPARATOR}{file_size}'.encode(), ("127.0.0.1", 1234))
s.send(f'{filename}{SEPARATOR}{file_size}'.encode('utf-8'))
# 文件传输
progress = tqdm.tqdm(range(file_size), f'发送{filename}', unit='B', unit_divisor=1024)
with open(filename, 'rb') as f:
# 读取文件
for _ in progress:
bytes_read = f.read(Buffersize)
# print(bytes_read)
if not bytes_read:
print('exit退出传输,传输完毕!')
s.sendall('file_download_exit'.encode('utf-8'))
break
# sendall 确保络忙碌的时候,数据仍然可以传输
s.sendall(bytes_read)
progress.update(len(bytes_read))
sleep(0.001)
# 关闭资源
s.close()
if __name__ == '__main__':
address = ('127.0.0.1', 1234)
# host = '127.0.0.1'
# port = 1234
filename = input('请输入文件名:')
t = threading.Thread(target=send, args=(address, filename))
t.start()
# received(address, filename)
2、接收
import socket
import tqdm
import os
import threading
# 使用UDP传输视频,全双工,但只需一方接,一方收即可
# 设置服务器的ip和 port
# 服务器信息
# sever_host = '127.0.0.1'
# sever_port =1234
def recvived(address, port):
# 传输数据间隔符
SEPARATOR = '<SEPARATOR>'
# 文件缓冲区
Buffersize = 4096*10
while True:
print('准备接收新的文件...')
udp_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
udp_socket.bind((address, port))
recv_data = udp_socket.recvfrom(Buffersize)
recv_file_info = recv_data[0].decode('utf-8') # 存储接收到的数据,文件名
print(f'接收到的文件信息{recv_file_info}')
c_address = recv_data[1] # 存储客户的地址信息
# 打印客户端ip
print(f'客户端{c_address}连接')
# recv_data = udp_socket.recv()
# 接收客户端信息
# received = udp_socket.recvfrom(Buffersize).decode()
filename ,file_size = recv_file_info.split(SEPARATOR)
# 获取文件的名字,大小
filename = os.path.basename(filename)
file_size = int(file_size)
# 文件接收处理
progress = tqdm.tqdm(range(file_size), f'接收{filename}', unit='B', unit_divisor=1024, unit_scale=True)
with open('8_18_'+filename,'wb') as f:
for _ in progress:
# 从客户端读取数据
bytes_read = udp_socket.recv(Buffersize)
# 如果没有数据传输内容
# print(bytes_read)
if bytes_read == b'file_download_exit':
print('完成传输!')
print(bytes_read)
break
# 读取写入
f.write(bytes_read)
# 更新进度条
progress.update(len(bytes_read))
udp_socket.close()
if __name__ == '__main__':
# address = ("127.0.0.1", 1234)
port = 1234
address = "127.0.0.1"
t = threading.Thread(target=recvived, args=(address, port))
t.start()
# send(address)
来源:https://blog.csdn.net/JSSQSC/article/details/120041114
标签:python,udp,文件传输
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
让复杂导航设计变得简单
2008-01-07 11:50:00
![](https://img.aspxhome.com/file/UploadPic/20081/7/200817122654620s.jpg)
空间session失效过快的解决办法
2010-09-15 10:01:00
Python的Flask框架中SQLAlchemy使用时的乱码问题解决
2023-01-23 01:59:51
PHP类的特性实例分析
2024-05-03 15:49:46
PHP实现通过二维数组键值获取一维键名操作示例
2023-11-22 12:00:52
22个HTML5的初级技巧
2010-12-17 12:39:00
![](https://img.aspxhome.com/file/UploadPic/201012/17/01-40s.jpg)
php 深入理解strtotime函数的使用详解
2024-05-03 15:53:03
MySQL脏读幻读不可重复读及事务的隔离级别和MVCC、LBCC实现
2024-01-19 00:23:03
![](https://img.aspxhome.com/file/2023/8/71048_0s.png)
Python中一些深不见底的“坑”
2021-10-10 05:03:57
python hough变换检测直线的实现方法
2022-06-11 10:08:37
![](https://img.aspxhome.com/file/2023/3/109993_0s.png)
Python 200行代码实现一个滑动验证码过程详解
2022-08-24 18:24:35
python将视频转换为全字符视频
2023-08-08 21:01:02
![](https://img.aspxhome.com/file/2023/8/61748_0s.gif)
python库JsonSchema验证JSON数据结构使用详解
2023-02-14 16:24:27
企业网站FLASH引导页存在的意义
2008-06-04 11:09:00
微信小程序开发注意指南和优化实践(小结)
2024-04-17 10:38:05
![](https://img.aspxhome.com/file/2023/7/136217_0s.jpg)
Django-Rest-Framework 权限管理源码浅析(小结)
2021-11-02 06:18:49
![](https://img.aspxhome.com/file/2023/9/117319_0s.png)
PHP实现判断二叉树是否对称的方法
2023-06-28 13:24:10
python线程锁(thread)学习示例
2021-02-09 09:45:23
pyinstaller 3.6版本通过pip安装失败的解决办法(推荐)
2023-10-13 11:55:44
![](https://img.aspxhome.com/file/2023/0/117580_0s.png)
python 实现图片上传接口开发 并生成可以访问的图片url
2021-03-19 01:02:02
![](https://img.aspxhome.com/file/2023/6/92316_0s.jpg)