#!/usr/bin/env python
# -*- coding=utf-8 -*-
import socket
import threading
import time
import sys
import os
import structdef socket_service():try:s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)s.bind(('192.168.137.9', 23456))#这里换上自己的ip和端口s.listen(10)except socket.error as msg:print(msg)sys.exit(1)print ("Waiting...")while 1:conn, addr = s.accept()t = threading.Thread(target=deal_data, args=(conn, addr))t.start()def deal_data(conn, addr):print ('Accept new connection from {0}'.format(addr))while 1:fileinfo_size = struct.calcsize('128sl')buf = conn.recv(fileinfo_size)if buf:filename, filesize = struct.unpack('128sl', buf)fn = filename.strip(str.encode('00'))new_filename = os.path.join(str.encode('./'), str.encode('new_') + fn)print ('file new name is {0}, filesize if {1}'.format(new_filename, filesize))recvd_size = 0  # 定义已接收文件的大小fp = open(new_filename, 'wb')print ("start receiving...")while not recvd_size == filesize:if filesize - recvd_size > 1024:data = conn.recv(1024)recvd_size += len(data)else:data = conn.recv(filesize - recvd_size)recvd_size = filesizefp.write(data)fp.close()print ("end receive...")conn.close()breakif __name__ == '__main__':socket_service()

#!/usr/bin/env python
# -*- coding=utf-8 -*-import socket
import os
import sys
import structdef socket_client():try:s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)s.connect(('192.168.137.1',23456))except socket.error as msg:print(msg)sys.exit(1)print (s.recv(1024))while 1:filepath = input("please input file path: ")if os.path.isfile(filepath):# 定义定义文件信息。128s表示文件名为128bytes长，l表示一个int或log文件类型，在此为文件大小fileinfo_size = struct.calcsize('128sl')# 定义文件头信息，包含文件名和文件大小fhead = struct.pack('128sl', bytes(os.path.basename(filepath).encode('utf-8')),os.stat(filepath).st_size)s.send(fhead)print ('client filepath: {0}'.format(filepath))fp = open(filepath, 'rb')while 1:data = fp.read(1024)if not data:print ('{0} file send over...'.format(filepath))breaks.send(data)s.close()breakif __name__ == '__main__':socket_client()