問題タブ [mosca]

mosca mqtt ブローカーを実行しています。Python クライアントから paho-mqtt を使用して接続します。コードで並列に実行する 2 つのスレッドがあります。1 つはメッセージを受信し、もう 1 つは公開します。

パブリッシュが発生するたびに、クライアントは切断されます。

行にコメントを付けてみましたclient.publishが、それでも切断が発生しています。したがって、この切断はマルチスレッドまたはブローカー自体の問題に関係しているのではないかと思います。誰でもこれで私を助けることができますか？

mosca mqtt ブローカーを稼働させています。Python クライアントからブローカーに接続し、特定のトピックをサブスクライブしてデータを受信します。データの受信中にデータ損失の問題に直面しています。私のコード

そしてコンソール出力

初めて切断されたとき、再接続され、1 秒以内にすぐにメッセージの受信を開始しました。しかし、2 回目の切断では、最後のメッセージと切断コールバックから出力された時間の間に 1 分の時間差があります。この 1 分差のデータは失われます。しかし、MQTT レンズを使用してデータを確認すると、ブローカーのアドレスに接続して同じトピックにサブスクライブすると、その 1 分間のデータも表示されます。したがって、ブローカーによって送信されているデータがありますが、python クライアントはそれを受信できません。1 分後に切断された場合、その 1 分間でそのデータを受信できないのはなぜですか。誰かがこれで私を助けることができますか?

だから、私は主題のためのプロジェクトを作っています.1つはローカル/温度で、もう1つはローカル/時間で、2つの変数を発行するファイル(weather.js)があります。私はそれらの両方にサブスクライブし、値 (blinds.js) で動作するファイルを作成していますが、それらが混在しています。温度と時間を同時に送信し、サブスクライバーで最初の値を温度ローカル変数 (blinds.js 内) に与え、次に時間ローカル変数に与えます。私に何ができる？

これが weather.js ファイルです。

これがブラインドの js ファイルです。