當前位置：首頁 > 编程语言 > python >内容正文

python

python第四十一天---作业:简单FTP

發布時間：2025/7/14 python 19 豆豆

生活随笔收集整理的這篇文章主要介紹了 python第四十一天---作业:简单FTP 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

作業要示：

開發簡單的FTP：
1. 用戶登陸
2. 上傳/下載文件
3. 不同用戶家目錄不同
4. 查看當前目錄下文件
5. 充分使用面向對象知識

?REDMAE

服務端

servers/

　　　　bin/

registration.py

socket_server.py

1 #！usr/bin/env python 2 #-*-coding:utf-8-*- 3 # Author calmyan 4 import socket,os,json 5 import sys 6 BASE_DIR=os.path.dirname(os.path.dirname(os.path.abspath(__file__)))#獲取相對路徑轉為絕對路徑賦于變量 7 sys.path.append(BASE_DIR)#增加環境變量 8 9 from core.server_class import listen_func 10 s=socket.socket()#定義 11 s.bind(('localhost',9000))#綁定要監聽的端口 12 s.listen(5)#對列5 13 print('正在監聽中') 14 listen_func(s)

cfg/

config.py

1 #！usr/bin/env python 2 #-*-coding:utf-8-*- 3 # Author calmyan 4 import os ,sys 5 BASE_DIR=os.path.dirname(os.path.dirname(os.path.abspath(__file__)))#獲取相對路徑轉為絕對路徑賦于變量 6 sys.path.append(BASE_DIR)#增加環境變量 7 8 9 USER_DIR=BASE_DIR+'\db\\user_file\\'#定義用戶目錄文件路徑變量 10 11 USER_FILE=BASE_DIR+'\db\\user_names'#定義用戶文件路徑變量 View Code

core/

server_class.py

1 #！usr/bin/env python 2 #-*-coding:utf-8-*- 3 # Author calmyan 4 import socket,os,json,sys,pickle 5 6 BASE_DIR=os.path.dirname(os.path.dirname(os.path.abspath(__file__)))#獲取相對路徑轉為絕對路徑賦于變量 7 sys.path.append(BASE_DIR)#增加環境變量 8 9 from cfg import config 10 11 12 #用戶名檢測函數 13 def open_file_list(name,pas):#傳入當前類 14 with open(config.USER_FILE,'r',encoding='utf-8') as f: 15 data=eval(f.readline()) 16 if name in data and pas==data[name]: 17 return True 18 else: 19 return False 20 21 22 #連接類 23 class socket_server(object): 24 '''連接類''' 25 file_path=config.USER_DIR#用戶路經變量 26 def __init__(self,data,conn):#傳入用戶名,密碼 27 self.DATA=data 28 self.conn=conn 29 30 31 def show_process(self,lens): 32 received_size=0#定義大小 33 current_percent=0#當前大小百分比 34 while received_size<lens: 35 if int((received_size/lens)*100)>current_percent: 36 print('#',end='',flush=True) 37 current_percent=int((received_size/lens)*100) 38 new_size=yield 39 received_size+=new_size 40 41 def ret_l(self): 42 ret=socket_server.login(self.DATA["name"],self.DATA['pwd'],self.conn)#用戶名檢測 43 return ret 44 def open_f(self,ret):#打開目錄 45 file_dir=os.path.join(socket_server.file_path,ret['data']['user'])#用戶目錄 46 file_name=os.listdir(file_dir)#目錄文件列表 47 f=file_dir+self.DATA['filename']##上傳的文件名 48 return file_dir,file_name,f#返回 49 50 def ls_file(self,data):#查看文件 51 self.conn.send(json.dumps(data[1]).encode()) 52 53 def send_file(self,data): 54 55 if self.DATA['filename'] in data[1]: 56 f=data[0]+'/'+self.DATA['filename'] 57 file_obj=open(f,"rb")#打開文件 58 name=file_obj.name.split('/')[-1]#文件名 59 sez=os.path.getsize(f)#獲取文件大小 60 print(sez) 61 data_header={ 62 "action":"put", 63 "filename":name, 64 "size":sez 65 } 66 self.conn.send(json.dumps(data_header).encode())#用json 序列化后,發送相關信息 67 for line in file_obj: 68 self.conn.send(line)#發送數據 69 70 elif self.DATA['filename'].isdigit(): 71 num=int(self.DATA['filename'])#轉為數字 72 try: 73 f=data[0]+'/'+data[1][num]# 74 file_obj=open(f,"rb")#打開文件 75 name=file_obj.name.split('/')[-1]#文件名 76 sez=os.path.getsize(f)#獲取文件大小 77 print(sez) 78 data_header={ 79 "action":"put", 80 "filename":name, 81 "size":sez 82 } 83 self.conn.send(json.dumps(data_header).encode())#用json 序列化后,發送相關信息 84 for line in file_obj: 85 self.conn.send(line)#發送數據 86 self.conn.send(json.dumps(f).encode())#發送文件 87 except Exception as e: 88 data={'filename':False} 89 self.conn.send(json.dumps(data).encode()) 90 else: 91 data={'filename':False} 92 self.conn.send(json.dumps(data).encode()) 93 def put_file(self,data):#上傳文件 94 file_obj=open(data[2],'wb')#打開新建這個文件 95 rece_size=0#定義文件大小值 96 #prten=socket_server.show_process(self.DATA["size"]) 97 #prten.__next__() 98 while rece_size<self.DATA["size"]:#小于接收的文件大小時, 99 recv_data=self.conn.recv(4096) 100 file_obj.write(recv_data)#寫入文件 101 rece_size+=len(recv_data)#增加文件大小計算 102 103 else: 104 print("文件[%s]接收完畢!"%self.DATA["filename"]) 105 file_obj.flush() 106 file_obj.close()#關閉文件 107 108 109 @staticmethod 110 def login(name,pas,conn):#用戶檢測函數 111 try: 112 if open_file_list(name,pas): 113 tag=True 114 error='' 115 datas={'user':name} 116 data={'mag':'用戶認證通過','tag':True} 117 print(json.dumps(data).encode()) 118 conn.send(json.dumps(data).encode()) 119 else: 120 raise Exception('\033[41;1m用戶名或密碼錯誤\033[0m' %name) 121 except Exception as e: 122 tag=False 123 error=str(e) 124 datas='' 125 data={'mag':'用戶或密碼錯誤','tag':False} 126 print('發送數據%s'%data) 127 conn.send(json.dumps(data).encode()) 128 return {'tag':tag,'error':error,'data':datas} 129 130 #監聽函數 131 def listen_func(s): 132 while True: 133 conn,client_addr=s.accept()#端口監聽中....返回兩個值 ,聯接編號對象 , ip 134 print('獲取到新連接:',client_addr) 135 while True: 136 data=conn.recv(4096)#接收數據指令 137 print('接收的數據:',data) 138 data= json.loads(data.decode())#反序列 139 if len(data)==0: 140 break 141 if data['action']=='user':#如果是用戶名,進行認證\ 142 serv=socket_server(data,conn) 143 ret=serv.ret_l() 144 if ret['tag']: 145 pass 146 else: 147 continue 148 149 print(data) 150 if data['action']=="put":#如果接收的字典中是put,就是進行接收 151 serv=socket_server(data,conn) 152 serv.put_file(serv.open_f(ret))#調對象方法 153 elif data['action']=='get':#下載 154 serv=socket_server(data,conn)#實例化 155 serv.send_file(serv.open_f(ret))#調用方法 156 elif data['action']=='ls':#查看 157 serv=socket_server(data,conn) 158 serv.ls_file(serv.open_f(ret)) 159 continue View Code

客戶端

clients/

bin/

socket_client.py

1 #！usr/bin/env python 2 #-*-coding:utf-8-*- 3 # Author calmyan 4 5 import socket,os,json,sys 6 BASE_DIR=os.path.dirname(os.path.dirname(os.path.abspath(__file__)))#獲取相對路徑轉為絕對路徑賦于變量 7 sys.path.append(BASE_DIR)#增加環境變量 8 from core.client_func import user_pwd 9 #from core.client_func import show_process 10 from cfg import config 11 12 #進度條 13 def show_process(lens): 14 received_size=0#定義大小 15 current_percent=0#當前大小百分比 16 while received_size<lens: 17 if int((received_size/lens)*100)>current_percent: 18 print('#',end='',flush=True) 19 current_percent=int((received_size/lens)*100) 20 new_size=yield 21 received_size+=new_size 22 23 24 client=socket.socket() 25 client.connect(('localhost',9000)) 26 while True: 27 data_d=user_pwd(client) 28 if data_d['tag']:#運行#用戶名登陸成功 29 while True: 30 print('''=====指令提示==== 31 查看目錄文件: ls 32 下載文件: get 文件名或文件編號如: get test.txt 或 get 1 33 上傳方件: put 路徑/文件名如 put e:/test.txt 34 退出：exit 35 ''') 36 cho=input('指令 >>:').strip() 37 if len(cho)==0:continue 38 if cho=='exit':exit()#退出指令 39 cmd_list=cho.split() 40 if cmd_list[0]=='put':#如果等于下載指令 41 if len(cmd_list)==1: 42 print('沒有輸入相關文件名') 43 continue 44 filename=cmd_list[1] 45 if os.path.isfile(filename):#如果文件存在 46 file_obj=open(filename,"rb")#打開文件 47 name=file_obj.name.split('/')[-1]#文件名 48 #name=filename.split("\\")[-1]#文件名 49 sez=os.path.getsize(filename)#獲取文件大小 50 data_header={ 51 "action":"put", 52 "filename":name, 53 "size":sez 54 } 55 client.send(json.dumps(data_header).encode())#用json 序列化后,發送相關信息 56 57 print("文件[%s]發送中...."%data_header["filename"]) 58 for line in file_obj: 59 client.send(line) 60 else: 61 print("文件[%s]發送完畢!"%data_header["filename"]) 62 else: 63 print('該文件不存在') 64 continue 65 elif cmd_list[0]=='get':#如查等于上傳指令 66 if len(cmd_list)==1: 67 print('沒有輸入相關文件名') 68 continue 69 filename=cmd_list[1] 70 print(filename) 71 data_header={ 72 "action":"get", 73 "filename":filename, 74 "size":'' 75 } 76 client.send(json.dumps(data_header).encode())#用json 序列化后,發送相關信息 77 datas=client.recv(4096)#接收數據指令 78 data_l= json.loads(datas.decode())#反序列 79 if not data_l['filename']: 80 print('文件不存在') 81 continue 82 file_dir=config.USER_DIR+data_l["filename"] 83 file_obj=open(file_dir,'wb')#打開新建這個文件 84 rece_size=0#定義文件大小值 85 prten=show_process(data_l["size"]) 86 prten.__next__() 87 while rece_size<data_l["size"]:#小于接收的文件大小時, 88 recv_data=client.recv(4096) 89 file_obj.write(recv_data)#寫入文件 90 rece_size+=len(recv_data)#增加文件大小計算 91 try: 92 prten.send(len(recv_data)) 93 except StopIteration as e: 94 print('100%') 95 96 else: 97 print("文件[%s]接收完畢!"%data_l["filename"]) 98 file_obj.flush() 99 file_obj.close()#關閉文件 100 elif cmd_list[0]=='ls':#查看目錄文件 101 data_header={ 102 "action":"ls", 103 "filename":'', 104 "size":'' 105 } 106 client.send(json.dumps(data_header).encode())#用json 序列化后,發送相關信息 107 datas=client.recv(4096)#接收數據指令 108 data_l= json.loads(datas.decode())#反序列 109 for k,v in enumerate(data_l): 110 print('編號: %s 文件名:%s'%(k,v)) 111 112 else: 113 print(data_d['mag']) View Code

cfg/

config.py

1 #！usr/bin/env python 2 #-*-coding:utf-8-*- 3 # Author calmyan 4 5 import os ,sys 6 BASE_DIR=os.path.dirname(os.path.dirname(os.path.abspath(__file__)))#獲取相對路徑轉為絕對路徑賦于變量 7 sys.path.append(BASE_DIR)#增加環境變量 8 9 10 USER_DIR=BASE_DIR+'\home\\'#定義用戶目錄文件路徑變量

core/

client_func.py

1 #！usr/bin/env python 2 #-*-coding:utf-8-*- 3 # Author calmyan 4 import socket,os,json,sys 5 #用戶名登陸函數 6 def user_pwd(client): 7 user_=input('請輸入用戶名:').strip() 8 pwd_=input('請輸入密碼:').strip() 9 data_header={ 10 "action":"user", 11 "name":user_, 12 "pwd":pwd_ 13 } 14 client.send(json.dumps(data_header).encode())#用json 序列化后,發送相關信息 15 data=client.recv(4096)#接收數據指令 16 data_s=json.loads(data.decode('utf-8'))#反序列 17 return data_s 18 19 20 #進度條 21 def show_process(lens): 22 received_size=0#定義大小 23 current_percent=0#當前大小百分比 24 while received_size<lens: 25 if int((received_size/lens)*100)>current_percent: 26 print('#',end='',flush=True) 27 current_percent=int((received_size/lens)*100) 28 new_size=yield 29 received_size+=new_size View Code

轉載于:https://www.cnblogs.com/uge3/p/6993604.html

總結

以上是生活随笔為你收集整理的python第四十一天---作业:简单FTP的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： q标签，短文本引用；blockquote
下一篇： SQL语言方方面面