重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
这篇文章将为大家详细讲解有关python传送文件的方法,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
让客户满意是我们工作的目标,不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户,将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴,公司提供的服务项目有:域名注册、虚拟空间、营销软件、网站建设、巴里坤哈萨克网站维护、网站推广。
在python中传送文件的方法:1、将报头转换成字符串【json.dumps】, 再将字符串的长度打包;2、发送报头长度和报头内容,然后放真实内容;3、将报头长度解压,得到头部信息的大小,再接收头部信息,反序列化即可
思路:
# 先将报头转换成字符串(json.dumps), 再将字符串的长度打包
# 发送报头长度,发送报头内容,最后放真实内容
# 报头内容包括文件名,文件信息,报头
# 接收时:先接收4个字节的报头长度,
# 将报头长度解压,得到头部信息的大小,在接收头部信息, 反序列化(json.loads)
# 最后接收真实文件
服务端
#!/usr/bin/env python # -*- coding: utf-8 -*- # @File : 文件传输-服务端.py # @Software: PyCharmfrom socket import *import structimport jsonimport ostcp_server = socket(AF_INET, SOCK_STREAM)ip_port = (('127.0.0.1', 8080))buffsize = 1024 # 端口的重复利用 tcp_server.setsockopt(SOL_SOCKET, SO_REUSEPORT, 1)tcp_server.bind(ip_port)tcp_server.listen(5)print('还没有人链接') while True: '''链接循环''' conn, addr = tcp_server.accept() print('链接人的信息:', addr) while True: if not conn: print('客户端链接中断') break '''通信循环''' filemesg = input('请输入要传送的文件名加后缀>>>').strip() filesize_bytes = os.path.getsize(filemesg) # 得到文件的大小,字节 filename = 'new' + filemesg dirc = { 'filename': filename, 'filesize_bytes': filesize_bytes, } head_info = json.dumps(dirc) # 将字典转换成字符串 head_info_len = struct.pack('i', len(head_info)) # 将字符串的长度打包 # 先将报头转换成字符串(json.dumps), 再将字符串的长度打包 # 发送报头长度,发送报头内容,最后放真是内容 # 报头内容包括文件名,文件信息,报头 # 接收时:先接收4个字节的报头长度, # 将报头长度解压,得到头部信息的大小,在接收头部信息, 反序列化(json.loads) # 最后接收真实文件 conn.send(head_info_len) # 发送head_info的长度 conn.send(head_info.encode('utf-8')) # 发送真是信息 with open(filemesg, 'rb') as f: data = f.read() conn.sendall(data) print('发送成功')
客户端
#!/usr/bin/env python # -*- coding: utf-8 -*- # @File : 文件传输_客户端.py # @Software: PyCharmfrom socket import * import struct import json import os import sys import time from 进度条 import process_bar tcp_client = socket(AF_INET, SOCK_STREAM) ip_port = (('127.0.0.1', 8080)) buffsize = 1024 tcp_client.connect_ex(ip_port) print('等待链接服务端') while True: head_struct = tcp_client.recv(4) # 接收报头的长度, if head_struct: print('已连接服务端,等待接收数据') head_len = struct.unpack('i', head_struct)[0] # 解析出报头的字符串大小 data = tcp_client.recv(head_len)# 接收长度为head_len的报头内容的信息 (包含文件大小,文件名的内容) head_dir = json.loads(data.decode('utf-8')) filesize_b = head_dir['filesize_bytes'] filename = head_dir['filename'] # 接受真的文件内容 recv_len = 0 recv_mesg = b'' old = time.time() f = open(filename, 'wb') while recv_len < filesize_b: percent = recv_len / filesize_b process_bar(percent) if filesize_b - recv_len > buffsize: recv_mesg = tcp_client.recv(buffsize) f.write(recv_mesg) recv_len += len(recv_mesg) else: recv_mesg = tcp_client.recv(filesize_b - recv_len) recv_len += len(recv_mesg) f.write(recv_mesg) print(recv_len, filesize_b) now = time.time() stamp = int(now - old) print('总共用时%ds' % stamp) f.close()
进度条
#!/usr/bin/env python # -*- coding: utf-8 -*- # @File : 进度条.py # @Software: PyCharm import sys import time def process_bar(precent, width=50): use_num = int(precent*width) space_num = int(width-use_num) precent = precent*100 # 第一个和最后一个一样梯形显示, 中间两个正确,但是在python2中报错 # print('[%s%s]%d%%'%(use_num*'#', space_num*' ',precent)) # print('[%s%s]%d%%'%(use_num*'#', space_num*' ',precent), end='\r') print('[%s%s]%d%%'%(use_num*'#', space_num*' ',precent),file=sys.stdout,flush=True, end='\r') # print('[%s%s]%d%%'%(use_num*'#', space_num*' ',precent),file=sys.stdout,flush=True) #for i in range(21): # precent = i/20 # process_bar(precent) # time.sleep(0.2)
关于python传送文件的方法就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。