用python實現FTP檔案傳輸，包括伺服器端和客戶端，要求

（1）客戶端訪問伺服器端要有一個驗證功能

（2）可以有多個客戶端訪問伺服器端

（3）可以對重名檔案重新上傳或下載

FTP（File Transfer Protocol，檔案傳輸協議） 是 TCP/IP 協議組中的協議之一。FTP協議包括兩個組成部分，其一為FTP伺服器，其二為FTP客戶端。其中FTP伺服器用來儲存檔案，使用者可以使用FTP客戶端通過FTP協議訪問位於FTP伺服器上的資源。在開發網站的時候，通常利用FTP協議把網頁或程式傳到Web伺服器上。它工作在TCP 模型的第四層， 即應用層， 使用 TCP 傳輸而不是 UDP， 客戶在和伺服器建立連線前要經過一個“三次握手”的過程， 保證客戶與伺服器之間的連線是可靠的， 而且是面向連線， 為資料傳輸提供可靠保證。

伺服器端

首先要實現對訪問客戶端的驗證，在本地建立一個數據庫檔案，將客戶端的使用者名稱和密碼寫入到檔案中。這樣每次訪問時都將使用者名稱和密碼和資料庫中存在的進行匹配，實現驗證功能。這裡對密碼進行了MD5加密，保證了密碼不會輕易洩露。

{"username": "ahpu","password": "96e79218965eb72c92a549dd5a330112","limitsize": 10240000,"homepath": "D:\\FTP\\home\\ahpu"}

登入驗證功能具體實現

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author : hgh
import hashlib
import os
import json
from conf import settings
class User_auth(object):
 def auth(self,account_info):
 """
 #此功能是進行使用者的登入資訊驗證，如果登入成功，那麼返回使用者對應的http狀態碼及賬戶資訊,否則只返回http狀態碼
 :param account_info: 使用者的賬戶資訊：使用者名稱，密碼
 :return:
 """
 name = account_info.split(":")[0]
 pwd = account_info.split(":")[1]
 pwd = self.hash(pwd.encode()) # 將使用者名稱的密碼轉換成hash值
 user_db_file = settings.DATABASE + r"\%s.db" % name # 也可以寫成 "\\%s.db" or "/%s.db"
 if os.path.isfile(user_db_file): # 輸入的使用者名稱存在
  with open(user_db_file) as fr:
  user_db_info = json.loads(fr.read()) # or josn.load(fr)
  if pwd == user_db_info['password']:
   return "200",user_db_info # 確定，客戶請求成功
  else:
   return "403.11",None # 密碼錯誤
 else:
  return "400",None # 使用者名稱不存在，使用者認證失敗
 def hash(self,pwd):
 """
  使用者的密碼加密
 :param self:
 :param pwd: 使用者密碼
 :return:
 """
 m = hashlib.md5()
 m.update(pwd)
 return m.hexdigest()

然後是重傳功能實現

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author : hgh
import hashlib
import sys
class Breakpoint(object):
 # 本模組確認使用者上傳或下載的檔案是否存在，如果存在是否需要斷點續傳
 def transfer(self,filename,has_send_size,total_size,conn):
 """
 進行續傳
 :param filename:
 :param has_send_size: 已經發送的檔案大小
 :param total_size: 需要傳輸檔案總大小
 :param conn: 客戶端和服務端進行資料交換的介面
 :return:
 """
 with open(filename,'rb') as fr:
  fr.seek(has_send_size) # 定位到續傳的位置
  print("has_send","total",total_size)
  m = hashlib.md5()
  if has_send_size == total_size:
  self.progress_bar(has_send_size,total_size)
  for line in fr:
  conn.send(line)
  m.update(line)
  has_send_size += len(line)
  # self.progress_bar(has_send_size,total_size)
 return m.hexdigest()
 def progress_bar(self,total_size):
 bar_width = 50 # 進度條長度
 process = has_send_size / total_size
 send_bar = int(process * bar_width + 0.5) # 傳送的資料佔到的進度條長度，四捨五入取整
 sys.stdout.write("#" * send_bar + "=" * (bar_width - send_bar) + "\r") # 注意點：只能這麼寫才能達到要求
 sys.stdout.write("\r%.2f%%: %s%s" % (process * 100,"#" * send_bar,"=" * (bar_width - send_bar))) # 注意點：在pycharm中要加\r\n
         # 用sublime只要\r否則換行
 sys.stdout.flush()

伺服器端程式碼

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author : hgh
import sys
import os
from core import socket_server
path = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
sys.path.append(path)
if __name__ == "__main__":
 HOST,PORT = "192.168.40.1",9901
 server = socket_server.socketserver.ThreadingTCPServer((HOST,PORT),socket_server.MyTCPServer)
 server.serve_forever()

客戶端

 #!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author : hgh
from core import socket_client
import os
import sys
path = os.path.dirname(os.path.abspath(__file__))
sys.path.append(path)
if __name__ == "__main__":
 host,port = "192.168.40.1",9901
 myClient = socket_client.MySocketClient(host,port)
 myClient.start()

由於篇幅有限，具體伺服器端及客戶端程式碼都放在了github上，地址https://github.com/heguohang/FTP-python

總結

到此這篇關於python實現FTP檔案傳輸（伺服器端和客戶端） 的文章就介紹到這了,更多相關python ftp 檔案傳輸內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！