这篇文章主要介绍了 Python Socket 传输文件示例,发送端可以不停的发送新文件,接收端可以不停的接收新文件。有兴趣的可以了解一下。
Python 是一种面向对象、解释型计算机程序设计语言,由 Guido van Rossum 于 1989 年底发明,第一个公开发行版发行于 1991 年。Python 语法简洁而清晰,具有丰富和强大的类库。它常被昵称为胶水语言,它能够把用其他语言制作的各种模块(尤其是 C/C++)很轻松地联结在一起。
发送端可以不停的发送新文件,接收端可以不停的接收新文件。
例如:发送端输入:e:\visio.rar,接收端会默认保存为 e:\new_visio.rar,支持多并发,具体实现如下;
接收端:
方法一:
- #-*- coding: UTF-8 -*-
- import socket,time,SocketServer,struct,os,thread
- host='192.168.50.74'
- port=12307
- s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #定义socket类型
- s.bind((host,port)) #绑定需要监听的Ip和端口号,tuple格式
- s.listen(1)
- def conn_thread(connection,address):
- while True:
- try:
- connection.settimeout(600)
- fileinfo_size=struct.calcsize('128sl')
- buf = connection.recv(fileinfo_size)
- if buf: #如果不加这个if,第一个文件传输完成后会自动走到下一句
- filename,filesize =struct.unpack('128sl',buf)
- filename_f = filename.strip('\00')
- filenewname = os.path.join('e:\\',('new_'+ filename_f))
- print 'file new name is %s, filesize is %s' %(filenewname,filesize)
- recvd_size = 0 #定义接收了的文件大小
- file = open(filenewname,'wb')
- print 'stat receiving...'
- while not recvd_size == filesize:
- if filesize - recvd_size > 1024:
- rdata = connection.recv(1024)
- recvd_size += len(rdata)
- else:
- rdata = connection.recv(filesize - recvd_size)
- recvd_size = filesize
- file.write(rdata)
- file.close()
- print 'receive done'
- #connection.close()
- except socket.timeout:
- connection.close()
- while True:
- connection,address=s.accept()
- print('Connected by ',address)
- #thread = threading.Thread(target=conn_thread,args=(connection,address)) #使用threading也可以
- #thread.start()
- thread.start_new_thread(conn_thread,(connection,address))
- s.close()
方法二:
- #-*- coding: UTF-8 -*-
- import socket,time,SocketServer,struct,os
- host='192.168.50.74'
- port=12307
- ADDR=(host,port)
- class MyRequestHandler(SocketServer.BaseRequestHandler):
- def handle(self):
- print('connected from:', self.client_address)
- while True:
- fileinfo_size=struct.calcsize('128sl') #定义文件信息。128s表示文件名为128bytes长,l表示一个int或log文件类型,在此为文件大小
- self.buf = self.request.recv(fileinfo_size)
- if self.buf: #如果不加这个if,第一个文件传输完成后会自动走到下一句
- self.filename,self.filesize =struct.unpack('128sl',self.buf) #根据128sl解包文件信息,与client端的打包规则相同
- print 'filesize is: ',self.filesize,'filename size is: ',len(self.filename) #文件名长度为128,大于文件名实际长度
- self.filenewname = os.path.join('e:\\',('new_'+ self.filename).strip('\00')) #使用strip()删除打包时附加的多余空字符
- print self.filenewname,type(self.filenewname)
- recvd_size = 0 #定义接收了的文件大小
- file = open(self.filenewname,'wb')
- print 'stat receiving...'
- while not recvd_size == self.filesize:
- if self.filesize - recvd_size > 1024:
- rdata = self.request.recv(1024)
- recvd_size += len(rdata)
- else:
- rdata = self.request.recv(self.filesize - recvd_size)
- recvd_size = self.filesize
- file.write(rdata)
- file.close()
- print 'receive done'
- #self.request.close()
- tcpServ = SocketServer.ThreadingTCPServer(ADDR, MyRequestHandler)
- print('waiting for connection...' )
- tcpServ.serve_forever()
发送端:
- #-*- coding: UTF-8 -*-
- import socket,os,struct
- s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
- s.connect(('192.168.50.74',12307))
- while True:
- filepath = raw_input('Please Enter chars:\r\n')
- if os.path.isfile(filepath):
- fileinfo_size=struct.calcsize('128sl') #定义打包规则
- #定义文件头信息,包含文件名和文件大小
- fhead = struct.pack('128sl',os.path.basename(filepath),os.stat(filepath).st_size)
- s.send(fhead)
- print 'client filepath: ',filepath
- # with open(filepath,'rb') as fo: 这样发送文件有问题,发送完成后还会发一些东西过去
- fo = open(filepath,'rb')
- while True:
- filedata = fo.read(1024)
- if not filedata:
- break
- s.send(filedata)
- fo.close()
- print 'send over...'
- #s.close()
来源: