mqtt

    1熱度

    1回答

    我已經爲MQTT訂戶編寫了一個python腳本,它在本地完美地工作。 的Python腳本用戶 import paho.mqtt.client as mqtt import os,json filePath = "logs.csv" def initiateFile(): if (os.path.exists(filePath) == False): fileObj

    0熱度

    1回答

    背景 我一直在玩MQTT的一個項目,遇到了一個奇怪的問題。我使用paho作爲我的MQTT客戶端,並使用VerneMQ作爲代理。 VerneMQ代理服務已啓動並正在運行,我可以通過runnnig netstat來確認,我可以看到127.0.0.1:1883條目處於LISTENING模式。 這是我的客戶端代碼: public class Producer implements MqttCallback

    0熱度

    1回答

    當代理後面可以使用emqttc https://github.com/emqtt/emqttc? 您可以將SSL選項傳遞給emqttc:start_link函數,但它似乎沒有爲代理執行任何操作。作爲一個例子,我嘗試使用{proxy_auth,{Proxy_Username, Proxy_Password}}作爲選項。任何建議,如果這是可能的或如何配置它的代理使用?

    0熱度

    1回答

    我正在運行一個RabbitMQ實例,它通過rabbitmq_web_mqtt插件通過websockets提供MQTT。 由於遺留原因,我需要支持非默認的WebSocket URL。 我在文檔中看到可以通過{ port, 1234 }配置更改端口,但我找不到任何方法來更改WebSocket URL。它目前設置爲默認路徑/ws 是否可以在不修改插件的情況下更改WebSocket URL?

    2熱度

    1回答

    我正在研究亞馬遜物聯網作爲定期測量數據的移動設備的傳輸機制(通常每N分鐘,N爲2到32分鐘之間的任何地方)。利用MQTT,我可以利用亞馬遜的經紀商將完成的測量結果發佈給QoS = 1的訂戶。我們還假設我的唯一用戶只是監聽通配符主題(例如abc /#)的另一個設備,並將發佈的消息存儲到本地數據庫中。 但現在它也有可能是: the publishing mobile devices have spot

    -1熱度

    1回答

    我對Aws物聯網相當陌生。我知道我們可以爲Aws IoT編寫Java客戶端。我有以下三個查詢: Java客戶端是否僅用於接收來自Aws'Thing'的消息? 其他設備可以訂閱Java客戶端 可以這樣客戶端也將消息發送給其他設備 這將是有益的,如果你能幫忙的出發點,以實現Java。參考任何文章或鏈接將非常有幫助。

    -1熱度

    3回答

    我在MQTT應用程序的工作,併爲int當我收到來自MQTT經紀人有效載荷的信息,並試圖將其從void *的是MESSAGE->的有效載荷爲int的轉換的 signed int var_1=*((int*) message->payload); ,而不是將其轉換爲它是將其轉換爲另一個數,看到這個我使用下面的代碼: printf("Message:%s\n",message->payload);

    0熱度

    1回答

    我正嘗試使用Python 2.7和Paho MQTT 1.3.1將JSON數據推送到IBM Watson IoT平臺。 它可以與來自IBM的Github的IoT Python客戶端一起工作,但是我的設備環境不支持此擴展。 測試時,我在IBM Watson IoT中禁用了TLS加密。 這是我的代碼: import json import paho.mqtt.client as mqtt cli

    0熱度

    2回答

    我想提出以下申請。 1.Send a command from mosquitto_pub to Arduino device via Watson IoT. 2.Arduino subscribes to commands. 3.Arduino publishes sensor information to mosquitto_sub via Watson IoT. 爲了進行簡單的連接測

    1熱度

    1回答

    我正在使用openssl使用Eclipse Paho MQTT C客戶端通過TLS連接到一個mosquitto代理。這是我的代碼的一部分: MQTTClient client; MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer; MQTTClient_message pubmsg = MQTT