pythonsocket编程3
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了pythonsocket编程3相关的知识,希望对你有一定的参考价值。
1 什么是粘包
只有TCP有粘包现象,UDP永远不会粘包
应用程序所看到的数据是一个整体,或说是一个流(stream),一条消息有多少字节对应用程序是不可见的,因此TCP协议是面向连接的,面向流的,收发两端都要有一一成对的socket,因此,发送端为了将多个发往接收端的包,更有效的发到对方,使用了优化方法,将多次间隔较小且数据量小的数据,合并成一个大的数据块,然后进行封包。这也是容易出现粘包问题的原因;
而UDP面向消息的协议,每个UDP段都是一条消息,应用程序必须以消息为单位提取数据,不能一次提取任意字节的数据。
粘包问题主要还是因为接收方不知道消息之间的界限,不知道一次性提取多少字节的数据所造成的。
两种情况下会发生粘包
(1.)发送端需要等缓冲区满才发送出去,造成粘包。发送数据时间间隔很短,数据很小会合到一起,产生粘包
(2)接收方不及时收取缓冲区的包,造成多个包接收,客户端发送了一段数据,服务端只收了一小部分,服务端下次再收的时候还是从缓冲区拿上次遗留的数据,产生粘包
#服务端 import socket phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.0.0.1",8080) phone.bind(ip_port) phone.listen(5) conn,addr=phone.accept() data1=conn.recv(1024) data2=conn.recv(1024) print("第1个包",data1) print("第2个包",data2) #客户端 import socket phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.0.0.1",8080) phone.connect(ip_port) phone.send("helloworld".encode("utf8")) phone.send("SB".encode("utf8")) >> 第1个包 b‘helloworldSB‘#产生粘包现象 第2个包 b‘‘
使用时间模块,并不能够彻底解决问题
#服务端 import socket phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.0.0.1",8080) phone.bind(ip_port) phone.listen(5) conn,addr=phone.accept() data1=conn.recv(1024) data2=conn.recv(1024) print("第1个包",data1) print("第2个包",data2) #客户端 import socket,time phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.0.0.1",8080) phone.connect(ip_port) phone.send("helloworld".encode("utf8")) time.sleep(3) phone.send("SB".encode("utf8")) >> 第1个包 b‘helloworld‘#send先执行一次后,发送至客户端内存 第2个包 b‘SB‘#延迟三秒后,,再执行发送
#服务端 import socket phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.0.0.1",8080) phone.bind(ip_port) phone.listen(5) conn,addr=phone.accept() data1=conn.recv(1) data2=conn.recv(1024) print("第1个包",data1) print("第2个包",data2) #客户端 import socket,time phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.0.0.1",8080) phone.connect(ip_port) phone.send("helloworld".encode("utf8")) time.sleep(3) phone.send("SB".encode("utf8")) >> 第1个包 b‘h‘ #recv第一次只取一个字节 第2个包 b‘elloworld‘ #第二次再次执行 ,”SB”还在服务器的内存中
2 自定制报头解决粘包问题
数据封装报头:
固定长度
包含对将要发送数据的描述信息
struct模块 import struct print(struct.pack("i",111)) >> b‘o\x00\x00\x00‘ #转成字节模式 import struct res=struct.pack("i",111)#struct.pack 打包 print(len(res)) >> 4 #转成字节长度为固定4 import struct res=struct.pack("i",111) # print(len(res)) print(struct.unpack("i",res))#解包 (111,)#获得以元组形式的结果
简单实现:
#服务端 import socket import struct import subprocess phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.168.0.1",8080) phone.bind(ip_port) phone.listen(5) #连接循环 while True: conn,addr=phone.accept() print("cline addr",addr) #通讯循环 while True: try: cmd=conn.recv(1024) res=subprocess.Popen(cmd.decode("utf8"), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) out_res=res.stdout.read() err_res=res.stderr.read() data_size=len(out_res)+len(err_res) #发送报头 conn.send(struct.pack("i",data_size)) #发送数据部分 conn.send(out_res) conn.send(err_res) except Exception: break conn.close() phone.close() #客户端 import socket import struct phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.168.0.1",8080) phone.connect(ip_port) #通信循环 while True: #发消息 cmd=input(">>").strip() if not cmd:continue phone.send(bytes(cmd,encoding="utf8")) #收报头 baotou=phone.recv(4) data_size=struct.unpack("i",baotou)[0] #收数据 recv_size=0 recv_data=b"" while recv_size<data_size: data=phone.recv(1024) recv_size+=len(data) recv_data+=data print(recv_data.decode("gbk")) phone.close()
完全解决:
#服务端 import socket import struct import subprocess import json phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.168.0.1",8080) phone.bind(ip_port) phone.listen(5) #连接循环 while True: conn,addr=phone.accept() print("cline addr",addr) #通讯循环 while True: try: cmd=conn.recv(1024) res=subprocess.Popen(cmd.decode("utf8"), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) out_res=res.stdout.read() err_res=res.stderr.read() data_size=len(out_res)+len(err_res) head_dic={"data_size":data_size} head_json=json.dumps(head_dic) head_bytes=head_json.encode("utf8") #发送报头 head_len=len(head_bytes) conn.send(struct.pack("i",data_size)) conn.send(head_bytes) #发送数据部分 conn.send(out_res) conn.send(err_res) except Exception: break conn.close() phone.close() #客户端 import socket import struct import json phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ip_port=("127.168.0.1",8080) phone.connect(ip_port) #通信循环 while True: #发消息 cmd=input(">>").strip() if not cmd:continue phone.send(bytes(cmd,encoding="utf8")) #收报头的长度 head_struct=phone.recv(4) head_len=struct.unpack("i",head_len)[0] #再收报头 head_bytes=phone.recv(head_len) head_json=head_bytes.decode("utf8") head_dic=json.loads(head_json) print(head_dic) data_size=head_dic["data_size"] #收数据 recv_size=0 recv_data=b"" while recv_size<data_size: data=phone.recv(1024) recv_size+=len(data) recv_data+=data print(recv_data.decode("gbk")) phone.close()
以上是关于pythonsocket编程3的主要内容,如果未能解决你的问题,请参考以下文章