hivemq

持久会话在 MQTT 中如何工作?

我使用 MQTT 和 QOS 1。 我有一个消费者和一个生产者。它们相互通信(HiveMQ 作为客户端)。他们使用 VerneMQ 作为代理。我使用持久会话。 如果消费者离线,后来又上线,他应该成为他离线的所有消息。但这只有在消费者在另一台计算机上并且我没有停止微服务但我关闭 WiFi 然后再打开时才有效。但是,如果我关闭了一个微服务,然后重新启动它,它就不适用于离线消息。 如果我再次启动微... »

MQTT 3.1.1 代理 QoS=1(“至少一次”)消息重新传递

我正在尝试找出关于“至少一次”(QoS 1)配置的 MQTT 订阅者接收到的消息的 MQTT 3.1.1 消息重新传递的现实情况: MQTT 代理是否会重新传递来自订阅者的未确认的“QoS 1”消息? 必须经过多长时间才能重新交付 MQTT 代理? MQTT 代理是否无休止地尝试重新传递未确认的消息? 还有其他方法可以触发重新投递吗? 假设 MQTT 订阅者 没有用PUBACK 消息响应收到的... »

ESP8266 未连接到 MQTT 代理 hivemq

我有一个简单的代码,我在其中尝试连接到 HiveMQ 开放代理并订阅主题以收听传入消息。 这里是代码 #include <ESP8266WiFi.h> #include <PubSubClient.h> const char *ssid = "P9Inct"; // cannot be longer tha... »

具有持久会话的 HiveMQ 共享订阅

尝试结合 HiveMQ 的两个特性:共享订阅和持久会话。 如果已经创建了一个非常简单的消息生产者。和一个非常简单的消费者。 运行多个消费者时,所有消费者都会收到所有消息。 将消费者的clearSession设置为'false'后,在运行消费者时,重新启动消费者,消费者在未连接时也会收到消息。太棒了。 现在将它与共享订阅功能相结合。 仅使用共享订阅时,clearSession 为“true”。... »

HiveMQ Java 阻塞客户端订阅者不消费任何消息

我正在使用 HiveMQ Java 客户端连接到 HiveMQ 代理。阻塞客户端订阅者不使用任何消息。使用 MQTTBox 发布和订阅工作正常。这是代码。我关注HiveMQ Java Client Documentation public class MQTTMain { public static void main(String[] args) { Mqtt3BlockingClient p... »

Hivemq 在一段时间后关闭

我在我的 Ubuntu 16.04 服务器上安装了 HiveMQ(将 zip 文件放到我的服务器中并解压缩),然后我通过终端启动它(使用 SSH 连接)并连接了一个客户端,一切都很好。 然后我关闭了终端,看看能不能再次连接,我可以,我也可以在 2 小时后连接,但突然我不能。 有什么命令可以让它一直开吗? 提前致谢... »

运行 HiveMQ 时出现错误:无法绑定到所有接口和端口 1883,因为它已在使用中

我正在使用企业代理 HiveMQ 开发基于 MQTT 的应用程序。我按照这里的说明安装了它-http://www.hivemq.com/docs/hivemq/2.0.1/ 当我使用 ./bin/run.sh 运行它时,服务器连接由于错误而立即关闭 - 无法绑定到所有接口和端口 1883,因为它已经在使用中。停止 HiveMQ 据我所知,没有其他人在使用此端口。即使我重新启动计算机并且没有其他... »

HiveMQ 持久性如何工作?

HiveMQ 为持久性功能提供了哪些选项?默认情况下是基于文件的吗?如果需要,我们可以将其更改为数据库吗? 我试图在网上找到一些东西,但我能想到的只是这个MQTT-SQL-Database Plugin,它使用 MySQL db 在消息到达时存储消息。我想将用户订阅、统计数据和任何其他数据等所有内容都保存到数据库中。目前,如果我重新启动代理,所有数据都会丢失。... »

无法在远程服务器上启动 hivemq 服务器?

我制作了两台服务器,一台是虚拟测试服务器,另一台是我的 django 项目正在运行的地方。我可以在我的虚拟服务器上运行 hivemq 服务器,但是当我尝试在我的项目服务器上运行它时它会引发错误。 java.lang.ExceptionInInitializerError: null at org.jgroups.logging.LogFactory.getLog(Unknown Sour... »

Hivemq 加载默认配置,configuration.properties 问题

我是 hivemq 新手。在 hivemq conf 文件夹中有 config.xml 但在文档中有各种文件,如 configuration.properties 或 application.properties。这些不在文件夹中。 当我尝试创建它时,hivemq 给出了找不到配置的错误。如果我不想使用 XML,我可以通过 configuration.properties 文件对其进行配置吗?... »

MQTT与android上的paho,只接收第一条消息

我正在使用带有 paho 的 MQTT 在 android 上接收和发布消息。 我的 MQTT 初始化有以下代码。 private void initializeMQTT(){ try{ mqttClient = new MqttClient( "tcp://broker.hivemq.com:1883", ... »

HiveMQ RESTful 身份验证插件

我正在为在我的组织内部运行的专有服务器连接 RESTful API。我们正在使用 HiveMQ,我根据 HiveMQ 网站上非常有用的文档创建了一个简单的插件。 我还回顾了缓存和非阻塞的理念,因此了解我在编写插件代码时需要考虑这些。 我们的 RESTful API 已实现 Spring Security Remember-Me Auth,我们的 HiveMQ 插件将使用“有效”响应在 Hiv... »

如何使用 Gradle 将 HiveMQ 客户端作为依赖项添加到 HiveMQ 社区版?

我想将 HiveMQ 客户端和 HiveMQ 社区版(代理的实现)结合到一个项目中。我尝试将 HiveMQ 客户端作为依赖项添加到 Hive MQ 社区版(代理)中的 build.gradle 文件。它能够成功构建,但我不确定我是否做得正确。当我尝试在 Community Edition 中引用客户端类时,它给了我错误。我错过了什么吗?我希望能够将客户端项目放入代理社区版中,并能够创建一个客户端并... »

MQTT PUBACK 网络套接字

我正在处理HiveMQ Websocket Client,但我遇到了message delivery 的一些问题。 所以,我遇到了PUBACK这个词 让我解释一下我的理解,然后我会问我的问题。 每当我们使用QOS1 发送消息时,hivemq 服务器都会通过PUBACK 回调确认发送者。 现在,我打算在我的 websockets 中订阅 onPubackReceived 事件,但是在发送消息后... »

在单线程 python 应用程序中同时使用 http 和 mqtt

我是 web 和 mqtt 编程的菜鸟,我正在开发一个使用 mqtt(通过 hivemq 或 rabbitmq 代理)的 python 应用程序,并且还需要为客户端实现 http rest api。 我意识到使用 python Bottle 框架很容易提供一个简单的 http 服务器,但是 Bottle 和 mqtt 都有它们的事件循环,我如何结合这两个事件循环,我想要一个单线程应用程序以避免复... »

Docker 从不同的来源拉取不同的架构

我有一个提取 FROM hivemq/hivemq-ce 的 Dockerfile。这适用于“标准”平台,但不适用于 Raspberry Pi。因此,我按照official HiveMQ repo 中的教程直接在RasPi 上为arm64 构建了映像,并将其推送到frederikheld/hivemq-ce。如果我将 FROM 行更改为 FROM frederikheld/hivemq-ce,Do... »

Paho-mqtt.client 可以连接到 digital-ocean mqtt 服务器但不能订阅

请帮我解决这个问题。我在这上面花了两天时间,但没有成功。 我正在使用 Paho-Mqtt python 客户端示例。我的 digitalocean debian 服务器上也有 HiveMq mqtt 服务器。 如果我在笔记本电脑或 linux Debian 机器上运行,python 中的客户端示例代码可以连接并订阅 digitalocean 服务器。但。这是但是。当我在 digitalocean... »

是否可以向未来发送消息?

是否有使用 MQTT 发布计划/延迟消息的最佳做法,例如,使用 Mosquitto 或 HiveMQ 代理? 用例是:告诉订阅者在 15 分钟内执行一些维护。 最好通过发布消息“请立即执行维护”来解决用例,并在消息中标记“不早于 15 分钟后交付”。... »