mqtt

    0

    1答えて

    MQTTブローカーに接続するためにPaho MQTTPacket組み込みC++ライブラリーを使用するC++コードがあります。そのブローカーがio.adafruit.comの場合、それは完璧に機能します。しかし、私自身のMosquittoインスタンスが自分のRaspberry Piで動作している場合、接続は失敗します。私はMQTT :: Clientで、MQTTClient.hにこのラインにそれを絞

    0

    1答えて

    私の状況に該当する解決策を見つけることなく何時間もこの問題について読んでいます。私は、インクルードされたファイルやライブラリに関連する問題があるかもしれないと理解していますが、実際に何が間違っているかを見つけることはできません。 MQTTクライアントライブラリを使用するArduinoスクリプトです。これは、古いPubSubClient.h libで美しく動作します。 今、私は最近のものでlibを更

    1

    1答えて

    私はモスキートブローカーとmqttをインストールしたラズベリーパイを持っています。 Piはセンサーに接続されており、このデータをadafruit IOT protalに送信する必要があります。私はpiが接続されているときにすべてのデータを送信することができますが、piがオフラインになると、私は20-30秒間しかデータを送信できません。 piが2〜3分以上オフラインの場合、そのデータはポータルに送信

    0

    1答えて

    Mosquitto MQTTブローカー上の選択されたユーザーのみに公開を制限する方法はありますか? 私はいくつかのユーザーが購読できるようにしたい、いくつかの他のユーザーが公開できるようにしたいと私はこれらの2つのグループのユーザーを分離する必要があります。 username:passwordでアクセスできる許可制御があることは知っています。しかし、ユーザーに役割を割り当てる方法は私には分かりませ

    0

    1答えて

    私はMQTTとMQTT.jsで遊んでいます。私はMQTTブローカーを実行していますが、今は複数のトピックを購読したいと思います。 1つのトピックは問題ありませんが、複数です。 私は、これら2つのトピックがあります。私は、このコードはconsole.logではこれら二つのトピック var mqtt = require('mqtt'); var client = mqtt.connect('mqtt

    0

    1答えて

    私はMosquittoのドッキングイメージを使ってローカル開発を行っています。それはうまくいっていますが、ソースコードを更新せずに以下に示すようなカスタムログをドッカーが作成する出力に追加する方法があるかどうかは疑問です。たとえば、どのトピックやメッセージが公開されているかなど、接続されたクライアントに追加情報を追加しようとします。これは生産のためのアイデアではなく、ただ私が興味があるものです。

    1

    2答えて

    MQTTメッセージを最初のサブスクライバが受信した後に削除して、他のサブスクライバがそれを読み取れないようにする方法はありますか? この奇妙な質問を明確にするには: 私は4つのJBossインスタンスを扱わなければなりません(私はこのアーキテクチャーの責任を絶対に負いません)。彼らはお互いの鏡です。だから、すべての人が特定のトピックを購読する仕事をしています。このトピックのメッセージは、データベース

    -4

    2答えて

    私は、アプリケーションが同時にリアルタイムの保全を保証する必要があるpublish.subscribe通信モデルを使用する必要があることを探しています。

    0

    1答えて

    subscribe()が呼び出されると、nodemcuによってメッセージを受信する際に問題が発生します。メッセージを送信中にpublish()が問題なく動作しています。ブローカーはモスキートです。私もcallback()を使用しましたが、応答はありません。ここにコードがあります。それは実際にカードタグを読み取り、ブローカに送信し、送信されたカードタグに基づいて、Linux上の別のクライアントがsu

    -1

    1答えて

    私の目標は、2台のAndroidデバイス間のピアツーピア接続を確立することです。この目標を達成するために、私はプロトコルmqttを選択しました。 最初のデバイスでブローカーを開始し、最初のデバイスに接続する2番目のブローカーを開始したいとします。私はこの方法でブローカーを作成します。 私は、サーバーを作成しますが、デフォルトURIがTCPであるその後のGradleへ dependencies {