立即學習:https://edu.csdn.net/course/play/24458/296245?utm_source=blogtoedu
1.課程目的:
?????? 實現客戶端輸入下載文件的命令,然后將命令發送給服務端,服務端再執行下載文件的命令,最后將執行下載文件命令后的結果返回給客戶端,客戶端進行接收,這樣就完成了一個簡單的文件下載功能。文件的上傳與下載類似,只是兩個相反的過程
?
2.知識點與關鍵點:
1)os模塊:可使用os.path.getsize(filename)來獲取指定文件的大小;
2)在服務端接收的命令,使用split命令將接收的命令的字符串分割,判斷第一個是‘get’還是‘put’,即判斷時下載文件還是上傳文件
?
3.完整代碼
'''
服務端
'''
import socket
import subprocess
import json
import struct
import os
server_dir = r'C:\Users\jinlin\Desktop\python_further_study\socket編程\文件的傳輸(上傳)\簡單版本\serve'phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
phone.bind(('127.0.0.1',8080))
phone.listen(5)
while True:#接收客戶端發送過來連接服務器請求res = phone.accept()conn,client_addr = reswhile True:try:#1接收客戶端發送過來的命令resv = conn.recv(1024)#2將接收到的結果進行分割,獲得命令以及文件名cmds = resv.decode('utf-8').split()#['get','a.txt']print('*'*50)#3處理命令,執行命令并且獲得命令得到的結果cmd = cmds[0]filename = cmds[1]total_size = os.path.getsize(r'%s/%s'%(server_dir,filename))#獲得文件的字節數大小#1)制作包含文件名和文件大小的文件頭,用字典實現headers_dict = {"filename":filename,"filedata":"2020/03/09","total_size":total_size}#2)將字典先序列化成驚悚字符串,再轉為bytes類型文件頭headers_json = json.dumps(headers_dict)#3)獲取bytes類型的長度headers_bytes = headers_json.encode('utf-8')headers_size = len(headers_bytes)#4)將bytes類型文件頭長度定制為固定長度的報頭header = struct.pack('i',headers_size)#5)向客戶端發送報頭conn.send(header)#6)向客戶端發送包含文件信息的字典conn.send(headers_bytes)#7)通過二進制只讀的方式打開文件,按行讀取文件并且發送給客戶端with open(filename,'rb') as fp:for line in fp:conn.send(line)except ConnectionResetError:breakconn.close()phone.close()
?
'''
客戶端
'''
#導入模塊
import socket
import struct
import json
client_dir = r'C:\Users\jinlin\Desktop\python_further_study\socket編程\文件的傳輸(上傳)\簡單版本\client'#1、設置phone套接字
phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#2、連接服務器(打電話),本地地址:127.0.0.1
phone.connect(('127.0.0.1',8080))#3、向服務器發送請求send(),發送的數據不能直接發送字符串,因為要傳送到物理層底層,因此需要轉換成二進制的bytes類型進行發送,只需:發送的數據.encode('utf-8')即可
while True:cmd = input("請輸入:")#向服務端發送下載文件的命令,get a.txt#修復客戶端發送空字符串而服務器卡在接收信息處的bug,continue表示跳出本次循環,重新開始下一次的循環if not cmd:continuephone.send(cmd.encode('utf-8'))#4、接收服務器返回來的數據recv()#1)先接收由服務器返回來的報頭,報頭是固定長度的,因此取前面4字節的數據即為報頭header = phone.recv(4)#返回的是一個對象#2)解析報頭,得到bytes類型的文件頭長度obj_truple = struct.unpack('i',header)#返回的是一個元組headers_bytes_size = obj_truple[0]#取元組第一個元素即為總字節數#3)接收bytes類型的文件頭數據headers_bytes = phone.recv(headers_bytes_size)#4)將bytes類型的文件頭數據反序列化成字典headers_json = headers_bytes.decode('utf-8')headers_dict = json.loads(headers_json)print(headers_dict)#5)從字典中取出字命令執行結果字節總長度total_size = headers_dict['total_size']filename = headers_dict['filename']#6)接收返回的數據with open(r'%s/%s'%(client_dir,filename), 'wb') as fp:recv_size = 0while recv_size < total_size:recv_line = phone.recv(1024)#接收小于1024bytes的數據fp.write(recv_line)recv_size += len(recv_line)print('文件總字節長為%s,已經下載了%s'%(total_size,recv_size))#5、關閉套接字phone
phone.close()
?
4.運行的結果:
...
客戶端結果
...
請輸入:get mn.png
{'filename': 'mn.png', 'filedata': '2020/03/09', 'total_size': 702935}
文件總字節長為702935,已經下載了6
文件總字節長為702935,已經下載了8
文件總字節長為702935,已經下載了237
文件總字節長為702935,已經下載了455
文件總字節長為702935,已經下載了686
文件總字節長為702935,已經下載了851
文件總字節長為702935,已經下載了946
文件總字節長為702935,已經下載了1113
文件總字節長為702935,已經下載了1339
文件總字節長為702935,已經下載了1387
文件總字節長為702935,已經下載了1847
文件總字節長為702935,已經下載了2009
.......
文件總字節長為702935,已經下載了702656
文件總字節長為702935,已經下載了702935
5.待改進
代碼的可讀性較差,可以通過函數以及面向對象來對其進行優化,增加其代碼的可讀性