broker

    1熱度

    1回答

    我是MQTT協議新手。在我閱讀文檔時,我看不到任何刪除已發佈主題的功能。我的目的是讓發佈者刪除已發佈的主題。我錯過了mqtt文檔中的某些內容嗎?任何建議?謝謝 !

    0熱度

    2回答

    我對我的項目中使用MQTT有個疑問。我只想知道是否有可能我使用RaspberryPi作爲MQTT代理(服務器)從MQTT中發佈的設備接收數據,然後同時這個RaspberryPi將MQTT中的相同數據發佈給另一個訂戶?如果可能的話,那麼第二部分的消息中介將會是什麼?我的意思是,我希望RaspberryPi成爲設備控制器(用於處理設備數據),同時將數據發佈到另一個MQTT訂戶。這可能嗎? 謝謝你這麼多

    1熱度

    1回答

    我是卡夫卡的新手。試圖實現消費者和生產者類來發送和接收消息。需要爲兩個類別配置bootstrap.servers,這是經紀人的IP和端口列表,由,分隔。例如, producerConfig.put("bootstrap.servers", "172.16.20.207:9946,172.16.20.234:9125,172.16.20.36:9636"); 由於應用程序將集羣的

    0熱度

    2回答

    mqtt客戶端具有相同的客戶端ID 如何關閉舊連接? 就是這樣。 New connection from 192.168.3.57 on port 1883. 1479826181: Client paho166768969170988 already connected, closing old connection. 1479826181: Client paho1667689691709

    0熱度

    1回答

    我有一個標準的ActiveMQ代理 private static String localVMurl = "vm://localhost"; broker = new BrokerService(); broker.addConnector(localVMurl); broker.start(); ,一切都很好。我的目標是,消費者通過特定主題與經紀人建立聯繫。一

    2熱度

    1回答

    我正嘗試使用proxybroker爲某些國家/地區生成具有活動代理的文件。我總是遇到同樣的錯誤,試圖獲取代理。該錯誤似乎是proxbroker使用的packe中的編碼/解碼錯誤。但我懷疑可能有更好的方式來使用代理經紀人。 這是引起問題的代碼: def gather_proxies(countries): """ This method uses the proxybroker package

    1熱度

    1回答

    我對Arduino相當陌生,對於我希望使用UNO向MQTT代理推送/發佈通知的項目,請讓代理將通知推送到訂閱Android應用程序我正在發展。 我有一個ESP8266爲我的Arduino傳入。我已經做了相當多的研究,但在拼湊事物時遇到了一些麻煩。我已經閱讀過Arduino作爲訂閱者,或者作爲服務器,或者Android作爲發佈者的文章,但沒有一篇針對這個具體實現。我認爲迄今爲止我所知道的是: 1:由

    2熱度

    1回答

    我是Fiware用戶,我在雲上的不同VM上部署了orion context broker GE,cepheus GE和iotagent-ul實例。我已經在註冊過程中在註冊過程中在上下文代理中創建了在註冊請求中指定命令屬性的IOT代理中註冊了一個設備,並且它的對應實體已經創建。 現在,當我註冊一個帶有其屬性和命令屬性 及其名稱和類型的設備時,該設備在iot代理上註冊,其實體也在上下文代理中創建。但奇

    0熱度

    1回答

    我 celery==3.1.23 Django==1.9.1 redis==2.10.5 ii redis-server 2:2.8.19-3 amd64 Persistent key-value database with networ ii redis-tools 2:2.8.19-3 amd64 Persistent key-value database with n

    0熱度

    1回答

    當我嘗試測試我非常簡單的消息流我得到這個錯誤: MQJE001: Completion Code '2', Reason '2495'. 我見過的其他問題與此相關的問題,但沒有解決辦法幫我解決這個... 這句話: Caused by: java.lang.UnsatisfiedLinkError: mqjbnd (Not found in java.library.path) 表明,有libmqj