mqtt

0熱度

1回答

我正在使用寫在Node.js中的服務通過MQTT（https://www.npmjs.com/package/mqtt）接收消息，然後寫入數據庫（使用mssql的SQL Server）。當一切正常工作時，這將工作得非常好，我創建了mqtt偵聽器並訂閱了新的消息事件。但是，如果與數據庫的連接失敗（這可能會由於網絡中斷等原因而週期性發生），那麼將消息寫入數據庫將失敗，並且該消息將被丟棄。我想告訴

0熱度

1回答

我們可以批量使用彈簧集成在蚊子10消息加載組

這是我如何定義我的mqtt連接使用春天integration.i我不知道這是否可能bt我們可以設置一個mqtt訂戶後得到10消息的加載。現在訂閱者在發佈消息之後就工作了。 @Autowired ConnectorConfig config; @Bean public MqttPahoClientFactory mqttClientFactory() {

0熱度

1回答

WSO2 EI和MQTT經紀人

WSO2 MB使用有一個可伸縮的MQTT經紀人 http://wso2.com/library/articles/2015/10/article-using-wso2-message-broker-as-a-scalable-mqtt-broker/ 現在WSO2 EI 6.1.1取代。當經紀人必須提供或者在產品內部運行時，我不清楚。儘管有些文檔似乎暗示經紀人已經在那裏，但其他一些示例要求蚊子

0熱度

1回答

使用Apache camel-mqtt的AWS IoT MQTT客戶端

我正在研究使用Apache Camel（使用camel-mqtt）+ Spring Boot構建AWS IoT Java客戶端。這聽起來像是一個很好的匹配，但找不到任何例子。有什麼缺點我看不到？會有興趣看到任何指針。

-1熱度

2回答

使用tcp反應原生paho mqtt不是webSocket

有沒有任何方法可以使用TCP而不是websocket來反應原生paho mqtt？

0熱度

1回答

Eclipse Paho和IBM Websphere MQ之間沒有建立連接MQ

我是IBM MQ的新手用戶。基本上我想建立客戶端（Eclipse Paho）和IBM MQ隊列管理器之間的連接。我已執行以下步驟：我已經安裝了IBM MQ v.9.0 創建隊列管理器發起者一個隊列管理器與端口號服務（1414）創建服務器通道並將其與創建的隊列管理器一起分配。在客戶端： Downloadd Eclipse的泛美衛生組織，這是MQTT Java客戶端。嘗試用小程序連接啓動的

0熱度

1回答

類型錯誤：on_connect（）到底需要3個參數（4給出）

我嘗試在MQTT代理（Ubuntu的服務器）執行此代碼，當從出版商獲取的數據將發送到UDP_IP。我的代碼： import json import socket import paho.mqtt.client as mqtt # MQTT Settings MQTT_Broker = "192.168.0.106" MQTT_Topic = "#" MQTT_Port = 1883

0熱度

1回答

Eclipse Paho - MQTT Javascript - 如何從外部訪問onMessageArrived

我正在使用Eclipse Paho - Mqtt JavaScript庫。試圖從外部函數訪問onMessageArrived： mqttConnect(){ var client = new Paho.MQTT.Client("wss://test.mqtt.address", "myClientId"); this.connectionInfo = client;

0熱度

1回答

的WebSocket不與SSL

https://www.hi-todd.com/websocket/ 我已創建了一個演示使用MQTT協議，它工作正常使用HTTP連接工作。但是當我嘗試將HTTP更改爲https時，它正在接收連接錯誤。我在mosquitto.conf文件中添加了證書路徑。讓我與你分享Mosquitto配置路徑。 # WebSockets over TLS/SSL listener 8083 protocol

0熱度

1回答

駱駝MQTT配置選項與豆值不工作的DSL路由URL參數

我可以從外部代理（AWs IoT）測試pub/sub;從camel-example-spring-boot示例項目開始，並添加了camel-mqtt-starter。似乎一切正常，直到我嘗試定義mqtt路由。我有配置的SSLContext網址參數的問題： @Configuration public class AppConfig { @Bean(name="awsiotsslcontext