問題タブ [paho]

mosquittoでストレステストをしたいので、以下のようなコードを作成します

しかし、実行中にいくつかのエラーが発生EOFExceptionし、一部のクライアントが切断されました。1 つの mosquitto サーバーで同時にメッセージを発行できるクライアントの数と、ストレス テストを行う方法を知りたいです。ありがとう！

詳細な例外は次のとおりです。

そして、mosquitto サーバーからいくつかのログを見つけました。

助けてください、ありがとう！

私は Android 4.3 で paho を使用しており、ホストされている Eclipse Mosquitto サーバーと通信していますm2m.eclipse.org。クライアントをサービスにラップし、 を使用しAlarmManagerてキープアライブ メッセージをサーバーに送信しています。サービスがリッスンしているトピックにメッセージを送信する別のクライアント (mqtt httbridge を使用するか、paho を使用する別の Android デバイス) があります。

すべてがスムーズに動作します...動作しなくなるまで。ある時点で、Android サービスがメッセージの受信を停止します。キープアライブは送信を続けます。すべて問題ないように見えますが、メッセージが届きません。mosquitto のローカル インスタンスでこの動作を複製することはできませんでした。これは、Eclipse 側の何らかの構成であると思わせますが、任意のポインターを適用します。

QoS は 0 です。

ubuntu で eclipse paho クライアントを使用しており、緯度、経度、タイムスタンプの情報を JSON 形式で MQTT ブローカーに送信しようとしています。それ、どうやったら出来るの？

この記事を見つけましたが、完全ではありません。

MQTT 接続を行う Flask を使用して、Python で Google Cloud Platform アプリを正しくしようとしています。を実行して paho python ライブラリを含めましたpip install paho-mqtt -t libs/。ただし、アプリを実行しようとすると、MQTT に接続しようとしなくても。IP アドレスのチェックで奇妙なエラーが発生します。 RuntimeError: error('illegal IP address string passed to inet_pton',)

ライブラリ内の何かがremote_socket問題を引き起こしているようです。これはセキュリティ上の問題ですか? 無効にする方法はありますか？

関連コード:

完全なスタック トレースと同様に:

ありがとう！

ubuntu で eclipse paho 'C' クライアントを使用しており、緯度、経度、タイムスタンプの情報を JSON 形式で MQTT ブローカーに送信しようとしています。それ、どうやったら出来るの ？

参照: http://www.eclipse.org/paho/clients/c/

トピックとキューで activeMQ 5.9.1 を使用する Java Swing アプリケーションがあります。

今、私の意図は、そのスイング アプリケーションを Web に移行することです。そのため、activeMQ + MQTT (paho) javascript ライブラリを使用していくつかの証明を作成しています。

私はactivemq.xmlでそれを有効にしました:

また、いくつかのトピックをリッスンするために、MQTT (paho - http://eclipse.org/paho/clients/js/ ) を使用していくつかの例を実装しました。

トピックへの応答は正しく受信されますが、復元されたメッセージは Java String オブジェクト参照です。

JavaアプリケーションがactiveMQトピックに直接書き込む場合、フレンドリーなメッセージを受け取る正しい方法を知っている人はいますか?

私はこれに慣れておらず、このプロトコルについて学んでいます。MQTT に関する wiki を読みながら。最初の行「MQTT[1] は、TCP/IP プロトコルの上で使用するパブリッシュ/サブスクライブ ベースの「軽量」メッセージング プロトコルです。」

これは、MQTT がトピックのみをサポートし、キューをサポートまたは操作しないことを意味しますか?

なぜなら、利用可能なクライアント API (fusesource と paho) でチェックアウトするからです。キューのクライアント API が見つかりません。

私は Android とサービスが初めてです。私の目標は、サブスクリプションを設定し、トピック文字列に関する出版物を作成できるようにすることです。トピック文字列とクライアント ID は、テキスト フィールドの入力を解析した後に設定されます。私はPaho MQTT サービスを使用しています(ソースをダウンロードして JAR をビルドしました)。

次の場合、 で Null ポインタ例外が発生しc.publish()ます。は、配信トークンが取得されているメソッドでのlogcat例外を示しています。IMqttDeliveryToken publish(String topic, MqttMessage message, Object userContext, IMqttActionListener callback)MqttAndroidClient

このサービスを使用して発行および購読する方法を教えてください。サンプル プロジェクト (Paho Android から) を参照しました。LWT のレイアウト ( activity_publish.xml) はパブリケーションにも使用されているようで、LWT とパブリッシュはマージされているようです。

私の目的は、MQTT デバイス間のメッセージ レイテンシ (スループットではない) を測定することであり、コード ハックに関するフィードバックを探しています。セットアップは簡単です。2 つのエンドポイントとして機能する 1 つのデバイス (2 つのターミナル セッションを備えた古い Linux PC。1 つはサブスクライバーを実行し、もう 1 つはパブリッシャー サンプル アプリを実行) と のデフォルト ブローカーtcp://m2m.eclipse.org:1883)。src/samplesフォルダの C 言語パブリッシュ/サブスクライブ サンプル アプリに、タイム キャプチャ コード フラグメントを挿入しました。

以下、変更点です。フィードバックをお寄せください。

サブスクライブ サンプル アプリの変更点MQTTAsync_subscribe.c( )

msgarrvd(メッセージが到着しました) 関数の先頭に以下の行を挿入しました

パブリッシュ サンプル アプリへの変更MQTTAsync_publish.c( )

onSend(callback) 関数の先頭に以下の行を挿入しました

これらの変更により (パブリッシャーで配信が確認された時刻からメッセージがサブスクライバーに到着した時刻を差し引いた後)、1 ミリ秒から 0.5 ミリ秒の間の時間が得られます。

質問

これはレイテンシーの大まかなベンチマークとして意味がありますか?

これは往復時間ですか？

往復時間は適切な球場でしょうか? 少ないほうがいい？もっと？

一方通行の時間ですか？

別の方法でレイテンシ ベンチマークを設計する必要がありますか? 大まかな測定が必要です（XMPPと比較しています）。

デフォルトの QoS 値 (1) を使用しています。変更する必要がありますか？

パブリッシャーが接続 (および切断) するのに一定の時間がかかります。これらを追加する必要がありますか？

Mosquitto Mqtt と paho API を使用して、Android デバイスでプッシュ メッセージを受信して​​います。しかし、ネットワーク接続が変更されるとすぐに、メッセージの受信が停止します。簡単なテスト ケースで問題を再現する手順は次のとおりです。

1) 簡単なアクティビティを作成します。

2) アクティビティの起動時に、paho API を介して mosquitto テスト サーバー (test.mosquitto.org:1883) に接続します。

3) トピックを購読します。

4) トピックにメッセージを発行します。

結果: Mqtt クライアントは、トピックに発行されたすべてのメッセージを受信します。今

5) モバイルのインターネット接続を無効にする (モバイルデータ)

6) トピックにメッセージを発行します。

7) インターネットに再接続します。

結果:クライアントは、インターネット接続が無効になった後に公開されたメッセージを受け取りません。

KeepAliveIntervalは高い値 (30 分) に保たれているため、インターネットに再接続した後、すべてのメッセージを受信する必要があります。

同じユース ケース (同じコード) は、ラップトップでインターネットを無効にしてユース ケースを実行する単純な Java プロジェクト (Android 以外) で機能しています。

Androidデバイスで動作しない理由はありますか??? 何か不足していますか？

ノート：

1) mqtt-client-0.4.1 の使用

2) Android ターゲット API レベル 11

3) テスト中にデバイスをスリープ モードにしない。

4) connectionLost コールバックで呼び出しを取得せず、mqtt コールバックの 4 つのスレッドすべてがテスト ケース全体で実行されています。つまり、mosquitto サーバーへの接続はそのままです。