paho

    0熱度

    1回答

    連接這是我的泛美衛生組織JavaScript客戶端代碼 client = new Paho.MQTT.Client(host, Number(port), clientId); client.onMessageArrived = onMessageArrived; client.onMessageDelivered = onMessageDelivered; cli

    6熱度

    4回答

    清除了一次性的消息。我的問題是設備開發人員發佈了大量垃圾消息。我有一個java/paho代碼庫,我想修改它以根據需要自動執行此操作,但似乎無法發佈零字節消息。我試過 client.publish(topic,null); 但這似乎並不奏效。 如何刪除一切,連接質量的任何建議。

    0熱度

    1回答

    我試圖創建一個允許NativeScript應用程序連接到MQTT服務器的插件。當我嘗試運行應用程序,我得到我的應用程序出現以下錯誤: java.lang.RuntimeException: Unable to start activity ComponentInfo{org.nativescript.testMQTT/com.tns.NativeScriptActivity}: com.tns.N

    0熱度

    2回答

    我見過很多paho客戶端讀取傳感器數據然後發佈的例子,例如https://github.com/jamesmoulding/motion-sensor/blob/master/open.py。我見過的都沒有啓動網絡循環,如https://eclipse.org/paho/clients/python/docs/#network-loop中所建議的。我想知道如果網絡循環是不必要的發佈?也許只有當我訂

    1熱度

    1回答

    我對某些應用程序使用MQTT客戶機Java庫,我認爲我正在以不良方式重新連接到Broker。現在我有一個處理MQTT操作的類,如連接,斷開連接,發佈和訂閱。 public class MqttConnection { private static final String BROKER_ADDRESS = Preferences.getProperty("mqtt-address");

    0熱度

    1回答

    我試圖通過使用Kii Cloud service從瀏覽器建立MQTT連接,但失敗了。 你有什麼建議嗎? [事件] 我試圖建立通過終點這是我從紀伊雲MQTT有一個連接,但返回以下錯誤。 ※我爲MQTT客戶端使用paho。 WebSocket連接到 'WS:// [主機名是我從基爾加丹雲了]:[端口這是我從基爾加丹雲有]/MQTT' 失敗:WebSocket的握手過程中的錯誤:淨:: ERR_CONN

    1熱度

    1回答

    我採取的是聽一個特定的主題,當一個新的消息由我ESP8266公佈的反應,因此程序。當收到來自ESP8266的新消息時,我的程序將觸發回調並執行一組任務。我在回調函數中發佈了兩條消息,回到了Arduino正在聽的話題。但是,只有在函數退出後纔會發佈消息。 謝謝你提前的所有時間。 我曾嘗試使用環路(1)與所述回調函數內1秒的超時。該程序會立即發佈消息,但它似乎陷入循環。有人能給我一些指針,我怎樣才能在

    1熱度

    1回答

    我已經安裝了蚊子,並在沒有問題的終端中使用,也安裝了paho for C++,蚊子和paho工作得很好。 然後通過pip爲python安裝paho。現在我試圖用這段代碼來測試它,但on_message和on_connect函數永遠不會被調用。我在做 mosquitto_pub -h localhost -t "test" -m "This is a message" 而python腳本運行,但它不

    3熱度

    1回答

    MQTT問題: 嗨,我試圖建立多樹莓派之間的MQTT網絡(從2開始)。 我有一個覆蓋有熱敏電阻傳感器的樹莓派(RPi-A)MQTT客戶端,以及一個作爲我的網絡集線器的覆盆子(RPi-B)MQTT經紀人/客戶端。 通過python腳本,我想每隔30分鐘從RPi-A通過MQTT發送溫度到主題傳感器/數據並由RPi-B接收。 當RPi-B通過主題傳感器/數據接收到來自RPi-A的消息時,我希望它通過MQ

    -1熱度

    1回答

    我一直在試圖發佈和分支圖像使用蚊子在R-pi。 這是pub.py import paho.mqtt.client as mqtt def on_publish(mosq, userdata, mid): mosq.disconnect() client = mqtt.Client() client.connect("test.mosquitto.org