日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問(wèn) 生活随笔!

生活随笔

當(dāng)前位置: 首頁(yè) > 编程语言 > python >内容正文

python

学习笔记(14):Python网络编程并发编程-文件传输功能实现

發(fā)布時(shí)間:2023/12/10 python 27 豆豆
生活随笔 收集整理的這篇文章主要介紹了 学习笔记(14):Python网络编程并发编程-文件传输功能实现 小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

立即學(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)題。

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