paho - IT屋-程序员软件开发技术分享社区

重新连接后阅读订阅的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 Python

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

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

发布时间：2022-07-03 14:21:36 android android-service mqtt paho moquette 移动开发

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 c mqtt paho 其他开发

哪个变量导致分段故障？

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

发布时间：2022-03-28 18:12:25 c visual-c++ mqtt paho 其他开发

我试图在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 python-3.x mqtt plotly-dash paho Python

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

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

发布时间：2022-03-28 17:53:11 mqtt paho 其他开发

MQTT服务错误&Quot；套接字失败：EPERM&Quot；

这是我的MQTTCONECTION课程 public class MQTTService extends Service { private static final String TAG = "MQTTService"; private static boolean hasWifi = false; private static boole ..

发布时间：2022-03-28 17:51:55 java android sockets mqtt paho Java开发

如何在Python中终止线程？

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

发布时间：2022-03-28 17:17:19 python multithreading mqtt paho Python

MQTT over Secure WebSockets套接字在一分钟后关闭-RabbitMQ

我通过安全WebSockets(使用此模块的角度为6，import { Paho } from 'ng2-mqtt/mqttws31')连接到MQTT RabbitMQ实例。它连接成功，但插座连接似乎在一分钟后关闭。KeepAliveInterval设置为什么并不重要，它似乎总是在一分钟后关闭套接字连接。这是我的客户端连接： this.client.connect({ userNam ..

发布时间：2022-03-28 17:13:52 angular websocket rabbitmq mqtt paho 其他开发

使用 Paho MqttClient 在 Android 上尝试 Mqtt 连接

当您第一次打开应用程序时，我想要一个屏幕，您可以在其中输入经纪人信息并单击尝试并保存. 当点击尝试时，它应该只显示一个 Snackbar 说明该信息是否有助于成功连接. 这是我按下 try 按钮时调用的代码: private void tryConnection(View v){如果(验证输入()){Snackbar.make(v, getString(R.string.trying ..

发布时间：2022-01-24 15:36:59 android connection mqtt paho 移动开发

即使无法访问 MQTT 服务器如何启动骆驼

我想让我的 Apache Camel 应用程序更有弹性，即使在无法访问 MQTT 代理时也能启动.我们在互联网连接可能不稳定的 IoT 设备上使用 Camel，我希望即使没有互联网连接也能启动我们的应用程序. 示例路线如下所示: from("timer:heartbeat?period=5000").routeId("发送心跳").setBody(simple("Hello World!" ..

发布时间：2022-01-19 08:44:04 java apache-camel paho Java开发

发送许多发布消息:正在进行的发布太多错误

这里是 paho 异步客户端: client = new MqttAsyncClient(appProps.getProperty("mqtt.broker"),appProps.getProperty("mqtt.clientId"), new MemoryPersistence());client.setCallback(this);client.connect(null, new IMq ..

发布时间：2022-01-11 17:29:52 rabbitmq mqtt paho 其他开发

树莓派上的python mqtt脚本来发送和接收消息

MQTT 问题: 嗨，我正在尝试在多个 Raspberry Pi(从两个开始)之间建立一个 MQTT 网络.我有一个 raspberry pi (RPi-A) MQTT 客户端，连接了一个热敏电阻传感器和一个 raspberry (RPi-B)，MQTT 代理/客户端，作为我的网络的集线器.通过 python 脚本，我希望每 30 分钟将温度从 RPi-A 通过 MQTT 发送到主题传感器/ ..

发布时间：2022-01-05 10:36:43 python raspberry-pi mqtt paho Python

Camel PAHO 路由在连接回时未收到离线消息

我正在使用基于 apache camel xml 的 paho 路由进行订阅、发布过程.在线时，一切正常.但是我无法接收离线消息. 我已经设置了以下内容，固定客户 ID 清除会话为假，两者都订阅了使用 QoS 2 发布使用独立程序，它可以获取所有离线消息.骆驼路线不会发生这种情况. 解决方案最后，我能够手动解决这个问题. Camel PAHO 客户端在执 ..

发布时间：2021-11-11 23:12:25 apache-camel mqtt message offline paho 其他开发

即使无法访问 MQTT 服务器，如何启动骆驼

我想让我的 Apache Camel 应用程序更具弹性并且即使在 MQTT 代理无法访问时也能启动.我们在互联网连接可能不稳定的物联网设备上使用 Camel，我希望我们的应用程序即使没有互联网访问也能启动. 示例路线如下所示: from("timer:heartbeat?period=5000").routeId("发送心跳").setBody(简单("Hello World!")).to ..

发布时间：2021-11-11 23:02:22 java apache-camel paho Java开发

使用 Paho MQTT 订阅消息时如何读取标头键:值对

我在使用 pika like 向我的 rabbitmq 代理发布消息时添加了一个标头键:值对 channel.basic_publish(exchange=self.exchange,routing_key=self.routing_key,属性=鼠兔.BasicProperties(headers={'key': 'value'}),正文=消息) 在我的客户端，我使用 websockets ..

发布时间：2021-06-04 18:37:47 python-3.x rabbitmq mqtt paho pika 其他开发

将订阅主题中的 MQTT 数据保存在文本文件中

我正在设置从订阅的主题接收 MQTT 数据，我想将数据保存在文本文件中. 我添加了将变量保存到文本文件的代码.然而，这不起作用，因为它只给我变量而不是它的值，即不给我“on_message"的值.有人可以帮帮我吗? 谢谢我的代码如下: 导入 paho.mqtt.client 作为 mqttClient导入时间def on_connect(client, userdata, f ..

发布时间：2021-06-04 18:37:42 python mqtt paho Python

当手机处于电源安全模式时，我可以信任 MQTT

我有一个简单的 Paho MQTT Android 客户端应用程序: public class PahoExampleActivity extends AppCompatActivity {mqttAndroidClient mqttAndroidClient;final String serverUri = "ssl://myserver:8887";String clientId = "Ex ..

发布时间：2021-06-04 18:37:29 java android mqtt paho Java开发

使用 MQTT 和 Python 控制程序

哟，伙计们.所以我对 Python 比较陌生，并且是 MQTT 的完全新手.所以，我试图通过 MQTT 建立两个程序的简单连接.其中一个程序是发布者: 将 paho.mqtt.client 导入为 mqtt导入系统、tty、termios## 发布者读取键盘输入定义获取():fd = sys.stdin.fileno()old_settings = termios.tcgetattr(fd)尝 ..

发布时间：2021-06-04 18:37:20 python mqtt payload paho Python

MQTT v3 客户端可以与 MQTT v5 服务器一起使用吗?

我想利用 MQTT v5 的共享订阅功能.但目前我正在使用不支持 MQTT v5 客户端的 AKKA MQTT 客户端.我还可以使用 v3 MQTT paho 客户端并使用共享订阅功能吗? 解决方案这应该不是问题，因为从 MQTT v3 客户端的角度来看，共享订阅就像任何订阅一样. 代理必须完成有关共享订阅逻辑的所有工作. 我能看到的唯一障碍是: MQTT 代理可能支持 ..

发布时间：2021-06-04 18:36:56 mqtt paho alpakka 其他开发

paho相关内容