18得票2回答
如何在Django中使用Paho MQTT客户端?

我正在编写一个Django应用程序,它应该作为MQTT发布者和订阅者。 在哪里应该启动paho客户端并运行loop_forever()函数。 它应该放在wsgi.py中吗?

17得票10回答
如何清除Mosquitto中的所有保留mqtt消息?

我看到了用mosquitto_pub -h [server] -r -n -t [XYZ]语法清除单个消息的方法。我的问题是设备开发人员发布了许多垃圾消息。 我有一个Java/Paho代码库,想要修改它以根据需要自动执行此操作,但我似乎无法发布零字节消息。我尝试过: client.publ...

16得票2回答
MqttClient对象的同步和异步接口无法工作

我创建了一个 MqttClient 类型的 client,并且如下面的代码所示,我创建了一个客户端并设置了它的 Asynchronous callback。问题是: 1- 当我运行程序时,“System.out.println("Client is Connected");”出现了,但我没有...

16得票2回答
安卓 - 用于发布的Paho MQTT服务

我是Android和服务的新手。我的目标是能够在主题字符串上设置订阅并进行发布。主题字符串和客户端ID是在解析文本字段输入后设置的。我正在使用Paho MQTT服务(下载了源码并构建了JAR)。 以下代码会在c.publish()处引发空指针异常。 logcat显示在MqttAndroidC...

15得票3回答
Java Eclipse Paho实现 - 自动重连

我正在尝试在我的项目中实现 eclipse.paho,以连接Mqtt Broker(用于订阅和发布)。问题是,当我使用订阅功能(实现MqttCallback接口)时,我无法弄清楚如何在连接丢失后重新连接。MqttCallback接口有一个connectionLost方法,但它只有在调试连接丢失...

15得票4回答
连接丢失(32109)- java.io.EOFException

我使用eclipse MQTT连接到MQTT服务器。 我成功连接到服务器,但当我发布消息时,出现以下错误: 连接已丢失 msg : 连接已丢失 loc : 连接已丢失 cause : java.io.EOFException excep : 连接已丢失 (32109)...

15得票2回答
导入错误:找不到paho.mqtt.client

我正在创建一个包含Python和PHP的Docker。 我编写了一个Python脚本来连接到另一个Docker中驻留的MQTT代理。 在我的Dockerfile中,我使用以下命令确保安装了Paho客户端:RUN apt-get install -y python3-dev RUN apt-...

13得票2回答
Docker容器使用主机网络速度非常慢

我遇到了Docker容器与主机网络之间的网络性能缓慢问题。我在Docker论坛上询问了这个问题,但至今没有得到答案。 问题 设置:两台Mac电脑在同一本地网络中;第一台运行MQTT代理服务器(mosquitto);第二台运行Docker for Mac。第二台Mac上有两个C++程序,它们...

13得票1回答
Paho MQTT客户端连接可靠性(断开连接后重新连接)

什么是使用Python Paho MQTT客户端的最可靠方法?我希望能够处理由于WiFi断开而导致的连接中断,并不断尝试重新连接,直到成功。 我现在拥有的是以下内容,但是否存在任何我没有遵循的最佳实践?import argparse from time import sleep impor...

12得票1回答
Golang MQTT 发布和订阅

有人知道我在哪里可以获取一些示例MQTT客户端Go(golang)代码,该代码可以在无限循环中执行发布和订阅操作吗? 我正在使用MacOS上运行的Mosquitto代理进行消息传递。 更详细地说... 从网络中获取一条消息(主题) 根据该消息计算某些内容 将计算结果发送回网络(主题) ...