paho相关内容

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

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

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

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

使用 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 其他开发

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

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

使用 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 其他开发

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

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

如何在 React Native 上使用 MQTT?

我是 React Native 的新手,我想在我的应用程序中使用 MQTT.我试图按照链接中的说明进行操作 --> https://github.com/Introvertuous/react_native_mqtt 我通过命令安装了 MQTT --> npm install react_native_mqtt --save 我的问题是:- 我应该在哪里粘贴下面的代码?在 app.js ..
发布时间:2021-06-04 18:36:50 其他开发

ANDROID-MQTT:无法连接到服务器 (32103)

我正在尝试在 Android 中学习基本的 MQTT 集成.我正在使用 mosquitto 代理来发布和订阅消息.我在真实设备上运行代码并收到此异常: 无法连接到服务器 (32103) - java.net.ConnectException:后连接到/192.168.0.103(端口 1883)失败30000 毫秒:isConnected 失败:ECONNREFUSED 这是我的代码: 公 ..
发布时间:2021-06-03 21:16:59 其他开发

蚊子经纪人没有将离线消息发送到 adafruit 物联网门户

我有一个 raspberry pi,我在其中安装了 mosquitto broker 和 mqtt.Pi 已连接到传感器,我需要将此数据发送到 adafruit IOT protal.我可以在 pi 连接时发送所有数据,但是当 pi 脱机时,我只能传输 20-30 秒的数据.如果 pi 离线超过 2-3 分钟,则该数据不会传输到门户. 我已经创建了一个 bridge.conf 文件并添加了所 ..
发布时间:2021-06-03 21:16:54 其他开发

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

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

如何使用MQTT订阅Watson IoT设备事件?

我正在使用Paho和Python创建一个MQTT客户端,以与Watson IoT Platform中的设备连接. 我正确组装了经纪人: .messaging.internetofthings.ibmcloud.com:1883 和客户: d::: 以及该主题的发布值: iot-2/evt/ ..
发布时间:2021-05-15 19:23:59 其他开发

如何在Django 3.1中实现Paho python客户端

来自这个SO问题,我实现了一个订阅者我的Django项目中的客户端如下: 在 mqtt.py 中,我创建了一个客户端,并连接到本地代理并订阅了一个主题. #myapp/mqtt.py:将paho.mqtt.client导入为paho导入json进口djangodjango.setup()从.models进口温度,浊度,精制燃料,原油从datetime导入datetime#客户端从服务器收到 ..
发布时间:2021-05-01 20:21:32 其他开发

与M2MQTT Paho Python客户端连接到Azure IoT中心

我正在使用以下代码尝试连接到Azure IoT中心.它使用SAS,因此不需要安全证书.我已使用C#中的相同M2MQTT库成功连接到Azure IoT中心,但是此代码失败并显示以下内容:连接失败.连接被拒绝,未经授权.错误代码= 5 我尝试了任何可能的安全性参数组合,但无济于事.SAS令牌由DeviceExplorer生成. #!/usr/bin/python3.5导入序列导入时间导入日期时 ..
发布时间:2021-04-14 18:35:10 其他开发

Google Cloud IoT-无效的MQTT发布主题

我正在使用带有paho-mqtt的Python客户端在以下特定的Google Cloud IoT主题中发布:projects/my_project/topics/sm1.我的代码如下,基于Google IoT文档的示例: import paho.mqtt.client as mqtt import ssl, random, jwt_maker from time import sleep ..
发布时间:2021-02-08 19:17:29 其他开发

蚊子经纪人保留多条消息

我要在EC2的Ubuntu上运行mosquitto代理.我也在/etc/mosquitto/mosquitto.conf 中做了max_queued_messages 1000和max_inflight_messages 10的更改 我正在使用 qos = 2 和保持启用状态向该代理发布.对于发布,我正在使用mosquitto_pub -t 1 -m "{c:{d:\"pN\",m:\"Pr1 ..
发布时间:2021-02-08 19:17:14 其他开发

Mosquitto与Eclipse Paho客户库

我只是在研究Eclipse PAHO 和 Mosquitto 库提供了一种实现客户端的方法Mosquitto MQTT经纪人的库. 我想了解这两个客户端库之间的主要区别是什么. 此处进行了讨论,但这不能回答我的问题.哪一个优于另一个,为什么?为什么Eclipse同时支持这两种方法? 解决方案 我是否遇到相同的问题,是否选择 paho.mqtt.cpp 维护得不好. 由于有两个功能 ..
发布时间:2021-02-08 19:16:53 其他开发

当另一个客户端连接到服务器时,Mqtt客户端断开连接

我是MQTT消息传递系统的新手,但是我设法在运行AOSP kk-4.4.2的snapdragon板上实现了paho Android服务.我的服务将在启动时启动,并将通过端口1883连接到HiveMQ的公共代理. 问题是将运行自定义AOSP的Android设备连接到服务器后,并且如果我尝试从手机上运行的android应用程序连接另一个客户端.金鱼草板上的客户端会自动与服务器断开连接.当我尝试重 ..
发布时间:2021-02-08 19:16:08 其他开发

在Linux上使用cmake独立编译PahoMqttCpp示例

我的目标 ...是使用PahoMqttCpp项目中的示例代码 async_subscribe.cpp ( https://github.com/eclipse/paho.mqtt.cpp )独立应用程序,然后根据我的需要对其进行修改。 我的方法 预备赛 Raspberry pi的最新模型( uname -a -> 4.14.98-v7 +#1200 SMP Tue Feb ..
发布时间:2020-10-03 21:55:39 其他开发

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

我想使我的Apache Camel应用程序更具弹性并即使在无法访问MQTT代理时也可以启动.我们正在可能不稳定的Internet连接的物联网设备上使用Camel,我希望即使没有Internet访问,我们的应用程序也可以启动. 一条示例路线如下: from("timer:heartbeat?period=5000") .routeId("send heartbeat") ..
发布时间:2020-09-03 06:04:49 其他开发