#!/usr/bin/python

# -*- coding: utf-8 -*-

importsys

reload(sys)

sys.setdefaultencoding("utf-8")

importtime

'''

等待連接

等待發(fā)送文件

讀取數(shù)據(jù)

寫入文件并且保存

等待連接

'''

importsocket

importthreading

importtime

importstruct

deffunction(newsock, address):

FILEINFO_SIZE=struct.calcsize(飄sI')

'''定義文件信息(包含文件名和文件大小)大小。128s代表128個char[](文件名)，I代表一個integer or long(文件大小)'''

while1:

try:

fhead=newsock.recv(FILEINFO_SIZE)

filename, filesize=struct.unpack(飄sI', fhead)

'''把接收到的數(shù)據(jù)庫進行解包，按照打包規(guī)則128sI'''

print"address is: ", address

printfilename,len(filename),type(filename)

printfilesize

#filename = 'new_'+filename.strip('\00') # 命名新文件new_傳送的文件

filename=filename.strip('\00')

fp=open(filename,'wb')# 新建文件，并且準備寫入

restsize=filesize

print"recving..."

while1:

ifrestsize >102400:# 如果剩余數(shù)據(jù)包大于1024，就去1024的數(shù)據(jù)包

filedata=newsock.recv(10240)

else:

filedata=newsock.recv(restsize)

fp.write(filedata)

#break

ifnotfiledata:

break

fp.write(filedata)

restsize=restsize-len(filedata)# 計算剩余數(shù)據(jù)包大小

ifrestsize <=0:

break

fp.close()

print"recv succeeded !!File named:", filename

exceptException, e:

printunicode(e).encode('gbk')

print"the socket partner maybe closed"

newsock.close()

break

sock=socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 創(chuàng)建tcp連接

sock.bind((?.240.146.82',8887))# 定于端口和ip

sock.listen(5)# 監(jiān)聽

whileTrue:

newsock, address=sock.accept()

print"accept another connection"

tmpThread=threading.Thread(target=function, args=(newsock, address))# 如果接收到文件，創(chuàng)建線程

tmpThread.start()# 執(zhí)行線程

print'end'

總結(jié)

以上是生活随笔為你收集整理的python socket 大文件_python：socket传输大文件示例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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