Библиотека MessageArrived MQTT paho

привет, ребята, я новичок, и я пытаюсь внедрить библиотеку paho, мой клиент paho получает сообщения в messageArrived по определенным темам, и я читал, что функции messageArrived синхронны, то есть по одному? Правильно !

проблема в том, что мой кот останавливается когда-то, мне нужно перезапустить его, и я вижу журнал в catalina.err

The web application [] is still processing a request that has yet to finish. This is very likely to create a memory leak. You can control the time allowed for requests to finish by using the unloadDelay attribute of the standard Context implementation.

и мой процесс немного длинный, я думаю, потому что мне нужно проверить сообщение в соответствии с моим требованием, и я также попытался создать несколько предупреждающих SMS с ними в той же функции, так что это может занять некоторое время.

так как я должен управлять им, я прав? или совсем неверная догадка??

любое предложение будет большим.


person Rawat    schedule 21.10.2016    source источник


Ответы (1)


Правильный способ обработки длительных задач, использующих сообщения MQTT, — создать пул потоков и передать обработку этих сообщений в пул потоков из метода onMessageArrived().

java.util.concurrent. ThreadPoolExecutor, вероятно, является вашей лучшей отправной точкой.

person hardillb    schedule 21.10.2016