mqtt相关内容

Android上的MQTT:连接断开

我正在尝试在Android应用程序上使用MQTT客户端,但无法使其正常工作. 我的MQTT客户端是0.4.0,我的Android是4.0.3. 该应用程序非常简单:它具有一个EditText和一个用于发布文本的按钮.此外,它具有TextView来显示收到的消息. 每次单击“发布"按钮,都会显示“连接丢失"消息,有时会显示两次或三次,因为它尝试多次连接然后断开连接. 同样,如果不单击 ..
发布时间:2020-05-12 20:15:44 移动开发

节点-红色,物联网基础输出节点未发送命令

我有一个绑定到IOT Foundation(iotf)服务的Node-RED应用程序.我可以从设备接收事件并适当地处理它们. 但是,我现在有兴趣将命令发送回我的设备,并且遇到了一些问题.设备上没有显示任何内容,但是通过在节点上创建IOTF,我可以确认命令正在通过iotf传递. 我肯定可以使用纯python获取通过iotf传递的命令,因为以下代码可以很好地工作: 客户代码: ..
发布时间:2020-05-12 20:15:42 其他开发

NestJS MQTT微服务有效的@MessagePattern是什么?

我正在尝试根据文档使用NestJS设置MQTT微服务. /p> 我已经使用Docker启动了可工作的Mosquitto Broker,并使用各种MQTT客户端验证了其可操作性.现在,当我启动NestJS服务时,它似乎已正确连接(mqqt.fx显示了新客户端),但是我无法在控制器中接收任何消息. 这是我的引导程序,就像在文档中一样: main.ts async function boo ..
发布时间:2020-05-12 20:15:39 其他开发

如何使用MQTT Paho订阅RabbitMQ队列

我正在尝试从我的Android应用连接到一个称为“消息"的队列. 生产者(一种基于AMQP协议的Web服务)已经连接,可以通过RabbitMQ管理面板进行检查. 要从我的Android设备进行连接,我正在这样编码. private void connect() throws Exception { this.sampleClient = new MqttClient(t ..
发布时间:2020-05-12 20:15:37 其他开发

带有主机网络的Docker容器的网络性能非常慢

我在Docker容器和主机网络之间的网络性能缓慢方面遇到了问题.我在Docker论坛上问了这个问题,但到目前为止还没有收到答案. 问题 设置:同一本地网络上的两台Mac;第一个运行MQTT经纪人(mosquitto);第二个运行Docker for Mac.两个C ++程序在第二台Mac上运行,并使用Paho MQTT C库通过MQTT代理(在第一台Mac上)多次交换数据. 本机 ..
发布时间:2020-05-12 20:15:34 其他开发

AWS IoT设备网关是MQTT代理吗?

我试图了解Amazon AWS IoT,并且看到在传感器/执行器和AWS(规则引擎)之间连接了一个设备网关.我了解传感器/执行器是MQTT客户端,可以发布/订阅主题. 设备网关还支持发布/订阅模式,这意味着 设备网关也是MQTT客户端吗? 那MQTT经纪人在哪里? OR设备网关是AWS + IoT服务的代理+通信接口吗? 我已在AWS IoT上附加了Image Ama ..
发布时间:2020-05-12 20:15:30 其他开发

将mqtt协议与kafka用作消息代理

我们如何将mqtt协议与kafka用作消息代理? 客户端(android/ios/桌面Java应用程序等)将使用mqtt phao客户端库生成和使用消息,该库可以使用kafka作为消息代理以不同的语言提供. 有什么建议吗? 解决方案 您可以使用Kafka源连接器,该连接器将从MQTT代理(如Mosquitto)将数据流式传输到Kafka集群中.参见 https://github ..
发布时间:2020-05-12 20:15:27 其他开发

微控制器上的MQTT库

我想使用MQtt协议作为Messing协议.我想使用CCS编译器将Mqtt库移植到微控制器TMS470(德州仪器)上.由于我是本协议的新手,任何人都可以建议我如何通过GPRS模块使用该协议.我对MQtt进行了一些研究.但是我不知道如何开始.打开TCP/IP之后,如何发布或订阅数据.通常如何移植库.而我将在哪里获得图书馆 解决方案 您可以使用Paho嵌入式客户端库:使用该库,您只需实现用于从 ..
发布时间:2020-05-12 20:15:20 其他开发

MQTT-客户端框架保持在后台运行

我正在尝试通过 MQTT-Client-Framework 连接到我们的推送服务器 连接服务器没有复杂性,只需几行代码,我就可以连接到服务器并订阅主题. 但是我有几个问题,我找不到他们的直接答案. 1)如何保持我的客户端在后台运行? 2)设备重启后会发生什么?设备重启后如何自动连接服务器? 3)假设我在连接服务器时遇到错误.该库是否将尝试循环连接?尝试几次?还是我需要 ..
发布时间:2020-05-12 20:15:18 移动开发

最大MQTT连接

我需要创建一个服务器场,该服务器场可以处理5+百万个连接,5 +百万个主题(每个客户端一个),每秒处理30万条消息. 我试图查看各种消息代理的功能,因此我目前正在使用两个RHEL EC2实例(r3.4xlarge)来提供大量可用资源.因此,您无需查找它,它具有16vCPU,122GB RAM.我的使用量还远远没有达到极限. 我无法通过600k的连接限制.既然在客户端和服务器上似乎都没有 ..
发布时间:2020-05-12 20:15:15 其他开发

Paho MQTT客户端连接可靠性(断开连接时重新连接)

使用Python Paho MQTT客户端最可靠的方法是什么?我希望能够处理由于WiFi掉线而导致的连接中断,并继续尝试重新连接,直到连接成功为止. 以下是我所拥有的,但是我不遵循任何最佳实践吗? import argparse from time import sleep import paho.mqtt.client as mqtt SUB_TOPICS = ("topic/ ..
发布时间:2020-05-12 20:15:13 Python

OPC-UA的替代品

作为访问由各种PLC组成的系统的过程数据的解决方案,OPC-UA是否有任何不错的选择?平台无关的东西,可以与不同品牌的产品“对话"吗? 我听说过 MQTT ,但这似乎更像是一种传输协议,仅此而已.它没有像信息建模之类的所有更高层次的东西. 感谢您的帮助! 解决方案 OPC是与PLC通信的唯一标准方法. OPC DA是旧的替代方法.如今,OPC UA是新的并推荐使用.在OPC之前 ..
发布时间:2020-05-12 20:15:11 其他开发

如何在Amazon AWS Lambda函数中发布到MQTT主题?

我希望有一个简单的命令,就像我在bash中使用的那样,将一些内容发布到AWS Lambda函数内的MQTT主题上.遵循以下原则: mosquitto_pub -h my.server.com -t"light/set" -m"on" 背景:我想用Alexa打开和关闭一个灯. Alexa可以启动Lambda函数,并且在此Lambda函数中,我想启动MQTT发布,因为指示灯可以收听MQTT主题并 ..
发布时间:2020-05-12 20:15:07 其他开发

物联网请求响应协议

我们需要构建一个服务器,该服务器可以与运行Android变体的某些嵌入式设备进行通信.我们需要能够将命令发送到设备并接收响应.一个简单的命令可能是询问设备的状态.我们没有HTTP,因此我们需要让客户端/设备与服务器建立连接. 我们正在考虑使用MQTT,因为它具有很多不错的属性(QoS,轻量级,为IoT构建),但是它本身不支持请求响应工作流. 我们已经考虑过在MQTT之上构建RPC,但是 ..
发布时间:2020-05-12 20:15:04 移动开发

OPC UA协议与MQTT协议

我想根据两种协议的总体特征(例如开销(数据包),安全性,信息建模和可靠性)来比较OPC UA与MQTT.在哪里可以找到每种协议的开销和其他特征的一些样本数据,以便进行比较.我需要你的建议.您可以建议使用任何工具来比较这些协议. 解决方案 我还没有看到OPC UA与MQTT的比较.请记住,OPC-UA最适合SCADA系统,MQTT非常适合通过不可靠的网络(例如移动网络)进行发布/订阅消息传递 ..
发布时间:2020-05-12 20:15:01 其他开发

MQTT《最后遗嘱》的目的或用途是什么?

我肯定缺少有关整个MQTT协议如何工作的信息,因为我无法掌握最后遗嘱消息的用法模式:它们的目的是什么? 我经常看到的一个例子是有关通知设备已脱机.对我而言,这没有多大意义,因为很明显,如果设备未发布任何数据,则它可能处于脱机状态,或者可能存在一些网络问题. 那么,LWT的一些实际用法是什么?它是干什么的? 解决方案 LWT消息并不真正关心检测客户端是否已脱机(该任务由keepAli ..
发布时间:2020-05-12 20:14:59 其他开发

最准确的计时器Qt C ++

我使用QTimer定期将"Ping"数据包发送到服务器(MQTT客户端).但是它的计时器并不是绝对准确的.工作一段时间后,它会出现一些延迟并且服务器断开连接. 我尝试使用其他Qt :: TimerType,但这无济于事. 我需要最准确的计时器.你有什么主意吗? 谢谢! EDIT(Frederik解决方案) 我做了这样的事情: tthread.h class TThre ..
发布时间:2020-05-12 20:14:57 C/C++开发

如何使用MqttClient的取消阻止方法

当我尝试使用下面的代码连接到mosquitto代理时,如您所知,连接到代理可能需要几秒钟/分钟,在此期间,当按下按钮进行连接时,它将一直保持按下状态直到连接成功为止建立并在建立连接时将按钮释放回其正常状态.据我所知,有两种使用paho java API连接客户端的方法,即blocking method和unblocking method.我的问题是,如何使用unblocking method? b ..
发布时间:2020-05-12 20:14:55 其他开发