立即學習:https://edu.csdn.net/course/play/24458/296245?utm_source=blogtoedu

1.課程目的：

?????? 實現(xiàn)客戶端輸入下載文件的命令，然后將命令發(fā)送給服務端，服務端再執(zhí)行下載文件的命令，最后將執(zhí)行下載文件命令后的結果返回給客戶端，客戶端進行接收，這樣就完成了一個簡單的文件下載功能。文件的上傳與下載類似，只是兩個相反的過程

?

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:#接收客戶端發(fā)送過來連接服務器請求res = phone.accept()conn,client_addr = reswhile True:try:#1接收客戶端發(fā)送過來的命令resv = conn.recv(1024)#2將接收到的結果進行分割，獲得命令以及文件名cmds = resv.decode('utf-8').split()#['get','a.txt']print('*'*50)#3處理命令，執(zhí)行命令并且獲得命令得到的結果cmd = cmds[0]filename = cmds[1]total_size = os.path.getsize(r'%s/%s'%(server_dir,filename))#獲得文件的字節(jié)數(shù)大小#1）制作包含文件名和文件大小的文件頭，用字典實現(xiàn)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)向客戶端發(fā)送報頭conn.send(header)#6)向客戶端發(fā)送包含文件信息的字典conn.send(headers_bytes)#7)通過二進制只讀的方式打開文件，按行讀取文件并且發(fā)送給客戶端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、向服務器發(fā)送請求send(),發(fā)送的數(shù)據(jù)不能直接發(fā)送字符串，因為要傳送到物理層底層，因此需要轉換成二進制的bytes類型進行發(fā)送，只需:發(fā)送的數(shù)據(jù).encode('utf-8')即可 while True:cmd = input("請輸入：")#向服務端發(fā)送下載文件的命令，get a.txt#修復客戶端發(fā)送空字符串而服務器卡在接收信息處的bug,continue表示跳出本次循環(huán)，重新開始下一次的循環(huán)if not cmd:continuephone.send(cmd.encode('utf-8'))#4、接收服務器返回來的數(shù)據(jù)recv()#1)先接收由服務器返回來的報頭,報頭是固定長度的，因此取前面4字節(jié)的數(shù)據(jù)即為報頭header = phone.recv(4)#返回的是一個對象#2）解析報頭，得到bytes類型的文件頭長度obj_truple = struct.unpack('i',header)#返回的是一個元組headers_bytes_size = obj_truple[0]#取元組第一個元素即為總字節(jié)數(shù)#3)接收bytes類型的文件頭數(shù)據(jù)headers_bytes = phone.recv(headers_bytes_size)#4）將bytes類型的文件頭數(shù)據(jù)反序列化成字典headers_json = headers_bytes.decode('utf-8')headers_dict = json.loads(headers_json)print(headers_dict)#5)從字典中取出字命令執(zhí)行結果字節(jié)總長度total_size = headers_dict['total_size']filename = headers_dict['filename']#6)接收返回的數(shù)據(jù)with open(r'%s/%s'%(client_dir,filename), 'wb') as fp:recv_size = 0while recv_size < total_size:recv_line = phone.recv(1024)#接收小于1024bytes的數(shù)據(jù)fp.write(recv_line)recv_size += len(recv_line)print('文件總字節(jié)長為%s,已經(jīng)下載了%s'%(total_size,recv_size))#5、關閉套接字phone phone.close()

?

4.運行的結果：

...

客戶端結果

...

請輸入：get mn.png
{'filename': 'mn.png', 'filedata': '2020/03/09', 'total_size': 702935}
文件總字節(jié)長為702935,已經(jīng)下載了6
文件總字節(jié)長為702935,已經(jīng)下載了8
文件總字節(jié)長為702935,已經(jīng)下載了237
文件總字節(jié)長為702935,已經(jīng)下載了455
文件總字節(jié)長為702935,已經(jīng)下載了686
文件總字節(jié)長為702935,已經(jīng)下載了851
文件總字節(jié)長為702935,已經(jīng)下載了946
文件總字節(jié)長為702935,已經(jīng)下載了1113
文件總字節(jié)長為702935,已經(jīng)下載了1339
文件總字節(jié)長為702935,已經(jīng)下載了1387
文件總字節(jié)長為702935,已經(jīng)下載了1847
文件總字節(jié)長為702935,已經(jīng)下載了2009

.......

文件總字節(jié)長為702935,已經(jīng)下載了702656
文件總字節(jié)長為702935,已經(jīng)下載了702935

5.待改進

代碼的可讀性較差，可以通過函數(shù)以及面向對象來對其進行優(yōu)化，增加其代碼的可讀性

總結

以上是生活随笔為你收集整理的学习笔记(14):Python网络编程并发编程-文件传输功能实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。