問題タブ [paho]

形式の URL を使用して Eclipse paho (1.0.2) Java ライブラリーを使用して MQTT ブローカーに接続しようとするとtls:// ...、IllegalArgumentException. 驚くべきことではありませんが、コードでは明確に禁止されています (ssl は利用可能ですが)。接続は、MqttConnectOptions でこのメソッドを呼び出します

この制限を回避する方法はありますか? あるいは、これがブロックされている何らかの理由がありますか? これらの URL でこのクライアントをどのように使用しますか? どんな助けでも感謝します。

Mqttを使用してサーバーからメッセージを受信するためにpaho androidサービスクライアントを使用しています。アクティビティが実行されているとき、アプリケーションは送信と受信の両方で正常に動作しますが、アプリケーションが実行されていないときに公開されたメッセージは受信されず、Callback クラスは実行されません。

コンテキストに問題がある可能性があり、Callback がアクティビティ コンテキストに関連付けられているか、何らかの方法でアプリケーションを起動して、メッセージをデータベースに書き込んでから再びスリープ状態にする必要があると思います。

これが私の MqttCallback の実装です。

私のクライアントのインスタンス化は次のとおりです。

両方に送信されるコンテキストは、私の MainActivity (これ) のコンテキストです。

ガイダンスをいただければ幸いです。

よ、みんな。したがって、私は Python には比較的慣れておらず、MQTT の完全な初心者です。そこで、MQTT を介して 2 つのプログラムを簡単に接続しようとしています。プログラムの 1 つがパブリッシャーです。

したがって、基本的にパブリッシャーはキー入力を読み取り、それをブローカーに送信します。そして、クライアント プログラムはキー ストロークを読み取り、それに応じて反応することになっています。

これは単純なテスト プログラムですが、MQTT ペイロードを「読み取ろう」とするのに苦労しました。

Moquette MQTT ブローカーをセットアップし、Eclipse Paho クライアントに接続しました (これを と呼びますpaho1)。in/#トピックへのサブスクライブ。

別の Paho クライアント (これを と呼びます) をもちろん別のクライアント ID で作成し、トピックpaho2を使用してブローカーに公開しました。in/device

最初に、パケットは正常に配信されました。しかし、paho2ブローカーとの接続を切断して再接続し、同じパケットを送信すると、paho1.

なぜこれが起こっているのだろうか。私の Paho クライアントの設定はqos = 0(1 と 2 も試しました) です。

ブローカーのログを見ていたら、以下のようになっています。成功すると、自分のプロトコル バージョンがログに出力されます。

デバイス側とアプリケーション側の両方で、Eclipse Paho Lib (org.eclipse.paho.client.mqtt3-1.0.2.jar) を使用して Internet of Things MQTT サーバーに公開/サブスクライブする Java アプリケーションを作成しています。

接続は両方の資格情報タイプでうまく機能し、同じように公開されているようです...エラーが発生するのは購読です:

mosquitto_sub コマンドラインで試してみると、次のようにループします。

等々。

MqttAsyncClient を使用して Java から試行すると、subcribe() メソッドは返されますが、waitForCompletion() メソッドはすぐにスローします。

これは私が実行しているコードです:

その後：

また、このエラーにより、lib は AsyncClient によって永続パス ユーザーを解放せず、JVM を停止してそのパスを手動でクリアするまで、再試行のたびに「Persistence Already in Use」例外が発生しますが、これはライブラリのバグのようなものです。

残念ながら、IoT 側の mqtt サーバーにアクセスして、そこで何が起こっているのかを理解することはできません (または方法がわかりません)。

何か案は？ありがとうございました

Spring の統合ライブラリを使用して、mosquitto に接続してメッセージの読み取り/送信を試みています...しかし、理解できないことがいくつかあります。

1 - アプリを初期化するとき、アプリは mosquitto に接続しますが、mosquitto は数秒で同じ ID を持つ同じアプリから何百もの接続要求を受け取ります。これはログの例です:

2 - この構成を使用して mosquitto からメッセージを取得できません:

春の XML :

カスタム アダプター:

送信されたメッセージが到着したトピックを知る必要があるため、サービスアクティベーターを使用していないため、 Spring Integration DocsMqttPahoMessageDrivenChannelAdapter内で言及されているようにラップしました

何か提案はありますか？

Androidで外部サービス(別のjarにある)ファイルをバインド解除する適切な方法は何ですか?

org.eclipse.paho.android.service-1.0.2.jarマニフェスト ファイルでサービス ( にある) を次のように宣言します。

サービスソースはこちら

そして、サービスは適切に実行されます。ただし、アプリを終了するとエラーが発生し、検索を行った後、アクティビティのメソッドServiceConnectionLeakedを呼び出す必要があることがわかりました。unbindService(...);onDestroy()

ログ：

ただし、サービスを手動で開始するわけではないため、ServiceConnection渡す必要はありません。unbindService()そのサービスを取得してServiceConnectionバインドを解除する方法はありますか?

Mqtt (Paho)​​ を使用して Android アプリケーションを実装しています。ワイルドカードを含むサブスクライブされたトピックと、クライアントが公開した実際のトピックを一般的に比較する必要があるコンポーネントがいくつかあります。

私はそれを理解していないだけで、「初歩的な」正規表現スキルも役に立ちません...

Paho/Java MQTT にユーティリティ クラスがあるかどうかを確認する

「SENSOR/TEMPERATURE/+/DEGREE/#/ID」（サブスクライブトピック）

に適用されます

「SENOR/TEMPERATURE/GARDEN/DEGREE/CELSIUS/ABOVEZERO/ID」（本題）？

誰かがそれを行うための最良の方法を知っていますか?

ありがとうございました！

編集：こんにちは-これは正しいはずだと思います