Python Socket传输大文件:基于文件大小预知与循环接收的实现
本文介绍使用Python Socket库传输大文件的完整方案。针对Socket单次发送数据量的限制,核心思路是先发送包含文件元数据的头部信息(如文件名、大小),随后客户端根据文件大小计算接收次数,通过循环接收并拼接数据的方式完成大文件传输。文章提供了服务器端与客户端的具体代码示例,展示了如何处理头部握手及数据分块接收逻辑。
大文件传输的核心思路
核心思路:
在使用Socket进行文件传输时,受限于网络缓冲区和单次发送大小的限制,直接一次性发送大文件往往会导致数据截断或传输失败。因此,处理大文件的标准做法是采取“先头后体”的策略:服务器端首先将文件的元数据(如文件名、大小等)封装成头部信息发送给客户端;客户端接收到头部后,解析出文件总大小,随后进入循环接收模式,持续读取数据直到收满指定大小为止。
具体代码实现如下:
一、服务器端实现
服务器端代码实现
#!/usr/bin/env python
#-*- coding:utf-8 -*-
#environment:2.7
import os,json,time,socket
sk = socket.socket()
ip_port=('127.0.0.1',9600)
sk.bind(ip_port)
sk.listen(5)
file_path = '/root/update/123.txt'
file_name = file_path.rsplit(os.sep,1)[1]
file_size = os.path.getsize(file_path) #获取文件内容大小
#发送给客户端的头部信息
header_data = {
'file_name': file_name,
'file_size': file_size,
'date': time.strftime('%Y-%m-%d %X',time.localtime()),
'charset': 'utf-8'
}
while True:
conn, addr = sk.accept()
print("%s:%s is connect"% addr)
request_data = conn.recv(1024)
print(request_data)
# 把头部内容发送过去
conn.send(json.dumps(header_data))
request_data1 = conn.recv(1024)
print(request_data1)
f = open(file_path,'r')
content = f.read()
#发送文件内容
conn.sendall(content)
conn.close()
二、客户端实现
客户端代码实现
#!/usr/bin/env python
#-*- coding:utf-8 -*-
#environment:2.7
import socket,json
while True:
sk = socket.socket()
ip_port = ('127.0.0.1',9600)
sk.connect(ip_port)
user_input = raw_input('>>>:').strip()
if len(user_input) == 0:continue
if user_input == 'q':break
sk.send(user_input)
server_head_msg = json.loads(sk.recv(1024))
print(server_head_msg)
#文件名res_name,文件大小res_size
res_name = server_head_msg['file_name']
res_size = server_head_msg['file_size']
sk.send('已经收到头部信息,你可以发送数据了')
#下面是循环接收文件内容的部分
num = res_size/1024.0
if num != int(num):
num = int(num) +1
else:
num = int(num)
for i in range(num):
content = sk.recv(1024)
print(content)
补充说明:客户端在接收服务器发送的文件内容时,同样需要依据每次接收的数据量进行判断和处理。其基本逻辑与上述思路一致,即通过循环累加接收到的数据长度,直到达到文件总大小。具体实现参考以下代码片段。
数据接收逻辑补充
res = ''
recive_size = 0
while recive_size <= res_size:
data = sk.recv(1024)
recive_size += len(data)
res += data
else:
print(res)
print('done'.center(40,'='))
以上即为使用Python Socket进行大文件分发的完整实现方法,供各位开发者参考与实践。
免责声明:本文内容仅供参考,不代表本站观点。转载或引用请注明出处。









