mqtt

    1熱度

    1回答

    我目前正在研究我的第一個SpringXD流。它應該在MQTT主題上接收消息,在服務上執行HTTP POST並在另一個MQTT主題上發佈此結果。 目前我被困在發佈到不同於最初的MQTT主題。 這是我的流: stream create test --definition "in:mqtt --url='tcp://hivemq:1883' --topics='+/+/+/my/downlink' --

    0熱度

    2回答

    目標是使用mqtt協議發送數據。 Java項目(tempSensor)使用mqtt協議和使用mqtt預訂tempvalue的node.js生成臨時值。 node.js和java項目都使用相同的密鑰進行發佈/訂閱。我能夠使用java項目發佈數據,並且還可以在node.js中訂閱數據。但數據不是可讀格式。怎麼做 ?所以數據的格式是可讀的。 結構TempStruct是如下: public class T

    0熱度

    1回答

    雖然我在使用paho和spring框架的應用程序中修復了客戶端中的一些問題,但我發現了MQTT的集成。我不確定這是否能解決我的問題,我甚至不知道這是什麼。 有人可以解釋一起使用它的區別是什麼? Spring框架是否會帶來錯誤,導致整合解決的問題? 還是存儲足夠用這兩種技術分開? 由我使用的依賴關係: <dependency> <groupId>org.springframework.

    2熱度

    1回答

    我的應用程序使用paho客戶端時出現以下錯誤消息。發生此錯誤後,客戶端停止接收消息。雖然不確定,但我認爲我仍然可以發佈消息。 o.e.p.c.mqttv3.internal.ClientState : 106ed26f-74f8-4048-9035-cb9146e35c7c:67c62857-af3c-4aa0-9f28-3f4db6baf811: Timed out as no activit

    0熱度

    1回答

    我有這個Mqtt ckient應用程序正在工作,發佈方法工作正常,但是我的訂閱方法很難。 這是訂閱方法,我想點擊一個按鈕,SUBCRIBE到主題: public void subscribe(MqttClient MC) { String topic = jTextField3.getText(); int qos = jComboBox1.getSelectedIndex() ; St

    1熱度

    1回答

    我是mqtt的新手。我啓動一個ActiveMQ服務器並創建一個Java Spring使用者來處理請求。我成功地從終端發佈文本消息,並使用spring消費者進行處理。接下來,我需要通過mqtt發送一個圖像文件。我有一些問題: 是否可以使用mqtt發送圖像文件? 如何使用我的Spring消費者接收文件? 這是耗時MQTT短信我的Java代碼: public void onMessage(Message

    2熱度

    1回答

    我是新來MQTT,我只是瞭解了QOS等級的含義是決定當消息被髮布: ,當我們希望此消息將不會到達在所有的,而不是到達兩次 1時,我們希望消息至少一次到達,但如果它到達兩次不在乎(或更多) 當我們想要的信息準確地到達一次 。 更高的QoS的值意味着更慢的傳輸 我注意到,用戶側也可以設置「最大QOS級別他們將收到」。 從here引用: 例如,如果一個消息在服務質量2發佈和客戶端訂閱具有QoS 0,該消

    0熱度

    1回答

    我已經告訴MQTT-SN可以與藍牙,而不是TCP/IP的工作。 我下載RSMB從http://git.eclipse.org/c/mosquitto/org.eclipse.mosquitto.rsmb.git 我試圖然後將其配置爲使用TCP/IP以外的任何其他沒有任何的運氣工作。事實上,我能夠使用配置文件進行配置的唯一一件事就是端口號,因爲我無法在任何地方找到可能的配置列表。 有誰知道是否有可能

    0熱度

    1回答

    ActiveMQ中的警告是什麼意思? jvm 1 | WARN | Transport Connection to: tcp://xx.xxx.xxx.xxx:xxxxx failed: java.net.ProtocolException: Invalid CONNECT encoding 我使用ActiveMQ作爲代理並從Android與MQTT進行連接。我在ActiveMQ控制檯中每次連

    1熱度

    1回答

    我想配置我的消息驅動通道適配器,以便我可以抓取'連接被拒絕'錯誤的情況下: 1)消息代理關閉或2)錯誤經紀人URL指定 我試着用下面的代碼這樣做,但它沒有工作: <int:channel id="invalidChannel" /> <int-mqtt:message-driven-channel-adapter id="myAdapter" client-id="${in