思路:
使用socket傳輸文件過程中,如果單次傳輸每次只能發送一部分數據,如果針對大文件,一次傳輸肯定是不行的,所以需要我們在傳輸的時候提前把傳輸內容的大小先發送給客戶端,在客戶端循環接收數據即可。
代碼部分:
一、服務器
#!/usr/bin/env python #-*- coding:utf-8 -*- #environment:2.7 import os,json,time,socket sk = socket.socket() ip_port=('127.0.0.1',9600) sk.bind(ip_port) sk.listen(5) file_path = '/root/update/123.txt' file_name = file_path.rsplit(os.sep,1)[1] file_size = os.path.getsize(file_path) #獲取文件內容大小 #發送給客戶端的頭部信息 header_data = { 'file_name': file_name, 'file_size': file_size, 'date': time.strftime('%Y-%m-%d %X',time.localtime()), 'charset': 'utf-8' } while True: conn, addr = sk.accept() print("%s:%s is connect"% addr) request_data = conn.recv(1024) print(request_data) # 把頭部內容發送過去 conn.send(json.dumps(header_data)) request_data1 = conn.recv(1024) print(request_data1) f = open(file_path,'r') content = f.read() #發送文件內容 conn.sendall(content) conn.close()
二、客戶端
#!/usr/bin/env python #-*- coding:utf-8 -*- #environment:2.7 import socket,json while True: sk = socket.socket() ip_port = ('127.0.0.1',9600) sk.connect(ip_port) user_input = raw_input('>>>:').strip() if len(user_input) == 0:continue if user_input == 'q':break sk.send(user_input) server_head_msg = json.loads(sk.recv(1024)) print(server_head_msg) #文件名res_name,文件大小res_size res_name = server_head_msg['file_name'] res_size = server_head_msg['file_size'] sk.send('已經收到頭部信息,你可以發送數據了') #下面是循環接收文件內容的部分 num = res_size/1024.0 if num != int(num): num = int(num) +1 else: num = int(num) for i in range(num): content = sk.recv(1024) print(content)
備注:在接收服務器端發送來的文件也按照判斷每次接收數據的大小來考慮,大致思路如下
res = '' recive_size = 0 while recive_size <= res_size: data = sk.recv(1024) recive_size += len(data) res += data else: print(res) print('done'.center(40,'='))
以上這篇使用python socket分發大文件的實現方法就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持腳本之家。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
