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