2015-05-04 6 views
2

Я использую интеграцию Spring с mqtt-paho версии 4.0.4. Для получения сообщений MQTT по указанной теме.Mqtt paho с использованием Spring интеграции прекращает обработку сообщений по теме по определенным запросам на загрузку

Когда приложение получает огромную нагрузку, я обнаружил, что иногда приложение отключает связь с IMA (mqtt), и это случалось три раза в промежутке из 1 записи Lac. Но он восстанавливает возможность подключения и начинает принимать сообщения, полученные там после. Не было проблем с повторной связью 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. 

Нет постоянной точки или цифр, где приложение фактически прекращает получать сообщения. Пожалуйста, дайте мне знать, если кто-то столкнулся и решил это раньше.

+0

Не могли бы вы протестировать свое приложение с помощью последней интеграции Spring - '4.1.3'? –

+0

Спасибо, что поместили ваше драгоценное время, я бы сделал это, чтобы решить эту проблему на этой версии? у тебя есть идеи. –

+0

Извините, нет идей. Проблема действительно может быть в Paho, а не в Spring Integration. Я думаю, что некоторые тестовые примеры для воспроизведения будут полезны. –

ответ

0

У нас была та же проблема во время тестирования производительности и во время тестирования производительности/долговечности клиента MQTT Paho, прежде чем перейти к производству. Проблема была на стороне брокера, после настройки настроек, IMA-брокер смог потреблять миллионы сообщений без отклонений.

Ознакомьтесь с параметром максимального буфера на веб-консоли конфигурации IMA. И политика избыточного поведения (что делать с сообщениями, опубликованными за указанный порог): отклонение, опрокидывание и т. Д.