mqtt相关内容

客户端工具MQTT.fx上定义的主题未使用ActiveMQ Artemis消息

我的用例保证使用发布-订阅模型,因此我使用在我的Spring Boot客户端中定义的主题。我已经使用工具MQTT.fx和两个Spring Boot客户端进行了测试。两个Spring Boot客户端能够相互通信,但MQTT.fx客户端只连接到代理,不生成或使用消息。两个Spring Boot客户端都连接到端口61616,而MQTT.fx客户端连接到端口1883。 对于我的项目,我需要让MQTT ..
发布时间:2022-07-03 14:40:18 Java开发

重新连接后阅读订阅的MQTT消息

我正在尝试读取MQTT服务器上的邮件。在某些情况下,连接不稳定,需要重新连接。但在重新连接后,我无法收到来自我之前订阅的主题的任何消息。我正在使用PAHO的python包来处理MQTT连接。以下是我使用的一些代码 TopicName='some/topic/name' class Counter: def __init__(self, mqttClient): se ..
发布时间:2022-07-03 14:30:53 Python

MQTT PAHO客户端未自动重新连接到Android服务上的Broker

我有一个服务来管理我的MQTT客户端连接,MQTT工作得很好,但问题是当我重新启动Broker Server时,Android客户端无法重新连接。onConnectionLost()回调触发异常。 备注 我在同一台计算机上使用Moquette Broker->Moquette 我有两个Android客户端应用程序,一个使用服务(有问题的)和其他在没有服务的线程上工作(这很好用,重新连 ..
发布时间:2022-07-03 14:21:36 移动开发

MQTTClient_setCallback时出现分段故障

我有来自hivemq站点的SIMPe MQTT客户端应用程序: MQTTClient client; MQTTClient_create(&client, "ssl://xxx.s1.eu.hivemq.cloud:8883", "Client_1", MQTTCLIENT_PERSISTENCE_NONE, NULL); int i = MQTTClient_setCallbac ..
发布时间:2022-03-28 18:17:54 其他开发

哪个变量导致分段故障?

正在尝试调试MQTT Paho库中的未处理异常。不知道具体是哪个变量出现分段故障。变量m和ma不为空。不确定m->c->connect_state中的{...}是什么意思。 如何知道是哪个确切变量引发了问题? 如何解决此问题? MQTTClient.c中的函数代码: int MQTTClient_setCallbacks(MQTTClient handle, void* c ..
发布时间:2022-03-28 18:12:25 其他开发

为什么我的树莓PI不能连接到谷歌云物联网?

我已将rsa_private.pem添加到项目的certs目录中,并在IOT核心控制台中将相应的rsa_cert.pem公钥添加到我的设备。 我还从certs目录中运行了wget https://pki.google.com/roots.pem。 我不明白的是,现在生成的roots.pem文件有多个- ----BEGIN CERTIFICATE----- // RS256_X50 ..

MQTT-函数以破折号显示输出

我试图在Ploly Dash上显示订阅特定主题的MQTT响应。不幸的是,订阅该主题的on_message函数没有显示任何内容。我是Python和Ploly Dash的新手,无法正常工作 import dash import dash_html_components as html import dash_core_components as dcc import dash_bootstrap ..
发布时间:2022-03-28 18:03:02 Python

如何作为MQTT客户端累计消息1秒,然后保存到文件中

我的问题如下: 我写了一个订阅一个主题的程序,其中两个带有一个键的字典分别每秒到达更多的次数。在每条消息上,它们都会更改其值。 我将这些字典保存在一个名为&status&q;的大缓冲字典中。我需要的是将每秒状态的快照(&Q;)保存到文件中。 我尝试了计时。睡眠(1),但它漂移。而且我不知道如何用日程安排来处理这个问题,因为已经存在客户端循环. 我是Python和MQTT的新手,非常感谢 ..
发布时间:2022-03-28 17:59:04 Python

MQTT消息订单是否可以在简化情况下得到保证?

如果只有一个代理、一个发布者、一个主题和干净会话,在这个简化的情况下, 能否保证订户侧的邮件发货订单与发布商侧的发送订单相同?它是否会受到QoS的影响? 推荐答案 MQT3.1.1spec章节4.6介绍消息排序: 4.6邮件排序 客户端在实现协议流时必须遵循以下规则 在本章的其他地方定义: 当它重新发送任何PUBLISH数据包时,它必须按照发送原始PUBLISH数据 ..
发布时间:2022-03-28 17:53:11 其他开发

MQTT订阅/OTA更新深度睡眠/ESP32/FreeRTOS

目标是在定期从深度休眠中醒来的物联网设备中通过MQTT接收消息。OTA更新与任何其他参数更新存在完全相同的注意事项。在我的情况下,最终,我希望将此用于两者。 进度 它运行 设备唤醒大约15秒。如果在此期间,我向相关主题发布了一串消息,则消息成功到达。在AWS控制台内,我可以发布到: $aws/things//shadow/update/delta ..
发布时间:2022-03-28 17:46:32 其他开发

客户端<;客户端名称&>已超过断开连接超时

我使用的是MQTT 3.1.1,我在计算机上安装了蚊子作为本地服务器。 我正在将一些传感器数据从pubsubclient(MQTT客户端库)发送到蚊子,并从蚊子服务器将其保存到数据库 每当我开始会话最多5-10分钟时,我都会收到消息,但在此之后 MQTT客户端无法发送任何消息并自动断开连接。 在断开连接之前,在命令行中打印以下消息 client has ..
发布时间:2022-03-28 17:40:38 其他开发

应用程序在Android和iOS模拟器中可用,但在发布后不起作用

问题 我创建了一个App,它是一个MQTT代理客户端。当我使用iOS/Android模拟器进行开发时,我与Broker的连接工作正常。然而,当我发布一个apk版本时,我的应用程序无法连接。它有套接字问题(AMQJS0007E套接字错误:未定义)。 我已经尝试过此解决方案github solution 屏幕截图 应用程序在模拟器中运行 [] 正在运行的应用程序发布 ..
发布时间:2022-03-28 17:31:56 前端开发

Node.js MQTT SSL脚本

我创建了一个脚本,将我的Linux CentOS VM作为客户端连接到MQTT代理。现在我正在尝试使用SSL进行连接。要发布和订阅代理,需要用户名和密码。但是当我使用以下命令运行脚本时: node websitemqttclient.js 我刚刚收到下面的消息,在执行完成并可以输入新命令之前,光标在空白处停留了大约1.5分钟。我看到了折旧通知,但看起来还不是问题。此外,我已经验证了代理及其 ..
发布时间:2022-03-28 17:30:12 前端开发

如何在Python中终止线程?

我知道这个主题已经讨论过几次了,不管我怎么尝试,或者至少尝试了几乎所有的解决方案,但是作为一个相当新的python创建器,我之前的任何解决方案都无法运行。 脚本的基本前提是订阅MQTT Broker并等待命令,单个动作命令100%工作,但是其中一个命令需要循环无限期运行,直到收到另一个命令,因此最合适的解决方案是在单独的线程中运行“循环”,同时主订户循环继续“监听”下一个命令。 一切正 ..
发布时间:2022-03-28 17:17:19 Python