paho

    0熱度

    1回答

    目前這在paho java庫中不受支持,但我在我們的應用程序中需要此功能。例如,在應用程序啓動時,我們沒有網絡連接,但在30秒左右後,我們建立了連接,因此我希望我的客戶端能夠自動連接。 我的問題是 - 什麼是最好的方法來實現這一目標?我到目前爲止嘗試的是在連接方法出現問題時嘗試重新連接。而且由於我們使用RxJava,我已經計劃執行負責客戶端連接的相同方法。如果我粘貼代碼會更容易。 private

    0熱度

    1回答

    我想運行我的paho mqtt客戶端指定的時間段,而不是永遠。什麼是正確的實施方式? P.S.我想阻塞呼叫,而不是事件驅動loop_start()/ stop()設施 謝謝!

    0熱度

    1回答

    有人可以請我建議我如何在AWS服務器上創建主題?我知道,當我通過提供主題名稱發佈消息時,它會自動創建主題,但有什麼方法可以在服務器上添加所有可能的主題? 在上圖中,我能夠在一個主題(test_topic)發送消息,並在服務器上自動創建。有什麼方法可以一次在服務器上創建所有主題?

    1熱度

    1回答

    我正在致力於HiveMQ Websocket Client,我正面臨與message delivery有關的一些問題。 所以,我碰到過這個詞PUBACK 讓我解釋你對我的理解,然後我會問我的問題。 無論何時我們發送消息QOS1,hivemq服務器都會通過回調PUBACK來確認發件人。 現在,我打算在我的websockets中對onPubackReceived事件進行子類化,但事件在發送消息後未觸發

    2熱度

    2回答

    我只是看着Eclipse PAHO和Mosquitto客戶端庫(MQTT C++庫)的細節。看起來PAHO使用mosquitto MQTT代理,但提供了自己的MQTT客戶端庫。 此外,Mosquitto庫提供了一種爲Mosquitto MQTT代理實現客戶端庫的方法。 我想了解這兩個客戶端庫的主要區別是什麼。 Here它被討論但不能回答我的問題。哪一個比另一個更受歡迎,爲什麼?爲什麼eclipse

    1熱度

    1回答

    我正在用Paho在C++中編寫一個mqtt應用程序。我正在使用Paho.mqtt C庫,可以找到here。 當我在回調函數中收到消息時,它會調用另一個函數來打印消息。我希望能夠循環該功能,直到有新消息到達。 bool start = false; void loopMessage(std::string message){ start = true; while(start)

    0熱度

    2回答

    我使用mqtt協議將傳感器數據的消息發送給蚊子代理。我想要做的是每隔t秒發送一次傳感器數據,但是如果我收到消息並行處理它。是使用time.sleep(),但我認爲這會延遲「on_message」函數。我使用paho-mqtt和python 2.7。關於如何完成這樣的事情的任何想法? 客戶端1號(發送傳感器數據) from mysignals import mysignals import pah

    -1熱度

    1回答

    我有一個應用程序,其中連接到一個mqtt服務器i followed this link並作了一些修改,並與用戶名和密碼連接,如何從該服務器斷開連接 import { Injectable } from '@angular/core'; import { Http } from '@angular/http'; import 'rxjs/add/operator/map'; imp

    0熱度

    1回答

    嘗試在付費 GAE應用程序上運行簡單的MQTT客戶端(不是代理)。然而一個on_connect回調從來沒有發生在以下: worker.py import webapp2 import paho.mqtt.client as paho class WorkerHandler(webapp2.RequestHandler): def on_subscribe(client, user

    0熱度

    2回答

    我正在用eclipse paho java庫使用mosquitto MQ。我希望在訂閱主題並獲取消息之前檢查主題是否存在。我怎麼做 ?