034文件上传

 1 import ?socket 2 import ?os 3 ?4 def get_server_socket(): 5 ????sk = socket.socket() 6 ????address = (‘127.0.0.1‘,8888) 7 ????sk.bind(address) 8 ????sk.listen(3) 9 ????return sk10 11 def ?wait_connect(sk):12 ????print(‘waitconnecting...‘)13 ????conn, addr = sk.accept()14 ????return conn15 16 if ?__name__ == ‘__main__‘:17 ????sk = get_server_socket()18 ????conn = wait_connect(sk)19 ????BASIC_DIR = os.path.dirname(os.path.abspath(__file__))20 ????while True:21 ????????data = str(conn.recv(1024),‘utf8‘)22 ????????cmd,filename,file_size = data.split(‘|‘)23 ????????path = os.path.join(BASIC_DIR,‘yuan‘,filename)24 ????????file_size = int(file_size)25 ????f = open(path,‘wb‘)26 ????has_receive = 027 ????while has_receive != file_size:28 ????????data = conn.recv(1024)29 ????????f.write(data)30 ????????has_receive += len(data)31 ????f.close()

 1 import ?socket 2 import ?os 3 ?4 def ?get_client_socket(): 5 ????sk = socket.socket() 6 ????address = (‘127.0.0.1‘,8888) 7 ????sk.connect(address) 8 ????return sk 9 10 if __name__ == ‘__main__‘:11 ????BASIC_DIR = os.path.dirname(os.path.abspath(__file__))12 ????sk = get_client_socket()13 ????while ?True:14 ????????inp = input(‘>>>‘).strip()#post|11.png15 ????????cmd,path = inp.split(‘|‘)16 ????????path = os.path.join(BASIC_DIR,path)#使用系统的路径拼接17 ????????filename = os.path.basename(path)#拿到文件名字18 ????????file_size = os.stat(filename).st_size#拿到文件的大小19 ????????file_info = ‘post|%s|%s‘%(filename,file_size)20 ????????sk.sendall(bytes(file_info,‘utf8‘))21 ????f = open(path,‘rb‘)22 ????has_sent = 023 ????while has_sent != file_size:24 ????????data = f.read(1024)25 ????????sk.sendall(data)26 ????????has_sent += len(data)27 ????f.close()28 ????print(‘上传完成‘)