MessageArrived MQTT paho library

Question

こんにちは私は初心者です。私はパホ・ライブラリーを実装しようとしています。私のパホ・クライアントは特定のトピックでmessageArrivedでメッセージを受け取り、そのmessageArrived関数は同期しています。右 ！

問題は、私のTomcatがいつか私はそれを再起動する必要があり、私は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を作成しようとしたので、これは時間がかかることがあります。

どのように管理すればいいですか？または完全に間違った推測？

どのような提案も素晴らしいでしょう。

Answer 1

MQTTメッセージを消費する長時間実行されるタスクを処理する正しい方法は、スレッドプールを作成して、onMessageArrived()メソッドからそれらのメッセージの処理をスレッドプールに渡すことです。

java.util.concurrent.ThreadPoolExecutorはおそらくあなたの最善の出発点です。