建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
創(chuàng)新互聯(lián)Python教程：python怎么傳送文件
在python中傳送文件的方法：1、將報頭轉(zhuǎn)換成字符串【json.dumps】， 再將字符串的長度打包；2、發(fā)送報頭長度和報頭內(nèi)容，然后放真實內(nèi)容；3、將報頭長度解壓，得到頭部信息的大小，再接收頭部信息，反序列化即可
專注于為中小企業(yè)提供成都網(wǎng)站設(shè)計、網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)服務,電腦端+手機端+微信端的三站合一,更高效的管理,為中小企業(yè)坪山免費做網(wǎng)站提供優(yōu)質(zhì)的服務。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動了上千余家企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設(shè)實現(xiàn)規(guī)模擴充和轉(zhuǎn)變。
思路:
# 先將報頭轉(zhuǎn)換成字符串(json.dumps), 再將字符串的長度打包
# 發(fā)送報頭長度,發(fā)送報頭內(nèi)容,最后放真實內(nèi)容
# 報頭內(nèi)容包括文件名,文件信息,報頭
# 接收時:先接收4個字節(jié)的報頭長度,
# 將報頭長度解壓,得到頭部信息的大小,在接收頭部信息, 反序列化(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:
'''鏈接循環(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('等待鏈接服務端')
while True:
head_struct = tcp_client.recv(4) # 接收報頭的長度,
if head_struct:
print('已連接服務端,等待接收數(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)推薦課程:Python進階視頻教程
網(wǎng)站標題：創(chuàng)新互聯(lián)Python教程：python怎么傳送文件
轉(zhuǎn)載來源：http://www.dlmjj.cn/article/cosdhop.html
