2接收方的缓存机制
客户端发送了一段数据,服务端只收了一小部分,服务端下次再收的时候还是从缓冲区拿上次遗留的数据,产生粘包)
1 #_*_coding:utf-8_*_ 2 from socket import * 3 ip_port=('127.0.0.1',8080) 4 5 tcp_socket_server=socket(AF_INET,SOCK_STREAM) 6 tcp_socket_server.bind(ip_port) 7 tcp_socket_server.listen(5) 8 9 10 conn,addr=tcp_socket_server.accept() 11 12 13 data1=conn.recv(2) #一次没有收完整 14 data2=conn.recv(10)#下次收的时候,会先取旧的数据,然后取新的 15 16 print('----->',data1.decode('utf-8')) 17 print('----->',data2.decode('utf-8')) 18 19 conn.close()
1 #_*_coding:utf-8_*_ 2 import socket 3 BUFSIZE=1024 4 ip_port=('127.0.0.1',8080) 5 6 s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) 7 res=s.connect_ex(ip_port) 8 9 10 s.send('hello egg'.encode('utf-8'))
三 解决粘包问题
1 import socket 2 import struct 3 sk=socket.socket() 4 sk.bind(('127.0.0.1',8090)) 5 sk.listen() 6 conn,addr=sk.accept() 7 inp=input('>>>:').encode('utf-8') 8 inp_len=len(inp)#计算用户输入的长度 9 bytes_msg=struct.pack('i',inp_len)#将数字转换成固定的bytes 10 conn.send(bytes_msg) #先发送报头的长度4个bytes 11 conn.send(inp)#在发送报头的字节格式 12 conn.send(b'alex sb')#最后发送真实内容的字节格式 13 conn.close() 14 sk.close()
1 import socket 2 import struct 3 sk=socket.socket() 4 sk.connect(('127.0.0.1',8090)) 5 num=sk.recv(4) #先接受bytes的长度 6 num=struct.unpack('i',num)[0]#提取报文的长度 7 print(sk.recv(num).decode('utf-8')) 8 print(sk.recv(10)) 9 10 sk.close()
四 udp
1 udp server端 2 3 import socket 4 sk=socket.socket(type=socket.SOCK_DGRAM) 5 sk.bind(('127.0.0.1',8899)) 6 while True: 7 msg,addr=sk.recvfrom(1024) 8 print(msg.decode('utf-8'),addr) 9 inp=input('>>>:') 10 if inp=='q':break 11 sk.sendto(inp.encode('utf-8'),addr) 12 #print(msg) 13 sk.close()
1 udp client 2 3 import socket 4 sk=socket.socket(type=socket.SOCK_DGRAM) 5 sk.bind(('127.0.0.1',8899)) 6 while True: 7 msg,addr=sk.recvfrom(1024) 8 print(msg.decode('utf-8'),addr) 9 inp=input('>>>:') 10 if inp=='q':break 11 sk.sendto(inp.encode('utf-8'),addr) 12 #print(msg) 13 sk.close()