客户端消费能力不足

EMQX
1

在使用emqx进行了压测，一个服务一个连接，同一个topic，每秒900条消息，消费端会在1分钟的时候Lost Connection:已断开连接。然后一个服务六个连接 使用共享订阅，也是在1分钟的时候Lost Connection:已断开连接。很疑惑。不知道该如何解决这个连接丢失的问题。使用的工厂类为MqttPahoClientFactory 和MqttPahoMessageDrivenChannelAdapter

2

image
image2052×852 219 KB

3

请参考下 常见问题汇总
另外提供下 EMQX 版本和日志信息。

4

版本是4.3.11 2023-12-19T10:45:44.202026+08:00 [warning] platform-wrkj-ctuav-flyData2-localhost-1702953897942-RmUiIDwC@58.213.83.90:49995 [MQTT] socket_error: timeout
2023-12-19T10:45:44.395500+08:00 [warning] 54adcad7-91e9-4825-85eb-9e95ad5d4bfb1702918468191@27.204.39.90:56331 [Channel] Client 54adcad7-91e9-4825-85eb-9e95ad5d4bfb1702918468191 (Username: ‘4TADKAQ000004B’) login failed for not_authorized
2023-12-19T10:45:45.198801+08:00 [warning] platform-wrkj-ctuav-flyData0-localhost-1702953897858-yn5SePJJ@58.213.83.90:49993 [MQTT] socket_error: timeout
2023-12-19T10:45:45.447122+08:00 [warning] 54adcad7-91e9-4825-85eb-9e95ad5d4bfb1702918468191@27.204.39.90:56332 [Channel] Client 54adcad7-91e9-4825-85eb-9e95ad5d4bfb1702918468191 (Username: ‘4TADKAQ000004B’) login failed for not_authorized
2023-12-19T10:45:46.203946+08:00 [warning] platform-wrkj-ctuav-flyData1-localhost-1702953897921-7BQ5plzQ@58.213.83.90:49994 [MQTT] socket_error: timeout
2023-12-19T10:45:46.520549+08:00 [warning] 54adcad7-91e9-4825-85eb-9e95ad5d4bfb1702918468191@27.204.39.90:56335 [Channel] Client 54adcad7-91e9-4825-85eb

5

image
image2518×792 99.6 KB

这边就是我连接丢失的日志信息

6

版本是4.3.11

7

目前我们的项目使用的是springcloud的，然后就使用一个客户端服务的一个连接消费这个主题/auto/+/+/message，然后就想在这一次客户端使用多个连接client及共享订阅$queue//auto/+/+/message去负载均衡消费。但是结果和一个客户端一个连接一样。都是在消息涌入后1分钟失去连接。消息量大概是900条/秒。

8

先尝试用其他客户端工具例如 MQTTX/MQTTX-cli/emqtt-bench 订阅消息，看看会不会断。
如果没有的话可能要继续调查下你的客户端/网络方面有没有问题。

MQTTX
emqtt-bench