問題タブ [paho]

Androidデバイスからpublishメッセージを送信する方法を知るために、いくつかのチュートリアルに従いました。broker以下は私の試みであり、この時点ではMqttDeliveryTokenAndroid、ライブラリにないようにチュートリアルで提供されているメソッドが見つかりませんでした。

メッセージを正しく送信する方法を教えてください。publishまた、最近更新された Paho Android API へのリンクを提供してください。私が現在取り組んでいるものはPahoWeb サイトからダウンロードされ、いくつかのクラスとメソッドがあり、上記のものが欠落しています。

コード

clear session flage = falseブローカーに接続していないときに、購読している更新された発行済みメッセージを受信できないにもかかわらず、論理的な説明を誰かが持っていますか?

aoremoved フラグを false に設定してアプリを実行し、いくつかの値をトピックに公開し続けました (Android デバイスからブローカーではなく、PC からブローカーへ)。そして、Android デバイスの USB を PC から取り外し、いくつかの値を再度公開し続けました。USB を PC に再度接続すると、そのトピックに最近公開した値が表示されるはずでしたが、値が表示されませんでした。

私が発行しているトピックは、私が購読しているトピックとまったく同じですQoS = 1。

この JS を介して Mosquitto サーバーに接続しようとすると、次のエラーが表示されます。

コンソールから試してみましたが、正常に動作します。Java クライアントをプロバイダーおよびコンシューマーとして試してみましたが、正常に動作します。だから私はそれを機能させるために何をすべきか理解できません。

これはJSです：

これはJavaです（動作中）：

このクラスを使用すると、発生する可能性のあるすべてのイベントへのコールバックを持つオブジェクトIMqttClient()を作成できます。たとえば、client

IDただし、このクラスでは、クライアントごとに を指定することはできません。それはどのように可能ですか？特にあなたがと接続したい場合はclean session = false？

また、オプションとしてMqttConnectOptions設定できるオブジェクトをインスタンス化するときにクラスをチェックし、後でそのようなことを行うことができますが、を指定する方法はありません。server URIclient.connect(opts)ID

を指定するのclienIDは class のみの機能であるため、classおよびMqttAndroidClientを使用する場合は指定できません。IMqttClientIMqttAsynchClient

クライアントを一意に接続する本当の目的は何IDですか?

Eclipse を実行してプログラムをコンパイルすると、一度だけ動作し、最初のプログラムの実行後にもう一度実行しようとすると、次のメッセージが表示されます。

Exception in thread "main" Persistence is already in use

この問題を解決するには、Eclipse を閉じて再度開く必要があります。毎回同じことが起こります。それ以外の場合は、プログラムを 1 回実行できます。投稿されたメッセージが表示されます。

そのエラーは何を意味し、どうすれば修正できますか?

アップデート

コード:

コンソール出力:

以下は、私のJavaプログラムで使用されているインポートです。私がやろうとしているのは、client型を作成し、次のようMqttCientにメソッドを使用することですconnectWithResuls

問題は、日食が上記の嘘を赤い波線で強調していることです。その理由はわかりません。Paho java docs こちらも参照しました。

上記の方法が認識されない理由を教えてください。

輸入品