スレッドを作成することにより、約2000の接続で同時にメッセージを発行するためにpaho mqttv3 Javaクライアントを使用しています。
しばらくすると、MqttException が発生し始めます。
reason----- 32202
msg--------Too many publishes in progress
cause------ null
私はQos 1を設定していますが。
なぜそのような例外が発生するのか誰にもわかりますか?
前もって感謝します。
これは、サーバー側またはクライアント側の制限になる可能性があります。
サーバーの制限である場合は、より多くのクライアントを処理するように調整する方法について、特定のドキュメントを参照する必要があります。
それがクライアントの制限である場合は、代わりに(ノンブロッキング) Java クライアントをMqttClient
試してください。MqttAsyncClient
ここで3つの異なる例を見始めることができます
操作が完了するまでブロックする API を使用するサンプル
SampleAsyncWaitは、アクションが完了するまでブロックするウェイターで非同期 API を使用する方法を示しています。
SampleAsyncCallBackは、アクションの完了時にイベントを使用してアプリケーションに通知する非同期 API の使用方法を示しています。