問題タブ [moquette]

それで、Google App Engine プラットフォームで MQTT ブローカーを実行できるかどうか疑問に思っていましたか? それに関する情報が見つかりませんでした (または、間違ったキーワードを使用している可能性があります)。

Java で GAE を実行しているので、バックエンドを使用して GAE で MQTT ブローカーを実行する方向に進みたいと思います。

編集: さらに調査を行ったところ、Moquette は Java で実行されているようです。誰かが GAE で Moquette を実行した経験がありますか?

EDIT2: わかりました。Moquette の例は、GAE では利用できない OSGi コンテナーを使用して実行されているようです。GAE でこのサーバーを起動するスクリプトを探しています。

MQTT クライアント通信用に Android 内に Moquette/Mosquitto ブローカーをデプロイできますか?

Android 内に Moquette/Moquetto ブローカーをデプロイしたいのですが、1 つの MQTT クライアントがそのブローカーを使用して別のクライアントと通信します。

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

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

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

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

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

私は moquette mqtt ブローカーを使用しており、実装と MQTT ブローカーを理解しようとしています。個人的なプロジェクトのためにブローカーにいくつかの変更を加えたいと思っています。

デバイスが PUBLISH メッセージをブローカーに送信し、ブローカーがサブスクライバーにメッセージを配信できない場合にどうなるか知りたいです。プロトコルは、PUBACK がパブリッシャーに送り返されることを示しています。moquette のソース コードでは、この PUBACK はメッセージをサブスクライバーに転送した後に送信されるようです。

sendPubAck() 関数をコメントアウトして、メッセージが正常に発行されなかったことをシミュレートしたので、パブリッシャーがメッセージを再度発行すると想定しました。ただし、受信メッセージ ハンドラー関数の横に print ステートメントを追加すると、パブリッシャーからブローカーに定期的に送信される PINGREQ メッセージしか表示されません。パブリッシュ メッセージが表示されません。

私の質問は次のとおりです。クライアント デバイスは、メッセージを再発行するタイミングを正確にどのように決定しますか? sendPubAck() 関数をコメントアウトしても、パブリッシャーはメッセージを再送信しないようです。

MQTT は初めてで、AWS EC2 に MQTT MOquette を実装しようとしています。マシンにブローカーの構成とインストールを試み、クライアントから接続してテストすることができましたが、Aws EC2 インスタンスから同じことを行うと、iポート 1883、8080 が 0.0.0.0 の IP アドレスをリッスンしていることがわかりますが、クライアントから接続すると接続できません。

ローカル マシンでホストを構成するときに、ホストとポート 1883、8080 に 0.0.0.0 を指定し、AWS サーバーでは、ホストとポートのプライベート IP を 1883、8080 に指定しました。1883 と 8080 で tcp を許可するルールをセキュリティ グループに追加しました。 .

私の質問は、「ec2-XX-XX-XXX-XX.us-west-2.compute.amazonaws.com」のようなプライベート ip または aws url のような AWS で使用する必要があるホスト値と、url とは何かです。 「tcp://ec2-XX-XX-XXX-XX.us-west-2.compute.amazonaws.com」またはIPのようなクライアントからブローカーにアクセスできました

ここで何が間違っているのでしょうか?? この問題で立ち往生

皆さんありがとう

以下のコードを使用して、MQTT にデータを公開およびサブスクライブしようとしています。

しかし、MQTT には問題なくデータを公開できます。トピック名が /call/subscribecall のデータを公開すると、null ポインター例外が発生しますmessage.getPayload();が、サブスクライバーはデータを正しく送信します。

サブスクライバーがデータを送信する代わりに null を取得するのはなぜですか? 購読コードがデータを取得していないようです。

私はどこで間違いをしていますか？

http と mqtt の両方の機能を一緒に使用したかったので、以下に示すように moquette と一緒に tomcat を使用しようとしましたが、最終的に "java.net.BindException: Address already in use" が発生しました。何か良い方法があれば教えてください。

設定ファイルは次のようになります

サーバー.xml

Android 用のmoquetteブローカー (サーバー)を見つけましたが、Android アプリで実行できません。Android Studio でこのブローカーを使用して、クライアントでサンプルアプリを作成するのを手伝ってくれる人はいますか?

ソース コードを git からダウンロードし、dir 'broker' 'netty_parser' および 'parser_commons' をモジュールとして Android プロジェクトに追加しました。

「moquette」ドキュメントには、次を追加するように記載されています

settings.gradle に入れ、次にサーバーを起動するには

それは与えます

これを行う正しい方法は何ですか？

Android で利用できる他の MQTT ブローカー (サーバー) はありますか?