溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
用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", has_send_size, "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, has_send_size, 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 文件傳輸內容請搜索億速云以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持億速云！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
