ITPub博客

首页 > > > python 之网络编程(基于TCP协议Socket通信的粘包问题及解决)

python 之网络编程(基于TCP协议Socket通信的粘包问题及解决)

作者:llittle 时间:2019-12-20 17:06:20 0 删除 编辑

粘包问题

粘包问题发生的原因:

1.发送端需要等缓冲区满才发送出去,造成粘包(发送数据时间间隔很短,数据了很小,会合到一起,产生粘包),这样接收端,就难于分辨出来了,必须提供科学的拆包机制。 即面向流的通信是无消息保护边界的。

2.接收方不及时接收缓冲区的包,造成多个包接收(客户端发送了一段数据,服务端只收了一小部分,服务端下次再收的时候还是从缓冲区拿上次遗留的数据,产生粘包)

粘包问题主要还是因为接收方不知道消息之间的界限,不知道一次性提取多少字节的数据所造成的。

stract模块

1、把整型数字转成bytes类型 2、转成的bytes是固定长度的

2 利用stract模块解决粘包

为字节流加上自定义固定长度报头,报头中包含字节流长度,然后一次send到对端,对端在接收时,先从缓存中取出定长的报头(报头中含有真实数据长度),然后再取真实数据

服务端:

客户端:

3.自定义报头

我们可以把报头做成字典,字典里包含将要发送的真实数据的详细信息,字典然后json序列化,编码成byte类型,然后用struck将数据长度打包成4个字节(4个自己足够用了)

发送时:

先发报头长度,再编码报头内容然后发送,最后发真实内容

接收时:先收报头长度,用struct取出来,根据取出的长度收取报头内容,然后解码,反序列化,从反序列化的结果中取出待取数据的详细信息,然后去取真实的数据内容

服务端:

客户端:

客户端:

客户端实现等待后重连:

import socket
import time

while True:
 try:
 client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

 client.connect(('127.0.0.1',8080))
 break
 except ConnectionRefusedError:
 time.sleep(3)
 print('等待3秒。。。')


来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/813/viewspace-3155620/ ,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2019-04-12

  • 博文量
    448
  • 访问量
    4364