您好,登錄后才能下訂單哦!
這篇文章將為大家詳細講解有關(guān)python傳送文件的方法,小編覺得挺實用的,因此分享給大家做個參考,希望大家閱讀完這篇文章后可以有所收獲。
在python中傳送文件的方法:1、將報頭轉(zhuǎn)換成字符串【json.dumps】, 再將字符串的長度打包;2、發(fā)送報頭長度和報頭內(nèi)容,然后放真實內(nèi)容;3、將報頭長度解壓,得到頭部信息的大小,再接收頭部信息,反序列化即可
思路:
# 先將報頭轉(zhuǎn)換成字符串(json.dumps), 再將字符串的長度打包
# 發(fā)送報頭長度,發(fā)送報頭內(nèi)容,最后放真實內(nèi)容
# 報頭內(nèi)容包括文件名,文件信息,報頭
# 接收時:先接收4個字節(jié)的報頭長度,
# 將報頭長度解壓,得到頭部信息的大小,在接收頭部信息, 反序列化(json.loads)
# 最后接收真實文件
服務(wù)端
#!/usr/bin/env python # -*- coding: utf-8 -*- # @File : 文件傳輸-服務(wù)端.py # @Software: PyCharmfrom socket import *import structimport jsonimport ostcp_server = socket(AF_INET, SOCK_STREAM)ip_port = (('127.0.0.1', 8080))buffsize = 1024 # 端口的重復(fù)利用 tcp_server.setsockopt(SOL_SOCKET, SO_REUSEPORT, 1)tcp_server.bind(ip_port)tcp_server.listen(5)print('還沒有人鏈接') while True: '''鏈接循環(huán)''' conn, addr = tcp_server.accept() print('鏈接人的信息:', addr) while True: if not conn: print('客戶端鏈接中斷') break '''通信循環(huán)''' filemesg = input('請輸入要傳送的文件名加后綴>>>').strip() filesize_bytes = os.path.getsize(filemesg) # 得到文件的大小,字節(jié) filename = 'new' + filemesg dirc = { 'filename': filename, 'filesize_bytes': filesize_bytes, } head_info = json.dumps(dirc) # 將字典轉(zhuǎn)換成字符串 head_info_len = struct.pack('i', len(head_info)) # 將字符串的長度打包 # 先將報頭轉(zhuǎn)換成字符串(json.dumps), 再將字符串的長度打包 # 發(fā)送報頭長度,發(fā)送報頭內(nèi)容,最后放真是內(nèi)容 # 報頭內(nèi)容包括文件名,文件信息,報頭 # 接收時:先接收4個字節(jié)的報頭長度, # 將報頭長度解壓,得到頭部信息的大小,在接收頭部信息, 反序列化(json.loads) # 最后接收真實文件 conn.send(head_info_len) # 發(fā)送head_info的長度 conn.send(head_info.encode('utf-8')) # 發(fā)送真是信息 with open(filemesg, 'rb') as f: data = f.read() conn.sendall(data) print('發(fā)送成功')
客戶端
#!/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('等待鏈接服務(wù)端') while True: head_struct = tcp_client.recv(4) # 接收報頭的長度, if head_struct: print('已連接服務(wù)端,等待接收數(shù)據(jù)') head_len = struct.unpack('i', head_struct)[0] # 解析出報頭的字符串大小 data = tcp_client.recv(head_len)# 接收長度為head_len的報頭內(nèi)容的信息 (包含文件大小,文件名的內(nèi)容) head_dir = json.loads(data.decode('utf-8')) filesize_b = head_dir['filesize_bytes'] filename = head_dir['filename'] # 接受真的文件內(nèi)容 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)
關(guān)于python傳送文件的方法就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學(xué)到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。