学习笔记(14):Python网络编程并发编程-文件传输功能实现
立即學(xué)習(xí):https://edu.csdn.net/course/play/24458/296245?utm_source=blogtoedu
1.課程目的:
?????? 實(shí)現(xiàn)客戶端輸入下載文件的命令,然后將命令發(fā)送給服務(wù)端,服務(wù)端再執(zhí)行下載文件的命令,最后將執(zhí)行下載文件命令后的結(jié)果返回給客戶端,客戶端進(jìn)行接收,這樣就完成了一個(gè)簡(jiǎn)單的文件下載功能。文件的上傳與下載類似,只是兩個(gè)相反的過(guò)程
?
2.知識(shí)點(diǎn)與關(guān)鍵點(diǎn):
1)os模塊:可使用os.path.getsize(filename)來(lái)獲取指定文件的大小;
2)在服務(wù)端接收的命令,使用split命令將接收的命令的字符串分割,判斷第一個(gè)是‘get’還是‘put’,即判斷時(shí)下載文件還是上傳文件
?
3.完整代碼
'''
服務(wù)端
'''
import socket import subprocess import json import struct import os server_dir = r'C:\Users\jinlin\Desktop\python_further_study\socket編程\文件的傳輸(上傳)\簡(jiǎn)單版本\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ā)送過(guò)來(lái)連接服務(wù)器請(qǐng)求res = phone.accept()conn,client_addr = reswhile True:try:#1接收客戶端發(fā)送過(guò)來(lái)的命令resv = conn.recv(1024)#2將接收到的結(jié)果進(jìn)行分割,獲得命令以及文件名cmds = resv.decode('utf-8').split()#['get','a.txt']print('*'*50)#3處理命令,執(zhí)行命令并且獲得命令得到的結(jié)果cmd = cmds[0]filename = cmds[1]total_size = os.path.getsize(r'%s/%s'%(server_dir,filename))#獲得文件的字節(jié)數(shù)大小#1)制作包含文件名和文件大小的文件頭,用字典實(shí)現(xiàn)headers_dict = {"filename":filename,"filedata":"2020/03/09","total_size":total_size}#2)將字典先序列化成驚悚字符串,再轉(zhuǎn)為bytes類型文件頭headers_json = json.dumps(headers_dict)#3)獲取bytes類型的長(zhǎng)度headers_bytes = headers_json.encode('utf-8')headers_size = len(headers_bytes)#4)將bytes類型文件頭長(zhǎng)度定制為固定長(zhǎng)度的報(bào)頭header = struct.pack('i',headers_size)#5)向客戶端發(fā)送報(bào)頭conn.send(header)#6)向客戶端發(fā)送包含文件信息的字典conn.send(headers_bytes)#7)通過(guò)二進(jìn)制只讀的方式打開文件,按行讀取文件并且發(fā)送給客戶端with open(filename,'rb') as fp:for line in fp:conn.send(line)except ConnectionResetError:breakconn.close()phone.close()?
'''
客戶端
'''
#導(dǎo)入模塊 import socket import struct import json client_dir = r'C:\Users\jinlin\Desktop\python_further_study\socket編程\文件的傳輸(上傳)\簡(jiǎn)單版本\client'#1、設(shè)置phone套接字 phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#2、連接服務(wù)器(打電話),本地地址:127.0.0.1 phone.connect(('127.0.0.1',8080))#3、向服務(wù)器發(fā)送請(qǐng)求send(),發(fā)送的數(shù)據(jù)不能直接發(fā)送字符串,因?yàn)橐獋魉偷轿锢韺拥讓?#xff0c;因此需要轉(zhuǎn)換成二進(jìn)制的bytes類型進(jìn)行發(fā)送,只需:發(fā)送的數(shù)據(jù).encode('utf-8')即可 while True:cmd = input("請(qǐng)輸入:")#向服務(wù)端發(fā)送下載文件的命令,get a.txt#修復(fù)客戶端發(fā)送空字符串而服務(wù)器卡在接收信息處的bug,continue表示跳出本次循環(huán),重新開始下一次的循環(huán)if not cmd:continuephone.send(cmd.encode('utf-8'))#4、接收服務(wù)器返回來(lái)的數(shù)據(jù)recv()#1)先接收由服務(wù)器返回來(lái)的報(bào)頭,報(bào)頭是固定長(zhǎng)度的,因此取前面4字節(jié)的數(shù)據(jù)即為報(bào)頭header = phone.recv(4)#返回的是一個(gè)對(duì)象#2)解析報(bào)頭,得到bytes類型的文件頭長(zhǎng)度obj_truple = struct.unpack('i',header)#返回的是一個(gè)元組headers_bytes_size = obj_truple[0]#取元組第一個(gè)元素即為總字節(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é)果字節(jié)總長(zhǎng)度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é)長(zhǎng)為%s,已經(jīng)下載了%s'%(total_size,recv_size))#5、關(guān)閉套接字phone phone.close()?
4.運(yùn)行的結(jié)果:
...
客戶端結(jié)果
...
請(qǐng)輸入:get mn.png
{'filename': 'mn.png', 'filedata': '2020/03/09', 'total_size': 702935}
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了6
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了8
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了237
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了455
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了686
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了851
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了946
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了1113
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了1339
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了1387
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了1847
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了2009
.......
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了702656
文件總字節(jié)長(zhǎng)為702935,已經(jīng)下載了702935
5.待改進(jìn)
代碼的可讀性較差,可以通過(guò)函數(shù)以及面向?qū)ο髞?lái)對(duì)其進(jìn)行優(yōu)化,增加其代碼的可讀性
總結(jié)
以上是生活随笔為你收集整理的学习笔记(14):Python网络编程并发编程-文件传输功能实现的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: 权限分配之权限的展示
- 下一篇: 学习笔记(15):Python网络编程并