1.正在进行过多的发布 (32202)
查看了源码,分析原因分析入下:
发布消息的时候qos=1,需要等待broker会ack,由于客户端发送量太大,未能及时抽到broker回复的ack(这一点可能因为网络有延时),但是客户端维持的一个变量—maxinflight,默认值为10,如果以qos=1发送的消息,maxinflight就会+1,当抽到broker回复的ack时,maxinflight-1,所以当客户端发送量太大时,又未能及时收到broker回复的ack,导致达到了maxinflght的值,出现上述问题。
鄙人能想到的临时解决方法如下:
(1) 改qos=0
(2)调整maxinflight值的上限
(3)自己做流量控制
三种方法都各自有着优缺点,需根据不同情况自己确定。
分享到:
相关推荐
连接代理mqtt,订阅发布消息,多个主题多线程订阅。支持断网自动重连
MQTT发布/订阅消息机制
ESP32 Python MQTT断线重连+多线程应用
MQTT服务器的搭建以及mqtt的发布和订阅测试,且说明在搭建时出现的一些坑,以及解决方法。
包启Mqtt发布与订阅两个VS2010工程,实现了Mqtt的发布与订阅功能
MQTT测试客户端 Delphi10.3测试可用,根据网上资料,自己写的客户端。
用于物联网的通用协议Mqtt的订阅/发布测试,在applo,activemq测试通过
mqtt
Mqtt通信协议winform服务端测试小工具
目录 一、简介 ...MQTT 全称为 Message Queuing Telemetry Transport(消息队列遥测传输)是一种基于发布/订阅范式的“轻量级”消息协议,由 IBM 发布。 MQTT 可以被解释为一种低开销,低带宽占用
MQTT测试客户端 Delphi10.3测试可用,与上一个资源类似,实现方式不一样
java中使用消息中间件ActiveMQ的MQTT协议发布消息使用fusesource,fusesource提供三种方式实现发布消息的方式,分别是阻塞式(BlockingConnection)、回调式(CallbackConnection)和Future样式(FutureConnection)
Android中连接MQTT服务器实现发布一个消息推送给订阅者示例代码.rar Android中连接MQTT服务器实现发布一个消息推送给订阅者示例代码.rar Android中连接MQTT服务器实现发布一个消息推送给订阅者示例代码.rar
本人写的电力行业MQTT测试工具,单文件免安装,随存随用。支持MQTT报文发送、接收,对接收的MQTT报文进行抓取、过滤、筛选、查找、保存等操作,支持将json报文进行判断和解析,若报文正确能自动格式化显示。主要适配...
此jar包为jmeter 的mqtt连接服务器压力测试工具。本人使用的是MessageBufferPacker对数据加密所以没有传入参数,修改自己修改
winForm中使用MQTT收发消息,不懂的可以联系qq:502701291
python 3.7 写的mqtt 程序,多进程源码 ...pyqt5 界面实现连接,订阅发布,消息展示,参数存储 主进程 ,监听进程,mqtt_client.py 界面interface.py MQTT.py 基本功能实现。其实使用多线程比多进程更加合理。
Springboot集成MQTT,订阅发布一体,提供接口可发布主题。____________________________
mqttjs 的测试代码,很好用,谢谢,要支持支持原创,转发。
通过js 实现mqtt消息实现,本资源只有js部分,服务端是java写的,可参考网上的也可以去下载我的另一个资源。