學習筆記(14):Python網絡編程并發編程-文件傳輸功能實現

立即學習: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.待改進

代碼的可讀性較差,可以通過函數以及面向對象來對其進行優化,增加其代碼的可讀性

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/257070.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/257070.shtml
英文地址,請注明出處:http://en.pswp.cn/news/257070.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

NFS精簡版配置方法

此實驗的前提是防火墻需關閉。 1.關閉iptables /etc/init.d/iptables stop /etc/init.d/iptables status 2.關閉selinux setenforce 0 getenforce Permissive ---出現這個單詞即代表selinux臨時關閉&#xff0c;如需永久關閉則需修改/etc/sysconfig/selinux配置文件 …

Serializable接口中serialVersionUID字段的作用

序列化運行時使用一個稱為 serialVersionUID 的版本號與每個可序列化類相關聯&#xff0c;該序列號在反序列化過程中用于驗證序列化對象的發送者和接收者是否為該對象加載了與序列化兼容的類。 如果接收者加載的該對象的類的 serialVersionUID 與對應的發送者的類的版本號不同&…

重新認知指針

1、把指針指向的變量的數據類型稱為指針的數據類型&#xff1b;而任何一個指針變量本身數據值的類型都是unsigned long int 2.、指針變量名前的符號“*”表示的是指向運算。 3、不要認為“ *p" 是指針變量&#xff0c;指針變量是p而不是*p 4、

分布式數據庫 HBase

原文地址&#xff1a;http://www.oschina.net/p/hbase/ HBase 概念 HBase – Hadoop Database&#xff0c;是一個高可靠性、高性能、面向列、可伸縮的分布式存儲系統&#xff0c;利用HBase技術可在廉價PC Server上搭建起大規模結構化存儲集群。 HBase是Google Bigtable的開源實…

學習筆記(15):Python網絡編程并發編程-進程理論

立即學習:https://edu.csdn.net/course/play/24458/296423?utm_sourceblogtoedu 1.進程&#xff1a;正在運行的一個過程或者一個任務&#xff1b; 2.進程與程序的區別&#xff1a;程序是一堆代碼&#xff0c;程序運行起來就是進程了&#xff0c;一個程序運行兩次&#xff0c;算…

【翻譯】Designing Websites for iPhone X

讓網站適配 iphone X 英文原文地址&#xff1a;https://webkit.org/blog/7929/...本文原文地址&#xff1a;https://github.com/cnsnake11/... The section below about safe area insets was updated on Oct 31, 2017 to reflect changes in the iOS 11.2 beta. 以下關于safe …

指針作為函數參數引用數組的任意元素

void swap(int *a,int*b) {*a*a^*b;*b*a^*b;*a*a^*b; } swap(data[j],data[j1]&#xff09;; int data[10]{13,55,48,13,62,45,754,0,10};以上是我遇到的問題&#xff0c;我覺得調用這個swap函數是不能這樣直接把數組的某個元素直接丟給swap數據 在程序中參加數據處理的量不是指…

使用 Log4Net 記錄日志

第一步&#xff1a;下載Log4Net 下載地址&#xff1a;http://logging.apache.org/log4net/download_log4net.cgi 把下載的 log4net-1.2.11-bin-newkey解壓后&#xff0c;如下圖所示&#xff1a; 雙擊bin文件夾 雙擊net文件夾&#xff0c;選擇針對.NET FramerWork的不同版本 找…

Xcode常用快捷鍵

1. 文件CMD N: 新文件CMD SHIFT N: 新項目CMD O: 打開CMD S: 保存CMDOPtS&#xff1a;保存所有文件CMD SHIFT S: 另存為CMD W: 關閉窗口CMD Q :退出XcodeCMD SHIFT W: 關閉文件2. 編輯CMD [: 左縮進CMD ]: 右縮進CMDshiftF:項目中查找CMDG:查找下一個CMDshiftG:查…

學習筆記(16):Python網絡編程并發編程-開啟子進程的兩種方式

立即學習:https://edu.csdn.net/course/play/24458/296424?utm_sourceblogtoedu #方式一&#xff1a;使用python內置模塊multiprocessing下的process類 from multiprocessing import Process import time#定義進程函數 def task(name):print(%s is running&#xff01;%name)t…

ElasticSearch的API python調用

os json datetime datetime django.http HttpResponse reelasticsearch Elasticsearches Elasticsearch([])res8 es.search({:{:{:{::}}}} ) statistic():():hit res8[][]:a (%hit %hit[])a re.split(a);arow a:id row[] row[]idHttpResponse(a)轉載于:https://blog.51cto…

HDU 1757 A Simple Math Problem (矩陣快速冪)

題目鏈接&#xff1a;http://acm.hdu.edu.cn/showproblem.php?pid1757 在吳神的幫助下才明白如何構造矩陣&#xff0c;還是好弱啊。 此處盜一張圖 1 #include <iostream>2 #include <cstdio>3 #include <cstring>4 #include <cmath>5 #include <al…

Spring學習使用標簽來標記資源(@Component、@Repository、 @Service和@Controller)和用法(包括如何jsp正在使用)...

首先&#xff0c;在xml其中新增部分標有下劃線的文件&#xff0c;容器初始化的時候需要掃描包 注意&#xff1a; a. 包款掃描(下劃線部分)一定要加&#xff0c;默認是不掃描整個包。與每一包之間’&#xff0c;’開。如過具有同樣的父包&#xff0c;那么我們能夠用父包來取…

python 判斷字符串時是否是json格式方法

在實際工作中&#xff0c;有時候需要對判斷字符串是否為合法的json格式 解決方法使用json.loads,這樣更加符合‘Pythonic’寫法 代碼示例&#xff1a; Python import json def is_json(myjson):try:json_object json.loads(myjson)except ValueError, e:return Falsereturn Tr…

學習筆記(17):Python網絡編程并發編程-Process對象的其他屬性或方法

立即學習:https://edu.csdn.net/course/play/24458/296427?utm_sourceblogtoedu 1.pid與ppid&#xff1a;pid進程編碼&#xff0c;ppid進程的父進程編碼&#xff1b;os.getpid()查看正在運行的進程編碼&#xff0c;os.getppid()查看正在運行進程的父進程編碼 2.僵尸進程&…

用弦截法求一元三次方程的根x^3-5x^2+16x-80=0 ;帶注釋!

//用弦截法求一元三次方程的根x^3-5x^216x-800 #include<stdio.h>#include<math.h> float f(float x) //定義子函數f(x) x^3-5x^216x-80&#xff0c;當f(x) →0時&#xff0c;則x即為所求的實數根&#xff1b; { float y; y((x-5.0)*x16.0)*x-80.0; …

兩個很有用的進程間通信函數popen,pclose

兩個很有用的進程間通信函數popen,pclose 今天起的比較晚&#xff0c;然后來了也不想復習&#xff0c;還是看書學習--寫代碼--寫博客有意思&#xff0c;不敢說有多精通&#xff0c;至少每天都在學習新知識&#xff0c;不求立刻完全消化&#xff0c;但求每天有進步。 現在就看看…

c++中指針箭頭的用法

1、c中指針用箭頭來引用類或者結構體的成員&#xff0c;箭頭操作符“->”用來引用指針對象。這是是用于類&#xff0c;或者是結構體的指針變量用的。 如struct Point {int x,y;};Point *ptnew Point;pt->x1; 舉例子說明一下&#xff1a;比如&#xff0c;我有一個對象dark…

化零為整WCF(14) - 事務(Transaction)

[索引頁][源碼下載] 化零為整WCF(14) - 事務(Transaction)作者&#xff1a;webabcd介紹WCF(Windows Communication Foundation) - 事務(Transaction)&#xff1a; 對契約方法使用TransactionFlowAttribute聲明&#xff08;設置TransactionFlowOption參數&#xff09;&#x…