服务端

1 from socket import * 2 import json,struct 3  4 client= socket(AF_INET,SOCK_STREAM) 5 client.connect(('127.0.0.1',8081)) 6  7 while True: 8     cmd=input('>>>').strip() 9     if not cmd:continue10     client.send(cmd.encode('utf-8'))11     # 先接受报头长度12     head_len=struct.unpack('i',client.recv(4))[0]13     # 接收报头14     head_bytes=client.recv(head_len)15     # 解析报头16     head_json=head_bytes.decode('utf-8')17     head_dic=json.loads(head_json)18     print(head_json)19     total_size=head_dic['size']20     # 取出真实数据21     recv_size=022     finnally_data=b''23     while total_size>recv_size:24         recv_data=client.recv(1024)25         finnally_data+=recv_data26         recv_size+=len(recv_data)27     print(finnally_data.decode('gbk'))28 29 client.close()

 

客户端

1 from socket import * 2  3 client=socket(AF_INET,SOCK_DGRAM) 4  5 while True: 6     msg=input('>>>').strip() 7     if not msg:continue 8     client.sendto(msg.encode('utf-8'),('127.0.0.1',8080)) 9     data,addr=client.recvfrom(512)10     print(data.decode('utf-8'))