這篇文章將為大家詳細(xì)講解有關(guān)python如何實(shí)現(xiàn)ftp文件傳輸功能，小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

創(chuàng)新互聯(lián)專(zhuān)注于未央網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗(yàn)。 熱誠(chéng)為您提供未央營(yíng)銷(xiāo)型網(wǎng)站建設(shè)，未央網(wǎng)站制作、未央網(wǎng)頁(yè)設(shè)計(jì)、未央網(wǎng)站官網(wǎng)定制、成都微信小程序服務(wù)，打造未央網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供未央網(wǎng)站排名全網(wǎng)營(yíng)銷(xiāo)落地服務(wù)。

本文實(shí)例為大家分享了python實(shí)現(xiàn)ftp文件傳輸?shù)木唧w代碼，具體內(nèi)容如下

主要步驟可以分為以下幾步：

1.讀取文件名
2.檢測(cè)文件是否存在
3.打開(kāi)文件
4.檢測(cè)文件大小
5.發(fā)送文件大小和 md5值給客戶(hù)端
6.等客戶(hù)端確認(rèn)
7.開(kāi)始邊讀邊發(fā)數(shù)據(jù)

服務(wù)器端代碼：

import socket,os,time
import hashlib
 
server =socket.socket()
server.bind(('0.0.0.0',6666))
server.listen()
print("等待....")
while True:
 conn,addr = server.accept()
 print("new conn:",conn)
 while True:
 data = conn.recv(1024)
 if not data:
 print("client is disconnection")
 break
 cmd,filename = data.decode().split() #記錄指令和文件名
 print(filename)
 #判斷當(dāng)前目錄是否存在該文件，而且必須是文件，而不是目錄
 if os.path.isfile(filename):
 f = open(filename,'rb')
 #m = hashlib.md5() # 創(chuàng)建md5
 file_size = os.stat(filename).st_size #stat() 可以返回文件的大小值
 conn.send((str(file_size)).encode()) # 發(fā)送文件大小
 conn.recv(1024) #等待返回信息
 for line in f:
 # m.updata(line) 
 conn.send(line)
 #print("file md5",m.hexdigest()) #打印md5值
 f.close()

客戶(hù)端代碼：

# Author: zjt
import socket
 
client = socket.socket()
 
client.connect(("0.0.0.0",6666))
 
 
while True:
 cmd = input(">>>:").strip()
 
 if len(cmd)==0 :continue
 
 if cmd.startswith("get"):
 client.send(cmd.encode())
 server_response = client.recv(1024)
 print("server response: ",server_response)
 client.send(b"ready to recv file")
 
 # 開(kāi)始接收文件
 file_total_size = int(server_response.decode())
 received_size = 0 # 記錄接收文件的大小
 filename = cmd.split()[1]
 # 因?yàn)閮蓚€(gè)目錄一致，接收的文件名不能與原文件相同
 f = open(filename+".new","wb")
 while received_size < file_total_size:
 data = client.recv(1024)
 received_size += len(data)
 f.write(data)
 print("total：",file_total_size," present: ",received_size)
 else:
 print("file has received done!")
 f.close()
 
client.close()

用80M的文件傳輸測(cè)試，效果如下：

程序升級(jí)：

前面的代碼還沒(méi)添加md5進(jìn)行驗(yàn)證，現(xiàn)在對(duì)代碼進(jìn)行升級(jí)

服務(wù)器端代碼：

import socket,os,time
import hashlib
 
server =socket.socket()
server.bind(('0.0.0.0',8888))
server.listen()
print("等待....")
while True:
 conn,addr = server.accept()
 print("new conn:",conn)
 while True:
 data = conn.recv(1024)
 if not data:
 print("client is disconnection")
 break
 cmd,filename = data.decode().split() #記錄指令和文件名
 print(filename)
 #判斷當(dāng)前目錄是否存在該文件，而且必須是文件，而不是目錄
 if os.path.isfile(filename):
 f = open(filename,'rb')
 m = hashlib.md5() # 創(chuàng)建md5
 file_size = os.stat(filename).st_size #stat() 可以返回文件的大小值
 conn.send((str(file_size)).encode()) # 發(fā)送文件大小
 conn.recv(1024) #等待返回信息
 for line in f:
 m.update(line)
 conn.send(line)
 print("file md5",m.hexdigest()) #打印md5值
 
 f.close()
 conn.send(m.hexdigest().encode()) # 發(fā)送md5
 
 print("我真的已經(jīng)發(fā)過(guò)去了",m.hexdigest().encode())
 
 print("send done")
 
server.close()

客戶(hù)端代碼：

import socket
import hashlib
client = socket.socket()
client.connect(("0.0.0.0",8888))
while True:
 cmd = input(">>>:").strip()
 if len(cmd)==0 :continue
 if cmd.startswith("get"):
 client.send(cmd.encode())
 server_response = client.recv(1024)
 print("server response: ",server_response)
 client.send(b"ready to recv file")
 # 開(kāi)始接收文件
 file_total_size = int(server_response.decode())
 received_size = 0 # 記錄接收文件的大小
 filename = cmd.split()[1]
 # 因?yàn)閮蓚€(gè)目錄一致，接收的文件名不能與原文件相同
 f = open(filename+".new","wb")
 m = hashlib.md5()
 while received_size < file_total_size:
 data = client.recv(1024)
 received_size += len(data)
 m.update(data)
 f.write(data)
 #print("total：",file_total_size," present: ",received_size)
 else:
 new_file_md5 = m.hexdigest()
 print("client file md5:",new_file_md5)
 print("file has received done!")
 print("total：",file_total_size," present: ",received_size)
 f.close()
 sever_file_md5 = client.recv(1024)
 print("client file md5:",new_file_md5)
 print("server file md5:",sever_file_md5)
client.close()

兩個(gè)程序在linux 環(huán)境下運(yùn)行，結(jié)果如下：

可以看到傳輸后文件大小變大了一點(diǎn)點(diǎn)，而且md5前后值也不同，說(shuō)明文件傳輸發(fā)生了改變。

現(xiàn)在講程序在windows環(huán)境下運(yùn)行，結(jié)果如下：

此時(shí)可以看到windows上沒(méi)有問(wèn)題，文件大小相同，且md5值也一致。

原因分析：

之所以會(huì)發(fā)生這種情況，是因?yàn)樵趌inux上運(yùn)行時(shí)，最后一次傳輸文件與發(fā)送md5值的時(shí)候，發(fā)生可粘包，導(dǎo)致最后一次接收文件的時(shí)候，連同md5的數(shù)據(jù)一并發(fā)送了。而客戶(hù)端也當(dāng)作一條接收信息，全部接收了。所以客戶(hù)端出現(xiàn)沒(méi)有收到來(lái)自服務(wù)器端的md5值，多出來(lái)的那一點(diǎn)點(diǎn)，就是md5值的大小。

解決方法：

在接收文件的時(shí)候，判斷當(dāng)前剩余多少文件需要接收，如果大于1024，就接收1024大小的文件，否則就只接收剩下全部的文件，防止最后一次接收多余的數(shù)據(jù)。

只需要對(duì)客戶(hù)端代碼進(jìn)行修改，修改后代碼如下：

import socket
import hashlib
client = socket.socket()
client.connect(("0.0.0.0",8888))
while True:
 cmd = input(">>>:").strip()
 if len(cmd)==0 :continue
 if cmd.startswith("get"):
 client.send(cmd.encode())
 server_response = client.recv(1024)
 print("server response: ",server_response)
 client.send(b"ready to recv file")
 # 開(kāi)始接收文件
 file_total_size = int(server_response.decode())
 received_size = 0 # 記錄接收文件的大小
 filename = cmd.split()[1]
 f = open(filename+".new","wb")
 m = hashlib.md5()
 while received_size < file_total_size:
 #添加一次判斷，使最后一次剩多少就接收多少，避免發(fā)生粘包
 if file_total_size - received_size > 1024:
  size = 1024
 else: # 最后一次，剩多少收多少
  size = file_total_size - received_size
 data = client.recv(size)
 received_size += len(data)
 m.update(data)
 f.write(data)
 else:
 new_file_md5 = m.hexdigest() 
 print("client file md5:",new_file_md5)
 print("file has received done!")
 print("total：",file_total_size," present: ",received_size)
 print("下一句關(guān)閉文件")
 f.close()
 print("開(kāi)始接收md5 ") 
 sever_file_md5 = client.recv(1024)
 print("client file md5:",new_file_md5)
 print("server file md5:",sever_file_md5)
client.close()

關(guān)于“python如何實(shí)現(xiàn)ftp文件傳輸功能”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。

新聞名稱(chēng)：python如何實(shí)現(xiàn)ftp文件傳輸功能-創(chuàng)新互聯(lián)
地址分享：http://weahome.cn/article/dchjsp.html