服務端定義一個傳輸內(nèi)容得規(guī)則郑临，然后客戶端按照此內(nèi)容進行傳輸，服務端按照此內(nèi)容進行解析惋砂。
服務端
#encoding=utf-8
import socket,time,socketserver,struct,os,_thread
host = "127.0.0.1"
port = 12307
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.bind((host,port))
s.listen(1)
def conn_thread(connection,address):
while True:
try:
connection.settimeout(600)
fileinfo_size = struct.calcsize("12sl")
buf = connection.recv(fileinfo_size)
if buf:
filename,filesize = struct.unpack("12sl",buf)#接收到數(shù)據(jù)解析為一個字符串和一個長整形數(shù)
filename_f = filename.decode("utf-8").strip("\00")
?filenewname = os.path.join("e:\\",os.path.basename(filename_f))
print("文件名稱: %s 文件大小: %s" %(filenewname,filesize))
recvd_size = 0
file = open(filenewname,"wb")
print("開始傳輸文件內(nèi)容")
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")
except socket.timeout:
connection.close()
while True:
print("開始進入監(jiān)聽狀態(tài)")
connection,address = s.accept()
print("Connected by ",address)
_thread.start_new_thread(conn_thread,(connection,address)) ?
s.close()
客戶端
#encoding=utf-8
import socket,os,struct
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.connect(("127.0.0.1",12307))
while True:
filepath = input("Please Enter chars:\r\n")
print(type(filepath))
print(len(filepath.encode("utf-8")))
if os.path.isfile(filepath):
fhead = struct.pack("12sl",filepath.encode("utf-8"),os.stat(filepath).st_size)
print(os.stat(filepath).st_size)
s.send(fhead)
print("文件路徑:",filepath)
fo = open(filepath,"rb")
while True:
filedata = fo.read(1024)
if not filedata:
break
s.send(filedata)
fo.close()
print("傳輸成功")
