python发送文件_Python大文件传输

socker_server.py：

实现功能：获取yaml中的文件信息，用soket进行文件传输（TCP+三次握手）

socker_client.py：

实现功能：利用server端传过来的文件信息做校验，并继续文件接收

properties：

为yaml文件，储存文件信息

#file:socker_server.py

#_*_coding:utf-8_*_

#by Linhut

#time:2017/4/8

import SocketServer,yaml,json

class socketHandler(SocketServer.BaseRequestHandler):

def setup(self):

print '\033[32mServer starting successful ....\033[0m'

with open('F:/cgi-bin/p2/config/properties', 'r') as f:

content = f.read() #读出来内容

self.cfg = yaml.load(content) #通过yaml变成字典

def handle(self):

conn = self.request #把客户端的soket对象收到

first_mgs = conn.recv(1024) #判断第一次握手成功，发生文件头部

if first_mgs == 'successful':

with open(self.cfg['file_matadata']['filepath'],'rb') as f: #rb打开文件

self.content = f.read()

filesize = len(self.content)

self.cfg['file_matadata']['filesize'] = filesize # raml文件赋值文件大小

ack_msg = json.dumps(self.cfg).encode()

conn.send(ack_msg) #给客户端发送信息

else:

print 'client failed...'

if conn.recv(1024) == 'start':

conn.send(self.content)

finish_msg = conn.recv(1024)

print finish_msg

def finish(self):

pass

class socketserever(SocketServer.TCPServer):

pass

class MyServer(SocketServer.TCPServer,SocketServer.ThreadingMixIn):

pass

if __name__=='__main__':

server = socketserever(('127.0.0.1',2010),socketHandler)

server.serve_forever()

#file:socker_client.py

#_*_coding:utf-8_*_

#by Linhut

#time:2017/4/8

import socket,json,sys,time

recv_file = b''

recv_size = 0

server_address = ('127.0.0.1',2010)

sock =socket.socket(socket.AF_INET,socket.SOCK_STREAM)

for i in range(5):

try:

sock.connect(server_address)

break

except Exception as e:

print 'client connection server \033[31mfailad\033[0m,please 3s retry..'

time.sleep(3)

else:

print 'client exit..'

sys.exit(10)

sock.send('successful')

ack_msg = json.loads(sock.recv(1024).decode()) #拿ack信息

print ack_msg

if ack_msg['file_matadata']:

filename = ack_msg['file_matadata']['filename']

filesize = ack_msg['file_matadata']['filesize']

name = raw_input('raw_input you locla filename:')

save_file_path = 'C:/Users/T530_I7QM/Desktop/%s.pdf'%name

sock.send('start') #告诉服务器端可以发送数据了

while recv_size < filesize:

content = sock.recv(2048)

recv_file += content

recv_size += 2048

print '[%s] recv_size:%s'%(filename,recv_size)

else:

with open(save_file_path,'ab+') as f:

f.write(recv_file)

sock.send('\033[32m client recv finished\033[0m') #完成并发生一个消息

print '\033[32m recv finished.. \033[0m'

#file:properties

ack_msg:

filename: qqq.pdf

filepath: C:/Users/T530_I7QM/Desktop/qqq.pdf

filesize:

python发送文件_Python大文件传输相关推荐

python按行读取文件效率高吗_Python按行读取文件的实现方法【小文件和大文件读取】...
本文实例讲述了Python按行读取文件的实现方法.分享给大家供大家参考,具体如下: 小文件: #coding=utf-8 #author: walker #date: 2013-12-30 #func ...
Python 生成大量文件及大文件
Python 生成大量文件及大文件很多时候测试需要大量的文件和很大的文件,这些手动操作是非常麻烦的,现在来看看使用python自动生成一次生成大量小文件(速度很慢) import os impor ...
VC++中使用内存映射文件处理大文件
引言文件操作是应用程序最为基本的功能之一,Win32 API和MFC均提供有支持文件处理的函数和类,常用的有Win32 API的CreateFile().WriteFile().ReadFile() ...
Flink重写Iceberg数据湖小文件变大文件
1. 重写小文件变大文件 Flink支持Batch任务,将iceberg表的小文件重写成大文件合并前HDFS的metadata和data目录文件如下: [root@flink1 ~]# [root@ ...
python读取大文件的某行_Python按行读取文件的实现方法【小文件和大文件读取】...
本文实例讲述了Python按行读取文件的实现方法.分享给大家供大家参考,具体如下: 小文件: #coding=utf-8 #author: walker #date: 2013-12-30 #func ...
python读取大文件的某行_python 大文件以行为单位读取方式比对
先前需要做一个使用python读取大文件(大于1G),并逐条存入内存进行处理的工作.做了很多的尝试,最终看到了如下的文章. 该文章实际上提供了集中读取大文件的方式,先经过测试总结如下 1. for l ...
python如何读取文件指定行_Python读取文件、大文件和指定行内容的几种方法
在使用python处理文本的时候,经常会需要读取文件的内容.如果文件比较小,那么直接使用open文件对象打开文件,再通过read()方法最为方便,这种方法就是把文件内容读出来后放到内存变量. read ...
python读取文件多行内容-Python读取文件、大文件和指定行内容的几种方法
在使用python处理文本的时候,经常会需要读取文件的内容.如果文件比较小,那么直接使用open文件对象打开文件,再通过read()方法最为方便,这种方法就是把文件内容读出来后放到内存变量. read ...
python批量下载网页文件-超简单超详细python小文件、大文件、批量下载教程
按照不同的情况,python下载文件可以分为三种: 小文件下载大文件下载批量下载 python 小文件下载流程:使用request.get请求链接,返回的内容放置到变量r中,然后将r写入到你想放 ...

python发送文件_Python大文件传输

python发送文件_Python大文件传输相关推荐

最新文章

热门文章