Python socket连接中的粘包、精确传输问题实例分析
作者:随风行云 发布时间:2023-12-21 23:42:48
标签:Python,socket连接
本文实例讲述了Python socket连接中的粘包、精确传输问题。分享给大家供大家参考,具体如下:
粘包:
发生原因:
当调用send的时候,数据并不是即时发给客户端的。而是放到了系统的socket发送缓冲区里,等缓冲区满了、或者数据等待超时了,数据才会发送,所以有时候发送太快的话,前一份数据还没有传给客户端,那么这份数据和上一份数据一起发给客户端的时候就会造成“粘包” 。
解决方案:
解决根源的思想是避免不同段的数据一起发送。
方案1:前一段数据send完后,等待一段时间再send第二段数据。缺点:时间效率低,而且也无法完全避免问题【因为不清楚该设置多少时间才能保证前一份数据已经发送】
方案2:握手机制:前一段数据send完后,尝试recv,等待客户端回应,确认第一段数据发送完后,再send第二段数据。完美方案?
方案二的演示:
服务端【发送方】代码:
import socket
server=socket.socket()
server.bind(("localhost",1234))
server.listen()
while True:
print("正在等待。。。")
conn,addr=server.accept()
while True:
try:
conn.send(b"first info")
ack=conn.recv(1024) #接收客户端确认
print(ack)
conn.send(b"second info")
except ConnectionResetError as e:
print(e)
break
server.close()
客户端【接收方】代码:
import socket
client=socket.socket()
client.connect(("localhost",1234))
data=client.recv(1024)
print(data.decode())
client.send(b"ack")#发送确认
data=client.recv(1024)
print(data.decode())
client.close()
不精确传输问题:
发生原因:
由于数据太大,发送方一次send不完,而接收方只recv一次,使得影响了后面数据的传输
解决方案:
解决根源的思想是改变recv的次数。
方案:将数据的大小发给接收方,让接收方来决定recv的次数
方案实现代码【以解决长数据shell命令传输为例】:
服务端【发送方】:
import socket,os
server=socket.socket()
server.bind(("localhost",1234))
server.listen()
while True:
print("正在等待...")
conn,addr=server.accept()
print("连接成功!")
while True:
try:
cmd=conn.recv(1024)
data=os.popen(cmd.decode()).read()
# print(data)
cmd_len=len(data.encode())
print(cmd_len)
#发现这里如果cmd_len为0会导致异常,有些是没有返回值的command
if cmd_len==0:
data="command has nothing return"
cmd_len=len(data.encode())
##因为这里前面没有发送操作,所以不用担心粘包,如果有则要考虑处理
conn.send(str(cmd_len).encode())#因为len结果是int,所以还要转换
#这里要处理粘包
ack=conn.recv(1024)
conn.send(data.encode())
except ConnectionResetError as e:
print(e)
break
server.close()
客户端【接收方】:
import socket
client=socket.socket()
client.connect(("localhost",1234))
while True:
cmd = input(">>:")
client.send(cmd.encode())
data_len=client.recv(1024)
data_len=int(data_len.decode())
print(data_len)
recv_len=0
client.send(b'ack')
total_data=b''
while recv_len<data_len:
data=client.recv(1024)
recv_len+=len(data)
total_data+=data
print(total_data.decode())
client.close()
利用这个原理可以实现文件传输,只要能确定接受次数,就能保证文件传输的大小正确。
希望本文所述对大家Python程序设计有所帮助。
来源:https://www.cnblogs.com/progor/p/8429893.html
0
投稿
猜你喜欢
- PDO::preparePDO::prepare — 准备要执行的SQL语句并返回一个 PDOStatement 对象(PHP 5 >
- javascript编写的窗口代码,可以关闭显示窗口,可以最小化或还原窗口大小,还可以鼠标移动窗口,不错的一个功能。截图如下:<htm
- 在树莓派自带得python IDE Thonny中写如下代码,并在树莓派上插上usb摄像头import cv2cap=cv2.VideoCa
- <script> Function.prototype.createInstance = function(){ var T =
- 一、实验目的:1.掌握Python中柱状图、条形图绘图函数的使用2.利用上述绘图函数实现数据可视化二、实验内容:1.练习python中柱状图
- 我就废话不多说了,直接上代码吧!#coding=utf-8'''openCV中最核心的的类是Mat,他是matrix
- 最近我遇到了一个 bug,我试着通过 Rails 在以“utf8”编码的 MariaDB 中保存一个 UTF-8 字符串,然后出现了一个离奇
- 目录一.简介二.特色三.flask规模化四. flask Blueprint总结一.简介Flask是一个使用Python编写的轻量级Web应
- Oracle不像SQLServer那样在存储过程中用Select就可以返回结果集,而是通过Out型的参数进行结果集返回的。实际上是利用REF
- 吐槽一下企业微信的api文档真的不好读······企业微信本来是有功能,可以直接把图片显示到正文的,但是那个api我调用一直出错,各种折腾也
- 一、什么是缓存击穿当一个key是热点key时,一般会做缓存来抗大量并发,但当缓存失效的一瞬间,这些大量的并发请求会击穿缓存,直接请求数据库为
- 添加字段的语法:alter table tablename add (column datatype [default value][nul
- 这是个基于three.js的插件,预览地址:戳这里使用方法:1、这个插件的用法很简单,引入如下2个js<script src=&quo
- 对于所有的需求,当你不知道怎么处理的时候,你就先用最简单的方法,或者说的明白一点,用最原始的方法,先实现业务需求再说。一、对提现队列数据表“
- 滚动图片可以说是做网站经常会遇到的,特别是做企业网站,最常用的像产品展示,图片展示等,滚动的好处是吸引眼球,让人一下就注意到。之前本站发了一
- html5带给我们的不仅仅是更多语义丰富的标签,还有更多更牛逼的特性,比如“离线存储”。 对于台式电脑来说,或者它并没有带来什么惊喜,但是对
- 最近被告知,MySQL主从数据库的数据不一致,猜测备库在同步过程中出现了问题,于是,登上备库,使用 mysql> show slave
- 大家好,我是Peter~本文记录的使用seaborn绘制pairplot图,主要是用来显示两两变量之间的关系(线性或非线性,有无较为明显的相
- 1. 安装依赖将PyTorch模型转换为ONNX格式可以使它在其他框架中使用,如TensorFlow、Caffe2和MXNet首先安装以下必
- 直接开始,过程中对每一步可能出现的错误都进行了说明。1、安装好xampp,然后打开终端,输入:mysql -u root -p成功进入了,擦