mqtt

0熱度

1回答

我正在尋找訂閱特定主題的MQTT客戶端的Java代碼，發佈在該主題上的每條消息都只應達到客戶端一次。我寫了許多代碼，並且在所有情況下消息在連接到代理時正確傳遞給客戶端，但如果訂閱客戶端與代理斷開連接一段時間，然後再次連接回來，則它不會收到在未連接的時間內發送的消息，以及我已經設置了乾淨的會話標誌還爲假，但它仍然沒有工作，我用的代碼如下 import org.fusesource.hawtbuf.*

0熱度

1回答

當我打開mosquitto.db與sqlite它給出了一個錯誤'文件被加密或它不是一個數據庫'

我知道有像在php，android中創建數據庫的固定，但在這種情況下，它是由蚊子生成，所以如何我看到了。

0熱度

1回答

MQTT：刪除未傳遞的消息

我有一個要求刪除未傳遞的消息，當客戶端訂閱topic.I只是想在我的application.There實現塊/疏通功能是步驟 1) Person "A" blocked person "B",now person B publishing messages to A and person A will not get messages. 第一步很簡單並輕鬆done.I我在這裏面臨着在第2步 2

2熱度

1回答

反應mqtt訂閱setState警告

我使用https://www.npmjs.com/package/mqtt與React。在我的部分，我有： componentDidMount:function(){ client.subscribe('test/topic'); client.on('message',function(topic,message){ if(topic==='test/t

0熱度

1回答

我如何控制mosquitto_loop（）來提交消息？

我想有一個關於mosquittopp loop()的樣本。我的代碼是： MqttWrapper *mqttHdl = new MqttWrapper("sanggil", "***.**.**.***", 1883); int rc; while(1){ rc = mqttHdl->loop(); printf("while %d\n", rc);

0熱度

1回答

未使用node.js MQTT客戶端收到的消息使用socket.io

我正在使用socket.io，node.js和node.js MQTT客戶端連接到從HTMLS頁面在A-MQ上運行的代理。我可以成功連接到代理並訂閱我需要的主題，但我從來沒有從主題中收到任何消息，即使有幾個消息被排隊。這裏是我的代碼： subscribe.js var sys = require('sys'); var net = require('net'); var mqtt = req

1熱度

1回答

RSMB不接收UDP消息

看完之後this我試圖用mqtt-sn-tools來測試RSMB代理，但是我無法使它工作。當我嘗試發佈消息時，我總是得到一個recv failed: Connection refused。我可以看到代理正在偵聽端口1883上的TCP連接，但沒有涉及UDP。我可以使用mosquitto客戶端發送消息，因爲它使用TCP連接。 RSMB是否應該處理UDP請求？

1熱度

1回答

MQTT Android客戶端調用CalBackListener問題

我編寫了一個服務來訂閱來自mqtt服務器的消息。當互聯網連接開/關時，服務自動重新連接。此代碼： public class NotificationService extends Service{ private Handler connectBrokerHandler; private ConnectBrokerTimerTask connectBrokerTimerTa

5熱度

5回答

使用mktt協議和kafka作爲消息中介

我們如何使用mktt協議和kafka作爲消息中介？客戶端（機器人/ IOS /桌面Java應用程序等）將被產生和使用使用卡夫卡作爲消息代理，其可在不同的語言中使用MQTT phao客戶端庫使用消息。有什麼建議嗎？

0熱度

2回答

（Paho）MQTT回調沒有關閉

我在我的項目中使用MQTT API來讀取數據。（org.eclipse.paho org.eclipse.paho.client.mqttv3）當我關閉客戶端，mqttcallback仍然有效。我通過在對象上調用unsubscribe(...)，disconnect()和close()來關閉mqtt。我試着將回調設置爲null。沒什麼幫助。 mqtt客戶端關閉後。這是仍然不斷出現在日誌中的