2

我正在使用带有mqtt-paho版本 4.0.4 的 Spring Integration 来接收有关指定主题的 MQTT 消息。

当应用程序接收到巨大的负载时，我发现有时应用程序会断开与 IMA (mqtt) 的连接，这在 1 个 Lac 记录的范围内发生了 3 次。但它恢复了连接并开始使用之后收到的消息。IMA 重新连接没有问题。

在此测试期间，我还遇到了其他一些问题。

当应用程序持续负载时，有时应用程序会停止接收消息，我们可以看到屏幕上闪现一条消息，即

May 04, 2015 2:45:29 PM org.eclipse.paho.client.mqttv3.internal.ClientState checkForActivity
SEVERE: gvjIpONtSpP: Timed out as no activity, keepAlive=60,000 lastOutboundActivity=1,430,730,869,017 lastInboundActivity=1,430,730,929,151

在此之后，我们可以看到即使通过实用程序推送连续负载，应用程序也没有收到任何消息。这种行为我发现了三遍。

At around 40K.
At around 90K.
At around 145K.

应用程序实际上停止接收消息并没有一致的点或数字。请让我知道是否有人曾经面对并解决过这个问题。

4

1 回答 1

0

在转向生产之前，我们在性能测试和 MQTT Paho 客户端性能/耐用性测试期间遇到了同样的问题。问题出在代理端，在设置调整后，IMA 代理能够消费数百万条消息而没有拒绝。

请查看 IMA 配置 Web 控制台上的最大缓冲区参数。以及超限行为策略（如何处理超过指定阈值发布的消息）：拒绝、翻转等。

于 2016-09-01T19:19:09.463 回答