mqtt例外太多正在发表的文章(32202)

Question

我正在使用paho mqttv3 java客户端通过创建线程来同时发布大约2000个连接的消息.

一段时间后,它开始给MqttException是folows:

reason----- 32202
msg--------Too many publishes in progress
cause------ null

虽然我已经设置了Qos 1.

谁知道为什么我会得到这样的例外？

提前致谢.

Answer 1

我刚刚遇到另一个问题,哪个答案帮我解决了这个问题.

在连接到代理之前,必须使用对象中的setMaxInflight()方法设置更高的MaxInflight值MqttConnectOptions.

默认值设置为10.

原始主题是:发送许多发布消息:正在发布的太多错误

Answer 2

这可能是服务器或客户端的限制。

如果是服务器限制，您应该查看有关如何调整它以处理更多客户端的具体文档。

如果是客户端限制，则不要MqttClient尝试MqttAsyncClient（非阻塞）Java 客户端。

您可以在这里开始查看三个不同的示例

使用阻塞直到操作完成的 API 的示例

SampleAsyncWait展示了如何将异步 API 与阻塞直到操作完成的等待程序结合使用

SampleAsyncCallBack展示了如何使用异步 API，其中事件用于在操作完成时通知应用程序